Java线程池的应用实例分析

import java.util.concurrent.*;public class FutureCallableDemo{  static long fibonacci(long n)  {    if (n == 1 ||n == 2)      return 1;    else      return fibonacci(n - 1) + fibonacci(n - 2);  }  public static void main( String[] args) throws Exception  {    Callable<Long> task = () -> fibonacci(30);    ExecutorService executor = Executors.newFixedThreadPool(1);    Future<Long> future = executor.submit(task);    System.out.println("计算第10个斐波那契级数，过会来取...") ;    while (future.isDone() == false)    {      System.out.println("忙别的去吧，结果还在计算中...") ;    }    System.out.printf("计算完毕，第10个斐波那契级数是:%d %n", future.get()) ;  }}

import java.util.concurrent.Executors;import java.util.concurrent.ThreadPoolExecutor;import java.util.concurrent.TimeUnit;class Task implements Runnable{  private String name;  public Task(String name)  {    this.name = name;  }  public String getName() {    return name;  }  @Override  public void run()  {    try    {      Long duration = (long) (Math.random() * 100);      System.out.println("正在做工中，执行者 : " + name);      TimeUnit.SECONDS.sleep(duration);    }    catch (InterruptedException e)    {      e.printStackTrace();    }  }}public class BasicThreadPoolExecutorExample{  public static void main(String[] args)  {    ThreadPoolExecutor executor = (ThreadPoolExecutor) Executors.newCachedThreadPool();    for (int i = 0; i <= 5; i++)    {      Task task = new Task("Task " + i);      System.out.println("新任务添加成功 : " + task.getName());      executor.execute(task);    }    executor.shutdown();  }}