(2.2.2.9)Future接口和FutureTask类【FutureTask实现了Runnable和Future接口】

时间:2021-02-25 04:37:47

API:

 

Java代码  (2.2.2.9)Future接口和FutureTask类【FutureTask实现了Runnable和Future接口】
  1. public interface Future<V> {  
  2.   
  3.     /** 
  4.      * Attempts to cancel execution of this task.  This attempt will 
  5.      * fail if the task has already completed, has already been cancelled, 
  6.      * or could not be cancelled for some other reason. If successful, 
  7.      * and this task has not started when <tt>cancel</tt> is called, 
  8.      * this task should never run.  If the task has already started, 
  9.      * then the <tt>mayInterruptIfRunning</tt> parameter determines 
  10.      * whether the thread executing this task should be interrupted in 
  11.      * an attempt to stop the task. 
  12.      */     
  13.     boolean cancel(boolean mayInterruptIfRunning);  
  14.   
  15.     /** 
  16.      * Returns <tt>true</tt> if this task was cancelled before it completed 
  17.      * normally. 
  18.      * 
  19.      * @return <tt>true</tt> if this task was cancelled before it completed 
  20.      */  
  21.     boolean isCancelled();  
  22.   
  23.     /** 
  24.      * Returns <tt>true</tt> if this task completed. 
  25.      * 
  26.      * Completion may be due to normal termination, an exception, or 
  27.      * cancellation -- in all of these cases, this method will return 
  28.      * <tt>true</tt>. 
  29.      * 
  30.      * @return <tt>true</tt> if this task completed 
  31.      */  
  32.     boolean isDone();  
  33.   
  34.     /** 
  35.      * Waits if necessary for the computation to complete, and then 
  36.      * retrieves its result. 
  37.      * 
  38.      * @return the computed result 
  39.      * @throws CancellationException if the computation was cancelled 
  40.      * @throws ExecutionException if the computation threw an 
  41.      * exception 
  42.      * @throws InterruptedException if the current thread was interrupted 
  43.      * while waiting 
  44.      */  
  45.     V get() throws InterruptedException, ExecutionException;  
  46.   
  47.     /** 
  48.      * Waits if necessary for at most the given time for the computation 
  49.      * to complete, and then retrieves its result, if available. 
  50.      * 
  51.      * @param timeout the maximum time to wait 
  52.      * @param unit the time unit of the timeout argument 
  53.      * @return the computed result 
  54.      * @throws CancellationException if the computation was cancelled 
  55.      * @throws ExecutionException if the computation threw an 
  56.      * exception 
  57.      * @throws InterruptedException if the current thread was interrupted 
  58.      * while waiting 
  59.      * @throws TimeoutException if the wait timed out 
  60.      */  
  61.     V get(long timeout, TimeUnit unit)  
  62.         throws InterruptedException, ExecutionException, TimeoutException;  
  63. }  

 

Java代码  (2.2.2.9)Future接口和FutureTask类【FutureTask实现了Runnable和Future接口】
  1. public interface Executor {      
  2.     void execute(Runnable command);    
  3. }   
  4.   
  5. public interface ExecutorService extends Executor {    
  6.     
  7.     <T> Future<T> submit(Callable<T> task);         
  8.     <T> Future<T> submit(Runnable task, T result);      
  9.     Future<?> submit(Runnable task);          
  10.     ...       
  11. }    
  12.   
  13. public class FutureTask<V>  extends Object    
  14.             implements Future<V>, Runnable {  
  15.       FutureTask(Callable<V> callable)     
  16.              //创建一个 FutureTask,一旦运行就执行给定的 Callable。      
  17.       FutureTask(Runnable runnable, V result)     
  18.              //创建一个 FutureTask,一旦运行就执行给定的 Runnable,并安排成功完成时 get 返回给定的结果 。    
  19. }  
  20. /*参数:   
  21. runnable - 可运行的任务。   
  22. result - 成功完成时要返回的结果。   
  23. 如果不需要特定的结果,则考虑使用下列形式的构造:Future<?> f = new FutureTask<Object>(runnable, null)  */  

  

