线程池

标签：scheduled   ati   port   sch   为什么   ++   import   current   print   

import java.util.concurrent.ExecutorService;
import java.util.concurrent.Executors;
import java.util.concurrent.TimeUnit;

public class ThreadDemo5 {

　　public static void main(String[] args) {

/**
* 创建几个线程
* 下面只创建3个线程去执行任务task
* ExecutorService exe=Executors.newFixedThreadPool(3);
*
* 创建单个线程去执行任务（线程死掉会重新启动）
* ExecutorService threadPool = Executors.newSingleThreadExecutor();
*/


/**
* 创建线程缓冲区
* 下面会创建10个线程
*/
ExecutorService exe=Executors.newCachedThreadPool();
for( int j=0;j<10;j++){
final int fi=j; //为什么要用final
exe.execute(new Runnable(){

　　@Override
　　public void run() {

　　　　for(int i=0;i<10;i++)
　　　　{System.out.println(Thread.currentThread().getName()+" "+i+"次"+"task "+fi );}
　　}



　　}　　　　　　);
}

/**
* 定时器
*/
　　　　ExecutorService scheduled=Executors.newScheduledThreadPool(3);
　　　　Executors.newScheduledThreadPool(3).scheduleAtFixedRate //在固定速率调度
　　　　　　(new Runnable(){

　　　　　　@Override

　　　　　　public void run() {
　　　　　　System.out.print("bomb!");

　　　　　　}



　　　　　　}, 10, 2, TimeUnit.SECONDS); //10秒 2秒 单位


}

}

线程池

标签：scheduled   ati   port   sch   为什么   ++   import   current   print   

原文地址：http://www.cnblogs.com/yugeng/p/7858095.html