从头认识java-17.7 执行器(Executor)(1)-线程池
2016-01-17 12:03
423 查看
这一章节我们来讨论一下Executor的第一个话题线程池。
1.什么是线程池?(下面的解释来自http://baike.haosou.com/doc/2511076-2653416.html)
线程池是一种多线程处理形式,处理过程中将任务添加到队列,然后在创建线程后自动启动这些任务。线程池线程都是后台线程。每个线程都使用默认的堆栈大小,以默认的优先级运行,并处于多线程单元中。如果某个线程在托管代码中空闲(如正在等待某个事件),则线程池将插入另一个辅助线程来使所有处理器保持繁忙。如果所有线程池线程都始终保持繁忙,但队列中包含挂起的工作,则线程池将在一段时间后创建另一个辅助线程但线程的数目永远不会超过最大值。超过最大值的线程可以排队,但他们要等到其他线程完成后才启动。
2.作用:
(1)集中管理线程
(2)提高线程的利用率,因为应用程序都会启动多个线程,而这些线程可能在大部分的时间里面都属于休眠或者等待状态,我们就需要把它们利用起来。
3.例子:
(1)系统自动管理线程数量
doing something...
17
(2)手动设置线程数量
输出:
doing something...
17
4.注意点:(1)创建线程池的时候我们可以根据实际情况来决定线程的数量或者是由系统决定
(2)使用submit方法提交Runnable或者Callable任务
(3)如果想取消任务或者提交了Callable任务,需要保存Future返回的对象
(4)最后记得加上shundown方法,关闭线程池。
总结:这一章节主要介绍了Executor的线程池。
这一章节就到这里,谢谢。
-----------------------------------
目录
1.什么是线程池?(下面的解释来自http://baike.haosou.com/doc/2511076-2653416.html)
线程池是一种多线程处理形式,处理过程中将任务添加到队列,然后在创建线程后自动启动这些任务。线程池线程都是后台线程。每个线程都使用默认的堆栈大小,以默认的优先级运行,并处于多线程单元中。如果某个线程在托管代码中空闲(如正在等待某个事件),则线程池将插入另一个辅助线程来使所有处理器保持繁忙。如果所有线程池线程都始终保持繁忙,但队列中包含挂起的工作,则线程池将在一段时间后创建另一个辅助线程但线程的数目永远不会超过最大值。超过最大值的线程可以排队,但他们要等到其他线程完成后才启动。
2.作用:
(1)集中管理线程
(2)提高线程的利用率,因为应用程序都会启动多个线程,而这些线程可能在大部分的时间里面都属于休眠或者等待状态,我们就需要把它们利用起来。
3.例子:
(1)系统自动管理线程数量
package com.ray.ch17; import java.util.Random; import java.util.concurrent.Callable; import java.util.concurrent.ExecutionException; import java.util.concurrent.ExecutorService; import java.util.concurrent.Executors; import java.util.concurrent.Future; public class Test { public static void main(String[] args) throws InterruptedException, ExecutionException { ExecutorService executors = Executors.newCachedThreadPool(); Callable<Integer> callable = new MyCall(); Future<Integer> future = executors.submit(callable); System.out.println(future.get()); executors.shutdown(); } } class MyCall implements Callable<Integer> { @Override public Integer call() throws Exception { System.out.println("doing something..."); Thread.sleep(1000); return new Random().nextInt(50); } }输出:
doing something...
17
(2)手动设置线程数量
package com.ray.ch17; import java.util.Random; import java.util.concurrent.Callable; import java.util.concurrent.ExecutionException; import java.util.concurrent.ExecutorService; import java.util.concurrent.Executors; import java.util.concurrent.Future; public class Test { public static void main(String[] args) throws InterruptedException, ExecutionException { ExecutorService executors = Executors.newFixedThreadPool(2); Callable<Integer> callable = new MyCall(); Future<Integer> future = executors.submit(callable); System.out.println(future.get()); executors.shutdown(); } } class MyCall implements Callable<Integer> { @Override public Integer call() throws Exception { System.out.println("doing something..."); Thread.sleep(1000); return new Random().nextInt(50); } }
输出:
doing something...
17
4.注意点:(1)创建线程池的时候我们可以根据实际情况来决定线程的数量或者是由系统决定
(2)使用submit方法提交Runnable或者Callable任务
(3)如果想取消任务或者提交了Callable任务,需要保存Future返回的对象
(4)最后记得加上shundown方法,关闭线程池。
总结:这一章节主要介绍了Executor的线程池。
这一章节就到这里,谢谢。
-----------------------------------
目录
相关文章推荐
- java正则表达式的学习
- 严重: Exception starting filter struts2 java.lang.NullPointerException
- Java 多线程:AtomicInteger源码分析——基于CAS的乐观锁实现
- hibernate、java、数据库对应类型
- Java 多线程:Condition 多线程同步关键字
- Chapter 2 Java Basic Grammar
- springmvc学习之安装spring tool suite
- kali 安装eclipse启动不了的问题
- 初学java——java数据类型,数据类型之间的转换
- java流与文件——内存映射文件
- eclipse 启动报错“An error occurred while automatically activating bundle com.android.ide.eclipse.adt (84
- Remove Duplicate Letters(Java 递归与非递归)
- 3、程序流程
- Web 开发IDE:NetBeans IDE For PHP 简体中文版 8.1
- [java01]Java基本数据类型
- [Java 8] (6) Lambda与资源管理
- 运行Myeclipse时,如何删除IVM窗口
- 运行Myeclipse时,如何删除IVM窗口
- java基础之数据类型
- ssh 整合 (spring + Struts2 + hibernate)