单独使用Runnable时

        无法获得返回值

 

单独使用Callable时

        无法在新线程中(new Thread(Runnable r))使用,只能使用ExecutorService

        Thread类只支持Runnable

 

FutureTask

         实现了RunnableFuture,所以兼顾两者优点

         既可以使用ExecutorService,也可以使用Thread

 

Java代码  (2.2.2.9)Future接口和FutureTask类【FutureTask实现了Runnable和Future接口】
  1. Callable pAccount = new PrivateAccount();    
  2.     FutureTask futureTask = new FutureTask(pAccount);    
  3.     // 使用futureTask创建一个线程    
  4.     Thread thread = new Thread(futureTask);    
  5.     thread.start();    

  

=================================================================

public interface Future<V> Future 表示异步计算的结果。
Future有个get方法而获取结果只有在计算完成时获取,否则会一直阻塞直到任务转入完成状态,然后会返回结果或者抛出异常。 

  

Future 主要定义了5个方法: 

1)boolean cancel(boolean mayInterruptIfRunning):试图取消对此任务的执行。如果任务已完成、或已取消,或者由于某些其他原因而无法取消,则此尝试将失败。当调用 cancel 时,如果调用成功,而此任务尚未启动,则此任务将永不运行。如果任务已经启动,则 mayInterruptIfRunning 参数确定是否应该以试图停止任务的方式来中断执行此任务的线程。此方法返回后,对 isDone() 的后续调用将始终返回 true。如果此方法返回 true,则对 isCancelled() 的后续调用将始终返回 true。 


2)boolean isCancelled():如果在任务正常完成前将其取消,则返回 true。 
3)boolean isDone():如果任务已完成,则返回 true。 可能由于正常终止、异常或取消而完成,在所有这些情况中,此方法都将返回 true。 
4)V get()throws InterruptedException,ExecutionException:如有必要,等待计算完成,然后获取其结果。 
5)V get(long timeout,TimeUnit unit) throws InterruptedException,ExecutionException,TimeoutException:如有必要,最多等待为使计算完成所给定的时间之后,获取其结果(如果结果可用)。

 

Java代码  (2.2.2.9)Future接口和FutureTask类【FutureTask实现了Runnable和Future接口】
  1. public class FutureTask<V>  extends Object  
  2.     implements Future<V>, Runnable  
Future是一个接口, FutureTask类是Future 的一个实现类,并实现了Runnable,因此FutureTask可以传递到线程对象Thread中新建一个线程执行。所以可通过Excutor(线程池) 来执行,也可传递给Thread对象执行。如果在主线程中需要执行比较耗时的操作时,但又不想阻塞主线程时,可以把这些作业交给Future对象在后台完成,当主线程将来需要时,就可以通过Future对象获得后台作业的计算结果或者执行状态。 

FutureTask是为了弥补Thread的不足而设计的,它可以让程序员准确地知道线程什么时候执行完成并获得到线程执行完成后返回的结果(如果有需要)。

 

FutureTask是一种可以取消的异步的计算任务。它的计算是通过Callable实现的,它等价于可以携带结果的Runnable,并且有三个状态:等待、运行和完成。完成包括所有计算以任意的方式结束,包括正常结束、取消和异常。

Executor框架利用FutureTask来完成异步任务,并可以用来进行任何潜在的耗时的计算。一般FutureTask多用于耗时的计算,主线程可以在完成自己的任务后,再去获取结果。

  FutureTask多用于耗时的计算,主线程可以在完成自己的任务后,再去获取结果

 

JDK:

此类提供了对 Future 的基本实现。仅在计算完成时才能检索结果;如果计算尚未完成,则阻塞 get 方法。一旦计算完成,就不能再重新开始或取消计算。

 

可使用 FutureTask 包装 Callable 或 Runnable 对象。因为 FutureTask 实现了 Runnable,所以可将 FutureTask 提交给 Executor 执行。

 

 

