Java并发学习札记（2）在java中实现多线程的启动

?

使用线程池启动一个任务

(1)使用Executors中的工厂方法可以创建一个线程池:

? ?newFixedThreadPool:创建一个定长的线程池,每当提交一个任务就创建一个线程,知道达到池的最大长度,这时线程池会保持长度不再变化

? newCachedThreadPool:创建一个可缓存的线程池,如果当前线程池的长度超过了处理的需要时,它可以灵活地回收线程,所以此线程池的长度没有限制.

? newSingleThreadPool:创建一个单线程化的executor,它只创建唯一的工作线程来执行任务,如果这个线程异常结束,会有另一个取代它,executor会保证任务依照任务队列所规定的顺序(FIFO,LIFO,优先级)执行.

? ? ? ? ?newScheduledThreadPool定长的线程池,而且至支持定时的以及周期性的任务执行.

? ? i.?????????ScheduledThreadPool在java5中已经取缔了Timer.配合DelayQueue可以实现各种延时,定时任务.

? ? 1.????????DelayQueue中的对象都实现了Delayed接口此接口只有一个方法getDelay(TimeUnit)方法.此方法返回延迟还有多少时间DelayQueue只会将此方法返回值 ? ? ? ? ? ? ? ? ? ? ? ? ? ? 为0或??者小于0的对象取出.如果没有小于等于0的将会阻塞.

(2)以上方法返回一个ExecutoServicer对象,ExecutorService扩展了Executor.下面介绍下ExecutorService

? a)????????ExecutorService有3个状态:

? ? i.?????????运行.创建后的状态是运行.

? ? ii.???????关闭.调用shutdown方法后ExecutorService将停止接受新提交的任务,同时等待已经提交的任务完成.

? ? iii.????? 终止.一旦所有任务完成就会进入终止状态.
? ? isTerminated可以检测关闭后是否所有任务都完成.

? b)???????awaitTermination请求关闭、发生超时或者当前线程中断，无论哪一个首先发生之后，都将导致阻塞，直到所有任务完成执行。

(3)Executor使用Runnable作为其任务的基本表达形式.Runnable不能返回一个值,或者抛出受检查的异常.很多任务是需要返回值的.比如数据库查询.这是就需要Callable接口它的call方法允许返回结果.FutureTask可以包装一个Runnable或者Callable然后使用Executor执行任务.也可以使用Submit提交Callable或者Runnable会返回一个Future对象.FutureTask对象执行一次将保存call返回的结果.第二次使用get方法返回和第一次无异.没有执行结束的FutureTask执行其get方法会阻塞.

(4)CompletionService:Executor+BlockingQueue

? a)????????CompetionService的实现方法是ExecutorCompetionService,它的构造方法接受一个BlockingQueue<Future>参数或者使用submit提交任务,使用poll/take方法返回 ? ? ? ? ? 一个已经完成任务的Future

(5)ExecutorService:invokeAll

? a)????????List<Future> invokeAll(Collection<? extends Callable<T>>tasks, long timeout, TimeUnitunit)

? b)???????执行给定的任务，当所有任务完成或超时期满时（无论哪个首先发生），返回保持任务状态和结果的 Future 列表。