首页 > 代码库 > 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线程池的实现
声明:以上内容来自用户投稿及互联网公开渠道收集整理发布,本网站不拥有所有权,未作人工编辑处理,也不承担相关法律责任,若内容有误或涉及侵权可进行投诉: 投诉/举报 工作人员会在5个工作日内联系你,一经查实,本站将立刻删除涉嫌侵权内容。