Java代码  (2.2.2.9)Future接口和FutureTask类【FutureTask实现了Runnable和Future接口】
  1. //构造方法摘要  
  2. FutureTask(Callable<V> callable)   
  3.           //创建一个 FutureTask,一旦运行就执行给定的 Callable。  
  4.   
  5. FutureTask(Runnable runnable, V result)   
  6.           //创建一个 FutureTask,一旦运行就执行给定的 Runnable,并安排成功完成时 get 返回给定的结果 。  
  7. //参数:  
  8. runnable - 可运行的任务。  
  9. result - 成功完成时要返回的结果。  
  10. 如果不需要特定的结果,则考虑使用下列形式的构造:Future<?> f = new FutureTask<Object>(runnable, null)  

 

Example1:

下面的例子模拟一个会计算账的过程,主线程已经获得其他帐户的总额了,为了不让主线程等待 PrivateAccount类的计算结果的返回而启用新的线程去处理, 并使用 FutureTask对象来监控,这样,主线程还可以继续做其他事情, 最后需要计算总额的时候再尝试去获得privateAccount 的信息。 

 

Java代码  (2.2.2.9)Future接口和FutureTask类【FutureTask实现了Runnable和Future接口】
  1. package test;  
  2.   
  3. import java.util.Random;  
  4. import java.util.concurrent.Callable;  
  5. import java.util.concurrent.ExecutionException;  
  6. import java.util.concurrent.FutureTask;  
  7.   
  8. /** 
  9.  * 
  10.  * @author Administrator 
  11.  * 
  12.  */  
  13. @SuppressWarnings("all")  
  14. public class FutureTaskDemo {  
  15.     public static void main(String[] args) {  
  16.         // 初始化一个Callable对象和FutureTask对象  
  17.         Callable pAccount = new PrivateAccount();  
  18.         FutureTask futureTask = new FutureTask(pAccount);  
  19.         // 使用futureTask创建一个线程  
  20.         Thread pAccountThread = new Thread(futureTask);  
  21.         System.out.println("futureTask线程现在开始启动,启动时间为:" + System.nanoTime());  
  22.         pAccountThread.start();  
  23.         System.out.println("主线程开始执行其他任务");  
  24.         // 从其他账户获取总金额  
  25.         int totalMoney = new Random().nextInt(100000);  
  26.         System.out.println("现在你在其他账户中的总金额为" + totalMoney);  
  27.         System.out.println("等待私有账户总金额统计完毕...");  
  28.         // 测试后台的计算线程是否完成,如果未完成则等待  
  29.         while (!futureTask.isDone()) {  
  30.             try {  
  31.                 Thread.sleep(500);  
  32.                 System.out.println("私有账户计算未完成继续等待...");  
  33.             } catch (InterruptedException e) {  
  34.                 e.printStackTrace();  
  35.             }  
  36.         }  
  37.         System.out.println("futureTask线程计算完毕,此时时间为" + System.nanoTime());  
  38.         Integer privateAccountMoney = null;  
  39.         try {  
  40.             privateAccountMoney = (Integer) futureTask.get();  
  41.         } catch (InterruptedException e) {  
  42.             e.printStackTrace();  
  43.         } catch (ExecutionException e) {  
  44.             e.printStackTrace();  
  45.         }  
  46.         System.out.println("您现在的总金额为:" + totalMoney + privateAccountMoney.intValue());  
  47.     }  
  48. }  
  49.   
  50. @SuppressWarnings("all")  
  51. class PrivateAccount implements Callable {  
  52.     Integer totalMoney;  
  53.   
  54.     @Override  
  55.     public Object call() throws Exception {  
  56.         Thread.sleep(5000);  
  57.         totalMoney = new Integer(new Random().nextInt(10000));  
  58.         System.out.println("您当前有" + totalMoney + "在您的私有账户中");  
  59.         return totalMoney;  
  60.     }  
  61.   
  62. }  

 运行结果   

(2.2.2.9)Future接口和FutureTask类【FutureTask实现了Runnable和Future接口】
 

      来源:
http://zheng12tian.iteye.com/blog/991484
       
