1. package com.kxg_07;
   
2. 
   
3. import java.util.concurrent.Callable;
   
4. 
   
5. public class MyCallable implements Callable<Integer> {
   
6.        
   
7.         private int number;
   
8. //        定义带参构造
   
9.         public MyCallable(int number) {
   
10.                 this.number = number;
    
11.         }
    
12. 
    
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;
   
2. 
   
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;
    
13. 
    
14. public class CallableDemo {
    
15.         public static void main(String[] args) throws InterruptedException,
    
16.                         ExecutionException {
    
17.                 // 创建线程池
    
18.                 ExecutorService pool = Executors.newFixedThreadPool(2);
    
19. 
    
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);
    
32. 
    
33.                 // 结束线程池
    
34.                 pool.shutdown();
    
35.         }
    
36. }

复制代码

1. package com.kxg_07;
   
2. 
   
3. import java.util.concurrent.Callable;
   
4. 
   
5. public class MyCallable implements Callable<Integer> {
   
6.        
   
7.         private int number;
   
8. //        定义带参构造
   
9.         public MyCallable(int number) {
   
10.                 this.number = number;
    
11.         }
    
12. 
    
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;
   
2. 
   
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;
    
13. 
    
14. public class CallableDemo {
    
15.         public static void main(String[] args) throws InterruptedException,
    
16.                         ExecutionException {
    
17.                 // 创建线程池
    
18.                 ExecutorService pool = Executors.newFixedThreadPool(2);
    
19. 
    
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);
    
32. 
    
33.                 // 结束线程池
    
34.                 pool.shutdown();
    
35.         }
    
36. }

复制代码