/** * * @描述: Callable Future * * 程序运行一个线程,线程运行结束后,我们可以获取另一个线程的结果 * * @作者: Wnj . * @创建时间: 2017年5月16日 . * @版本: 1.0 . */ public class CallableAndFuture { /** * 单个任务 * <功能详细描述> */ public static void single() { ExecutorService threadPool = Executors.newSingleThreadExecutor(); /** * 需要返回结果的就使用submit */ Future<String> future = threadPool.submit(new Callable<String>() { public String call() throws Exception { Thread.sleep(2000); return "hello"; }; }); System.out.println("等待拿到结果"); try { System.out.println("拿到结果" + future.get()); // System.out.println("拿到结果" + future.get(1,TimeUnit.SECONDS));//1秒钟内必须返回 } catch (InterruptedException e) { e.printStackTrace(); } catch (Exception e) { e.printStackTrace(); } } /** * 多个任务 * <功能详细描述> */ public static void array() { ExecutorService threadPool2 = Executors.newFixedThreadPool(10); /** * 一定就提交一组Callable任务,只要一个任务完成了就能获取到结果 */ CompletionService<Integer> completionService = new ExecutorCompletionService<Integer>(threadPool2); for (int i = 1; i <= 10; i++) { final int seq = i; completionService.submit(new Callable<Integer>() { @Override public Integer call() throws Exception { Thread.sleep(new Random().nextInt(5000)); return seq; } }); } for (int i = 0; i < 10; i++) { try { System.out.println(completionService.take().get()); } catch (InterruptedException e) { e.printStackTrace(); } catch (ExecutionException e) { e.printStackTrace(); } } } /** * @param args */ public static void main(String[] args) { array(); }
时间: 2024-11-09 22:48:33