Example2: Java代码  (2.2.2.9)Future接口和FutureTask类【FutureTask实现了Runnable和Future接口】
  1. public class FutureTaskSample {  
  2.       
  3.     static FutureTask<String> future = new FutureTask(new Callable<String>(){  
  4.         public String call(){  
  5.             return getPageContent();  
  6.         }  
  7.     });  
  8.       
  9.     public static void main(String[] args) throws InterruptedException, ExecutionException{  
  10.         //Start a thread to let this thread to do the time exhausting thing  
  11.         new Thread(future).start();  
  12.   
  13.         //Main thread can do own required thing first  
  14.         doOwnThing();  
  15.   
  16.         //At the needed time, main thread can get the result  
  17.         System.out.println(future.get());  
  18.     }  
  19.       
  20.     public static String doOwnThing(){  
  21.         return "Do Own Thing";  
  22.     }  
  23.     public static String getPageContent(){  
  24.         return "Callable method...";  
  25.     }  
  26. }  
 结果为:Callable method...
不科学啊,为毛??!   废话,因为就没打印
来源:http://tomyz0223.iteye.com/blog/1019924  改为这样,结果就正常: Java代码  (2.2.2.9)Future接口和FutureTask类【FutureTask实现了Runnable和Future接口】
  1. public class FutureTaskSample {    
  2.         
  3.     public static void main(String[] args) throws InterruptedException, ExecutionException{    
  4.         //Start a thread to let this thread to do the time exhausting thing    
  5.         Callable call = new MyCallable();  
  6.         FutureTask future = new FutureTask(call);  
  7.         new Thread(future).start();    
  8.     
  9.         //Main thread can do own required thing first    
  10.         //doOwnThing();    
  11.         System.out.println("Do Own Thing");    
  12.           
  13.         //At the needed time, main thread can get the result    
  14.         System.out.println(future.get());    
  15.     }    
  16.       
  17. }    
  18.   
  19.   
  20.     class MyCallable implements Callable<String>{  
  21.   
  22.         @Override  
  23.         public String call() throws Exception {  
  24.              return getPageContent();    
  25.         }  
  26.           
  27.         public String getPageContent(){    
  28.             return "Callable method...";    
  29.         }   
  30.     }  
 结果:
Do Own ThingCallable method...

 

 Example3:
Java代码  (2.2.2.9)Future接口和FutureTask类【FutureTask实现了Runnable和Future接口】
  1. import java.util.concurrent.Callable;  
  2.   
  3. public class Changgong implements Callable<Integer>{  
  4.   
  5.     private int hours=12;  
  6.     private int amount;  
  7.       
  8.     @Override  
  9.     public Integer call() throws Exception {  
  10.         while(hours>0){  
  11.             System.out.println("I'm working......");  
  12.             amount ++;  
  13.             hours--;  
  14.             Thread.sleep(1000);  
  15.         }  
  16.         return amount;  
  17.     }  
  18. }  
 Java代码  (2.2.2.9)Future接口和FutureTask类【FutureTask实现了Runnable和Future接口】
  1. public class Dizhu {  
  2.           
  3.     public static void main(String args[]){  
  4.         Changgong worker = new Changgong();  
  5.         FutureTask<Integer> jiangong = new FutureTask<Integer>(worker);  
  6.         new Thread(jiangong).start();  
  7.         while(!jiangong.isDone()){  
  8.             try {  
  9.                 System.out.println("看长工做完了没...");  
  10.                 Thread.sleep(1000);  
  11.             } catch (InterruptedException e) {  
  12.                 // TODO Auto-generated catch block  
  13.                 e.printStackTrace();  
  14.             }  
  15.         }  
  16.         int amount;  
  17.         try {  
  18.             amount = jiangong.get();  
  19.             System.out.println("工作做完了,上交了"+amount);  
  20.         } catch (InterruptedException e) {  
  21.             // TODO Auto-generated catch block  
  22.             e.printStackTrace();  
  23.         } catch (ExecutionException e) {  
  24.             // TODO Auto-generated catch block  
  25.             e.printStackTrace();  
  26.         }  
  27.     }  
  28. }  
 
