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 task = () -> fibonacci(30); ExecutorService executor = Executors.newFixedThreadPool(1); Future future = executor.submit(task); System.out.println("计算第10个斐波那契级数，过会来取...") ; while (future.isDone() == false) { System.out.println("忙别的去吧，结果还在计算中...") ; } System.out.printf("计算完毕，第10个斐波那契级数是:%d %n", future.get()) ; } } 

 <i style="color:transparent">来源gaodai$ma#com搞$代*码网</i>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(); } }