码迷,mamicode.com
首页 > 编程语言 > 详细

Java 线程池的原理与实现学习(二)

时间:2015-02-06 14:41:55      阅读:215      评论:0      收藏:0      [点我收藏+]

标签:

摘自:http://www.cnblogs.com/lxzh/archive/2013/01/20/2868736.html

  • execute(Runnable command):履行Ruannable类型的任务
  • submit(task):可用来提交Callable或Runnable任务,并返回代表此任务的Future对象
  • invokeAll(collection of tasks):执行给定的任务,当所有任务完成时,返回保持任务状态和结果的 Future 列表.
  • shutdown():在完成已提交的任务后封闭办事,不再接管新任务
  • shutdownNow():停止所有正在履行的任务并封闭办事。
  • isTerminated():测试是否所有任务都履行完毕了。
  • isShutdown():测试是否该ExecutorService已被封闭

1、固定大小线程池

import java.util.concurrent.Executors; 

import java.util.concurrent.ExecutorService;

ExecutorService pool = Executors.newFixedThreadPool(2);

pool.execute(t1);

pool.shutdown();

2、单任务线程池

ExecutorService pool = Executors.newSingleThreadExecutor();

3、可变尺寸线程池

ExecutorService pool = Executors.newCachedThreadPool();

4、延迟连接池

import java.util.concurrent.Executors; 

import java.util.concurrent.ScheduledExecutorService; 

import java.util.concurrent.TimeUnit;

ScheduledExecutorService pool = Executors.newScheduledThreadPool(2);

pool.schedule(t4, 10, TimeUnit.MILLISECONDS);

5、单任务延迟连接池

ScheduledExecutorService pool = Executors.newSingleThreadScheduledExecutor();

 

1.schedule         

  schedule(Runnable command, long delay, TimeUnit unit),schedule方法被用来延迟指定时间后执行某个指定任务。  

a.代码如下:

Java代码 技术分享

  1. public class Job implements Runnable { 
  2.     SimpleDateFormat sdf = new SimpleDateFormat("yyyy-MM-dd hh:mm:ss"); 
  3. public void run() { 
  4. try { 
  5.             Thread.sleep(5000); 
  6.         } catch (InterruptedException ex) { 
  7.             ex.printStackTrace(); 
  8.         } 
  9.         System.out.println("do something  at:" + sdf.format(new Date())); 
  10.     } 
  11. public class ScheduledExecutorServiceTest { 
  12. public static void main(String[] args) { 
  13.         ScheduledExecutorService schedule = Executors.newScheduledThreadPool(5); 
  14. final SimpleDateFormat sdf = new SimpleDateFormat("yyyy-MM-dd hh:mm:ss"); 
  15.         System.out.println(" begin to do something at:" + sdf.format(new Date())); 
  16.         schedule.schedule(new Job(),1, TimeUnit.SECONDS); 
  17.     } 

b.输出如下:

  1. begin to do something at:2012-08-03 09:31:36
  2. do something  at:2012-08-03 09:31:42

注:此时程序不会退出,若想让程序退出,需要加上schedule.shutdown();

 

ScheduledExecutorService 中两种最常用的调度方法 ScheduleAtFixedRateScheduleWithFixedDelay

ScheduleAtFixedRate 每次执行时间为上一次任务开始起向后推一个时间间隔,即每次执行时间为 :initialDelay, initialDelay+period, initialDelay+2*period, …;ScheduleWithFixedDelay 每次执行时间为上一次任务结束起向后推一个时间间隔,即每次执行时间为:initialDelay, initialDelay+executeTime+delay, initialDelay+2*executeTime+2*delay。

由此可见,ScheduleAtFixedRate 是基于固定时间间隔进行任务调度,ScheduleWithFixedDelay 取决于每次任务执行的时间长短,是基于不固定时间间隔进行任务调度。

 

2.scheduleWithFixedDelay             

   scheduleWithFixedDelay(Runnable command, long initialDelay, long delay,TimeUnit unit)         

       创建并执行一个在给定初始延迟后首次启用的定期操作,随后,在每一次执行终止和下一次执行开始之间都存在给定的延迟,如果任务的执行时间超过了廷迟时间(delay),下一个任务则会在当前任务执行所需时间+delay)后执行。    

a.代码如下:

Java代码 技术分享

  1. public class ScheduledExecutorServiceTest { 
  2. public static void main(String[] args) { 
  3.             ScheduledExecutorService schedule = Executors.newScheduledThreadPool(5); 
  4. final SimpleDateFormat sdf = new SimpleDateFormat("yyyy-MM-dd hh:mm:ss"); 
  5.             System.out.println(" begin to do something at:" + sdf.format(new Date())); 
  6.             schedule.scheduleWithFixedDelay(new Job(), 1, 2, TimeUnit.SECONDS); 
  7.         } 
  8.     } 

    b.输出如下:

  1. begin to do something at:2012-08-03 09:36:53
  2. do something at:2012-08-03 09:36:59
  3. do something at:2012-08-03 09:37:06
  4. do something at:2012-08-03 09:37:13

 

3.scheduleAtFixedRate             

   scheduleAtFixedRate(Runnable command, long initialDelay, long period, TimeUnitunit)            

      创建并执行一个在给定初始延迟后首次启用的定期操作,后续操作具有给定的周期;也就是将在 initialDelay 后开始执行,然后在initialDelay+period 后执行,接着在 initialDelay + 2 * period 后执行,依此类推。     如果任务的执行时间小于period,将会按上述规律执行。否则,则会按 任务的实际执行时间进行周期执行。      

a.代码如下:

  1. public class ScheduledExecutorServiceTest { 
  2. public static void main(String[] args) { 
  3.         ScheduledExecutorService schedule = Executors.newScheduledThreadPool(2); 
  4. final SimpleDateFormat sdf = new SimpleDateFormat("yyyy-MM-dd hh:mm:ss"); 
  5.         System.out.println(" begin to do something at:" + sdf.format(new Date())); 
  6.         schedule.scheduleAtFixedRate(new Job(), 1,2, TimeUnit.SECONDS); 
  7.     } 

    b.结果输出:

  1. begin to do something at:2012-08-04 08:53:30
  2. do something at:2012-08-04 08:53:36
  3. do something at:2012-08-04 08:53:41
  4. do something at:2012-08-04 08:53:46
  5. do something at:2012-08-04 08:53:51

 

Java 线程池的原理与实现学习(二)

标签:

原文地址:http://www.cnblogs.com/whsa/p/4277001.html

(0)
(0)
   
举报
评论 一句话评论(0
登录后才能评论!
© 2014 mamicode.com 版权所有  联系我们:gaon5@hotmail.com
迷上了代码!