黑马程序员技术交流社区

标题: 【记录】代码练习-线程求和案例 [打印本页]
作者: Kevin.Kang    时间: 2015-8-6 13:55
标题: 【记录】代码练习-线程求和案例
  1. package com.kxg_07;

  3. import java.util.concurrent.Callable;

  5. public class MyCallable implements Callable<Integer> {
  6.        
  7.         private int number;
  8. //        定义带参构造
  9.         public MyCallable(int number) {
  10.                 this.number = number;
  11.         }

  13.         @Override
  14.         public Integer call() throws Exception {
  15. //                定义参数用来接收和
  16.                 int sum = 0;
  17.                
  18. //                求出和
  19.                 for (int i = 0; i < number; i++) {
  20.                         sum += i;
  21.                 }
  22.                
  23. //                返回和
  24.                 return sum;
  25.         }
  26. }
复制代码
  1. package com.kxg_07;

  3. /*
  4. * 利用Callable实现多线程求和
  5. *
  6. *                        
  7. *                         Future<?> submit(Runnable task)：添加Runnable实现类
  8. */
  9. import java.util.concurrent.ExecutionException;
  10. import java.util.concurrent.ExecutorService;
  11. import java.util.concurrent.Executors;
  12. import java.util.concurrent.Future;

  14. public class CallableDemo {
  15.         public static void main(String[] args) throws InterruptedException,
  16.                         ExecutionException {
  17.                 // 创建线程池
  18.                 ExecutorService pool = Executors.newFixedThreadPool(2);

  20.                 // 添加线程到线程中，添加方法是submit()，其返回值是Future<T>接口，用此接口接收
  21.                 // <T> Future<T> submit(Callable<T> task)：添加Callable实现类
  22.                 Future<Integer> f1 = pool.submit(new MyCallable(100));
  23.                 Future<Integer> f2 = pool.submit(new MyCallable(50));
  24.                
  25.                 // 用Future<T>接口下的T get()方法，得到Future<T>接口的泛型类型返回值，也就是线程的返回值
  26.                 Integer i1 = f1.get();
  27.                 Integer i2 = f2.get();
  28.                
  29.                 // 输出结果
  30.                 System.out.println(i1);
  31.                 System.out.println(i2);

  33.                 // 结束线程池
  34.                 pool.shutdown();
  35.         }
  36. }
复制代码






欢迎光临 黑马程序员技术交流社区 (http://bbs.itheima.com/) 黑马程序员IT技术论坛 X3.2