结果: 看工人做完了没...
I'm working......
看工人做完了没...
I'm working......
看工人做完了没...
I'm working......
看工人做完了没...
I'm working......
看工人做完了没...
I'm working......
看工人做完了没...
I'm working......
看工人做完了没...
I'm working......
看工人做完了没...
I'm working......
看工人做完了没...
I'm working......
看工人做完了没...
I'm working......
看工人做完了没...
I'm working......
看工人做完了没...
I'm working......
看工人做完了没...
工作做完了,上交了12
 Java代码  (2.2.2.9)Future接口和FutureTask类【FutureTask实现了Runnable和Future接口】
  1. /** 
  2.  * Factory and utility methods for {@link Executor}, {@link 
  3.  * ExecutorService}, {@link ScheduledExecutorService}, {@link 
  4.  * ThreadFactory}, and {@link Callable} classes defined in this 
  5.  * package. This class supports the following kinds of methods: 
  6.  * 
  7.  * <ul> 
  8.  *   <li> Methods that create and return an {@link ExecutorService} 
  9.  *        set up with commonly useful configuration settings. 
  10.  *   <li> Methods that create and return a {@link ScheduledExecutorService} 
  11.  *        set up with commonly useful configuration settings. 
  12.  *   <li> Methods that create and return a "wrapped" ExecutorService, that 
  13.  *        disables reconfiguration by making implementation-specific methods 
  14.  *        inaccessible. 
  15.  *   <li> Methods that create and return a {@link ThreadFactory} 
  16.  *        that sets newly created threads to a known state. 
  17.  *   <li> Methods that create and return a {@link Callable} 
  18.  *        out of other closure-like forms, so they can be used 
  19.  *        in execution methods requiring <tt>Callable</tt>. 
  20.  * </ul> 
  21.  * 
  22.  * @since 1.5 
  23.  * @author Doug Lea 
  24.  */  
  25. public class Executors {  
  26.   
  27.     /** 
  28.      * Creates a thread pool that reuses a fixed number of threads 
  29.      * operating off a shared unbounded queue.  At any point, at most 
  30.      * <tt>nThreads</tt> threads will be active processing tasks. 
  31.      * If additional tasks are submitted when all threads are active, 
  32.      * they will wait in the queue until a thread is available. 
  33.      * If any thread terminates due to a failure during execution 
  34.      * prior to shutdown, a new one will take its place if needed to 
  35.      * execute subsequent tasks.  The threads in the pool will exist 
  36.      * until it is explicitly {@link ExecutorService#shutdown shutdown}. 
  37.      * 
  38.      * @param nThreads the number of threads in the pool 
  39.      * @return the newly created thread pool 
  40.      * @throws IllegalArgumentException if <tt>nThreads &lt;= 0</tt> 
  41.      */  
  42.     public static ExecutorService newFixedThreadPool(int nThreads) {  
  43.         return new ThreadPoolExecutor(nThreads, nThreads,  
  44.                                       0L, TimeUnit.MILLISECONDS,  
  45.                                       new LinkedBlockingQueue<Runnable>());  
  46.     }  
  47.   
  48.     /** 
  49.      * Creates a thread pool that reuses a fixed number of threads 
  50.      * operating off a shared unbounded queue, using the provided 
  51.      * ThreadFactory to create new threads when needed.  At any point, 
  52.      * at most <tt>nThreads</tt> threads will be active processing 
  53.      * tasks.  If additional tasks are submitted when all threads are 
  54.      * active, they will wait in the queue until a thread is 
  55.      * available.  If any thread terminates due to a failure during 
  56.      * execution prior to shutdown, a new one will take its place if 
  57.      * needed to execute subsequent tasks.  The threads in the pool will 
  58.      * exist until it is explicitly {@link ExecutorService#shutdown 
  59.      * shutdown}. 
  60.      * 
  61.      * @param nThreads the number of threads in the pool 
  62.      * @param threadFactory the factory to use when creating new threads 
  63.      * @return the newly created thread pool 
  64.      * @throws NullPointerException if threadFactory is null 
  65.      * @throws IllegalArgumentException if <tt>nThreads &lt;= 0</tt> 
  66.      */  
  67.     public static ExecutorService newFixedThreadPool(int nThreads, ThreadFactory threadFactory) {  
  68.         return new ThreadPoolExecutor(nThreads, nThreads,  
  69.                                       0L, TimeUnit.MILLISECONDS,  
  70.                                       new LinkedBlockingQueue<Runnable>(),  
  71.                                       threadFactory);  
  72.     }  
  73.   
  74.     /** 
  75.      * Creates an Executor that uses a single worker thread operating 
  76.      * off an unbounded queue. (Note however that if this single 
  77.      * thread terminates due to a failure during execution prior to 
  78.      * shutdown, a new one will take its place if needed to execute 
  79.      * subsequent tasks.)  Tasks are guaranteed to execute 
  80.      * sequentially, and no more than one task will be active at any 
  81.      * given time. Unlike the otherwise equivalent 
  82.      * <tt>newFixedThreadPool(1)</tt> the returned executor is 
  83.      * guaranteed not to be reconfigurable to use additional threads. 
  84.      * 
  85.      * @return the newly created single-threaded Executor 
  86.      */  
  87.     public static ExecutorService newSingleThreadExecutor() {  
  88.         return new FinalizableDelegatedExecutorService  
  89.             (new ThreadPoolExecutor(11,  
  90.                                     0L, TimeUnit.MILLISECONDS,  
  91.                                     new LinkedBlockingQueue<Runnable>()));  
  92.     }  
  93.   
  94.     /** 
  95.      * Creates an Executor that uses a single worker thread operating 
  96.      * off an unbounded queue, and uses the provided ThreadFactory to 
  97.      * create a new thread when needed. Unlike the otherwise 
  98.      * equivalent <tt>newFixedThreadPool(1, threadFactory)</tt> the 
  99.      * returned executor is guaranteed not to be reconfigurable to use 
  100.      * additional threads. 
  101.      * 
  102.      * @param threadFactory the factory to use when creating new 
  103.      * threads 
  104.      * 
  105.      * @return the newly created single-threaded Executor 
  106.      * @throws NullPointerException if threadFactory is null 
  107.      */  
  108.     public static ExecutorService newSingleThreadExecutor(ThreadFactory threadFactory) {  
  109.         return new FinalizableDelegatedExecutorService  
  110.             (new ThreadPoolExecutor(11,  
  111.                                     0L, TimeUnit.MILLISECONDS,  
  112.                                     new LinkedBlockingQueue<Runnable>(),  
  113.                                     threadFactory));  
  114.     }  
  115.   
  116.     /** 
  117.      * Creates a thread pool that creates new threads as needed, but 
  118.      * will reuse previously constructed threads when they are 
  119.      * available.  These pools will typically improve the performance 
  120.      * of programs that execute many short-lived asynchronous tasks. 
  121.      * Calls to <tt>execute</tt> will reuse previously constructed 
  122.      * threads if available. If no existing thread is available, a new 
  123.      * thread will be created and added to the pool. Threads that have 
  124.      * not been used for sixty seconds are terminated and removed from 
  125.      * the cache. Thus, a pool that remains idle for long enough will 
  126.      * not consume any resources. Note that pools with similar 
  127.      * properties but different details (for example, timeout parameters) 
  128.      * may be created using {@link ThreadPoolExecutor} constructors. 
  129.      * 
  130.      * @return the newly created thread pool 
  131.      */  
  132.     public static ExecutorService newCachedThreadPool() {  
  133.         return new ThreadPoolExecutor(0, Integer.MAX_VALUE,  
  134.                                       60L, TimeUnit.SECONDS,  
  135.                                       new SynchronousQueue<Runnable>());  
  136.     }  
  137.   
  138.     /** 
  139.      * Creates a thread pool that creates new threads as needed, but 
  140.      * will reuse previously constructed threads when they are 
  141.      * available, and uses the provided 
  142.      * ThreadFactory to create new threads when needed. 
  143.      * @param threadFactory the factory to use when creating new threads 
  144.      * @return the newly created thread pool 
  145.      * @throws NullPointerException if threadFactory is null 
  146.      */  
  147.     public static ExecutorService newCachedThreadPool(ThreadFactory threadFactory) {  
  148.         return new ThreadPoolExecutor(0, Integer.MAX_VALUE,  
  149.                                       60L, TimeUnit.SECONDS,  
  150.                                       new SynchronousQueue<Runnable>(),  
  151.                                       threadFactory);  
  152.     }  
  153.   
  154.     /** 
  155.      * Creates a single-threaded executor that can schedule commands 
  156.      * to run after a given delay, or to execute periodically. 
  157.      * (Note however that if this single 
  158.      * thread terminates due to a failure during execution prior to 
  159.      * shutdown, a new one will take its place if needed to execute 
  160.      * subsequent tasks.)  Tasks are guaranteed to execute 
  161.      * sequentially, and no more than one task will be active at any 
  162.      * given time. Unlike the otherwise equivalent 
  163.      * <tt>newScheduledThreadPool(1)</tt> the returned executor is 
  164.      * guaranteed not to be reconfigurable to use additional threads. 
  165.      * @return the newly created scheduled executor 
  166.      */  
  167.     public static ScheduledExecutorService newSingleThreadScheduledExecutor() {  
  168.         return new DelegatedScheduledExecutorService  
  169.             (new ScheduledThreadPoolExecutor(1));  
  170.     }  
  171.   
  172.     /** 
  173.      * Creates a single-threaded executor that can schedule commands 
  174.      * to run after a given delay, or to execute periodically.  (Note 
  175.      * however that if this single thread terminates due to a failure 
  176.      * during execution prior to shutdown, a new one will take its 
  177.      * place if needed to execute subsequent tasks.)  Tasks are 
  178.      * guaranteed to execute sequentially, and no more than one task 
  179.      * will be active at any given time. Unlike the otherwise 
  180.      * equivalent <tt>newScheduledThreadPool(1, threadFactory)</tt> 
  181.      * the returned executor is guaranteed not to be reconfigurable to 
  182.      * use additional threads. 
  183.      * @param threadFactory the factory to use when creating new 
  184.      * threads 
  185.      * @return a newly created scheduled executor 
  186.      * @throws NullPointerException if threadFactory is null 
  187.      */  
  188.     public static ScheduledExecutorService newSingleThreadScheduledExecutor(ThreadFactory threadFactory) {  
  189.         return new DelegatedScheduledExecutorService  
  190.             (new ScheduledThreadPoolExecutor(1, threadFactory));  
  191.     }  
  192.   
  193.     /** 
  194.      * Creates a thread pool that can schedule commands to run after a 
  195.      * given delay, or to execute periodically. 
  196.      * @param corePoolSize the number of threads to keep in the pool, 
  197.      * even if they are idle. 
  198.      * @return a newly created scheduled thread pool 
  199.      * @throws IllegalArgumentException if <tt>corePoolSize &lt; 0</tt> 
  200.      */  
  201.     public static ScheduledExecutorService newScheduledThreadPool(int corePoolSize) {  
  202.         return new ScheduledThreadPoolExecutor(corePoolSize);  
  203.     }  
  204.   
  205.     /** 
  206.      * Creates a thread pool that can schedule commands to run after a 
  207.      * given delay, or to execute periodically. 
  208.      * @param corePoolSize the number of threads to keep in the pool, 
  209.      * even if they are idle. 
  210.      * @param threadFactory the factory to use when the executor 
  211.      * creates a new thread. 
  212.      * @return a newly created scheduled thread pool 
  213.      * @throws IllegalArgumentException if <tt>corePoolSize &lt; 0</tt> 
  214.      * @throws NullPointerException if threadFactory is null 
  215.      */  
  216.     public static ScheduledExecutorService newScheduledThreadPool(  
  217.             int corePoolSize, ThreadFactory threadFactory) {  
  218.         return new ScheduledThreadPoolExecutor(corePoolSize, threadFactory);  
  219.     }  
  220.     ........  
  221.   
  222.     /** Cannot instantiate. */  
  223.     private Executors() {}  
  224. }