Java四种线程池的使用.

1、Java 四种线程池的使用/* 创建简单的线程 */public class MultiThreading Test public voidthreadTest( (new Thread( Override public voidrun( System.out.pri ntl n(threadi ng. ; .start(; Test public void runn ableTest( new Thread( new Runn able( Override publicvoid run( System.out.pri ntl n(r unn able Ing.; .start(; /* *

2、线程池 */ Test public void poolMultiTest( ExecutorService pool = Executors .newFixedThreadPool(3; for (int i = 0; i 10; i+ final int in dex = i; try Thread.sleep(1000; catch (In terruptedExcepti on e e.pri ntStackTrace(; pool.execute( new Runnable( Override public voidrun( System.out.pri ntln (i ndex;

3、; /* *创建一个缓存线程池，如果线程池长度超过处理需要，可灵活的回收空 闲的线程，若无回收的线程，则新建线程*/ Test public void newCachedThreadPoolTest( ExecutorService pool = Executors .n ewCachedThreadPool(;for (i nt i = 0; i 10; i+ final int index = i; try Thread.sleep( in dex*1000; catch(In terruptedExceptio n e e.pri ntStackTrace(; pool.execute(

4、 newRunn able( Override public void run( System.out.pri ntln (i ndex; ; /* *创建一个定长的线程池，可控制最大并发数，超出线程的在队列中等待，*定线程池的大小最好根据系统资源设置，Runtime.getRuntime(.availableProcessors( * *输入 index 的 3 位数字，5 秒之后右输出 3 位数字，知道输出完毕*/Test public void n ewFixedThreadPoolTest( ExecutorService pool =Executors. newFixedThread

5、Pool(R un time.getR un time(.availableProcessors(; for (int i =0;i 10; i+ final int in dex = i; pool.execute( new Runn able( Override public voidrun( System.out.pri ntln (i ndex; try Thread.sleep(5000; catch (In terruptedExcepti on e e.pri ntStackTrace(; ; /* *创建一个定长线程池，支持周期性的任务执行，延迟代码如下*表示延迟 3 秒执行。

6、*/ Test public voidn ewScheduledThreadPoolTest( ScheduledExecutorService pool=Executors .newScheduledThreadPool(5; pool.schedule( new Runn able( Override public voidrun( System.out.pri ntln (delay 3 seco nds; , 3, TimeU nit.SECONDS; /* *创建一个定长线程池，支持周期性的任务执行，延迟代码如下* *表示延迟 1秒后每 3 秒执行一次。*/ Test public

7、voidscheduleAtFixedRateTest( ScheduledExecutorService pool=Executors .newScheduledThreadPool(5; pool.scheduleAtFixedRate( newRunn able( Override public void run( System.out.pri ntl n(delay 3 sec on ds; ,1,3,TimeU nit.SECONDS; /* *创建一个单线程化的线程池，它只会用唯一的工作线程来执行任务，保 证所有任务按照指定顺序(FIFO, LIFO,优先级执行。示例代码如下：*

8、*结果依次 输出，相当于顺序执行各个任务。*你可以使用 JDK 自带的监控工具来监控我们 创建的线程数量，运行一个不终止的线程，创建指定量的线程，来观察：*工具目录：C:Program FilesJavajdk1.6.0_06binjconsole.exe */ Test public void n ewSi ngleThreadExecutorTest( ExecutorServicesi ngleThreadExecutor=Executors. newSi ngleThreadExecutor(; for (int i = 0; i 10; i+ final int in dex=i;

9、sin gleThreadExecutor.execute( new Runn able( Override public voidrun( System.out.println(index; ; /* * 你可以使用 JDK 自带的监控工具来 监控我们创建的线程数量，运行一个不终止的线程，创建指定量的线程，来观察：* 工具目录：C:Program FilesJavajdk1.6.0_06bi njcon sole.exe *运行程序做稍微修 改: */Test public void n ewCachedThreadPoolLoopTest( ExecutorServicecachedThreadPool=Executors .n ewCachedThreadPool(; for (int i = 0; i 10; i+ final int index=i; cachedThreadPool.execute( new Runn able( Override public voidrun( while(true System.out.println(index; try Thread.sleep(1000; catch(In terruptedExceptio n e e.pri ntStackTrace(; ; try Thre