java线程池的使用

Java线程池的使用

1.4版本JDK线程池的代替 定义一个线程( TimerTask )

public class TimerTestTask extends TimerTask { private String name=\ public TimerTestTask(String name){ this.name=name; } public void run() { for(int i=0;i<10;i+=1){ System.out.println(\第\个-\说：你好\ } }

}

使用线程池调用( Timer )

public static void main(String[] args){ TimerTestTask tsk1=new TimerTestTask(\小明\ TimerTestTask tsk2=new TimerTestTask(\小红\ TimerTestTask tsk3=new TimerTestTask(\笨笨\ TimerTestTask tsk4=new TimerTestTask(\贝贝\ TimerTestTask tsk5=new TimerTestTask(\呆呆\

Timer timer=new Timer(); timer.schedule(tsk1,0L); timer.schedule(tsk2,0L); timer.schedule(tsk3,0L); timer.schedule(tsk4,0L); timer.schedule(tsk5,0L); System.out.println(\完成\

}

以下所使用的线程池功能必须在1.5JDK以上版本才能使用；

Executors.newFixedThreadPool - 固定数量的线程池

一个线程池是一批线程的操作容器；(例如:停车厂)

创建一个固定可用线程数量的线程池(newFixedThreadPool)，线程池这东西不会因为投放的数量过多，而自己没有足够的空闲线程报错；

同一时刻同时处理任务的线程越多，则平均性能越差，如果固定线程池配置线程数量为1则每个线程的执行效率很高。

同时创建多个线程池处理任务，性能会有很大影响吗？

一个线程池内的多个线程同时处理，性能上会有影响，但是A线程池内的线程，对B线程池内的线程性能上不会有影响。

FixedThreadPool是一个典型且优秀的线程池，它具有线程池提高程序效率和节省创建线程时所耗的开销的优点。但是，在线程池空闲时，即线程池中没有可运行任务时，它不会释放工作线程，还会占用一定的系统资源。

定义一个线程

public class ThreadTestRunnable implements Runnable { public String name; public ThreadTestRunnable(String name){ this.name=name; } public void run() { long lStart=(new Date()).getTime(); String s=\ for(int i=0;i<5000;i+=1){ s+=\ } long lEnd=(new Date()).getTime(); System.out.println( name+\执行完成:\ } }

使用线程池调用

//创建线程池A

ExecutorService execu = Executors.newFixedThreadPool(6); execu.execute(th1); execu.execute(th2); execu.execute(th3); execu.execute(th4); execu.execute(th5); execu.execute(th6); execu.shutdown();

//创建线程池B

execu = Executors.newFixedThreadPool(1); execu.execute(th1a); execu.execute(th2a); execu.execute(th3a); execu.execute(th4a); execu.execute(th5a); execu.execute(th6a); execu.shutdown();

Executors.newSingleThreadExecutor - 单线线程池

只创建唯一的工作者线程来执行任务，如果这个线程异常结束，会有另一个取代它，保证顺序执行(我觉得这点是它的特色)。单工作线程最大的特点是可保证顺序地执行各个任务，并且在任意给定的时间不会有多个线程是活动的 。

使用线程池

Thread th1=new Thread(new ThreadTestRunnable(\小明\ExecutorService execu = Executors.newSingleThreadExecutor(); execu.execute(th1); //启动 execu.shutdown(); //关闭

Executors.newCachedThreadPool - 缓存线程池

工作线程的创建数量几乎没有限制(其实也有限制的,数目为Interger. MAX_VALUE), 这样可灵活的往线程池中添加线程。

如果长时间没有往线程池中提交任务，即如果工作线程空闲了指定的时间(默认为1分钟)，则该工作线程将自动终止。终止后，如果你又提交了新的任务，则线程池重新创建一个工作线程。

线程池空闲时，即线程池中没有可运行任务时，它会释放工作线程，从而释放工作线程所占用的资源。但是，但当出现新任务时，又要创建一新的工作线程，又要一定的系统开销。并且，在使用CachedThreadPool时，一定要注意控制任务的数量，否则，由于大量线程同时运行，很有会造成系统瘫痪。

使用线程池

ExecutorService execu = Executors.newCachedThreadPool(); execu.execute(th1); execu.execute(th2); execu.shutdown();

newScheduleThreadPool - 定长线程池

略