首页 > 代码库 > Java线程池的实现

Java线程池的实现

方法1:Java自带的线程池

采用Executors的factory method创建了固定大小的线程池,采用execute()方法添加Runnable Task。

1 ExecutorService threadPool = Executors.newFixedThreadPool(2);2 for (int i = 0; i < 4; i++)3      threadPool.execute(new InnerWork(i + ""));4 threadPool.shutdown();

内部实现是采用LinkedBlockingQueue。

技术分享 View Code

方法2:采用BlockingQueue编程实现一个大小可变的线程池。

思路:

1.线程池的功能有①执行线程任务execute();②停止线程任务shutdown()。

2.用BlockingQueue<Runnable> 存放Runnable Task,add(Runnable task)添加Task,take()取出Task执行。List<Thread> 保存线程,为了实现shutdown().

3.内部类的实现控制线程池。内部类采用while死循环来保证运行“实际运行的Task”运行,死循环可以保持线程不消亡。

 实现的线程池:MyThreadPool.java

技术分享 View Code

使用线程池:Main.java

技术分享 View Code


Java线程池的实现