Callable的使用

水深无声 2023-06-03 04:52 7阅读 0赞

**常用的线程创建的方式通常有两种：**

1.  继承Thread，重写run方法
2.  实现Runnable，重写run方法

**Callabel与Runable的不同：**  
Runnable是执行工作的独立任务，在JavaSE5中引入的**Callabel**是一种具有类型参数的泛型，它可以

1.  在任务完成时返回一个值，它的参数类型表示的是从方法call()中返回的值，并且需要用ExecutorService.submit()方法调用它。
2.  call()方法可以抛出异常，而Runable的run()方法不可以抛出异常
3.  summit()方法会产生Future对象，它用Callable返回结果的特定类型进行了参数化。你可以用isDone()方法来查询Future是否完成，当任务完成时，它具有一个结果，你可以调用get()方法来获取该结果。

**Callabel的例子**  
Java编程思想练习5：修改练习2，使得计算所有斐波纳契数字的数值总和的任务成为Callable。创建多个任务并显示结果。

import java.util.concurrent.Callable;
    
    public class CallableFib implements Callable<Integer>{
        
    	private int num=5;
    	public CallableFib() {
        }
    	public CallableFib(int num){
        
    		this.num = num;
    	}
    	public int Fib(int n) {
        
    		if(n==0)
    			return 1;
    		if(n==1)
    			return 1;
    		return Fib(n-2)+Fib(n-1);
    	}
    	@Override
    	public Integer call() {
        
    		// TODO Auto-generated method stub
    		return Fib(num);
    	}
    }

import java.util.ArrayList;
    import java.util.concurrent.ExecutionException;
    import java.util.concurrent.ExecutorService;
    import java.util.concurrent.Executors;
    import java.util.concurrent.Future;
    
    public class TestCallableFib {
        
    	public static void main(String[] args) {
        
    		// TODO Auto-generated method stub
    		ExecutorService exec = Executors.newCachedThreadPool();
    		ArrayList<Future<Integer>> results = new ArrayList<Future<Integer>>();
    		for(int i=0;i<10;i++) {
        
    			results.add(exec.submit(new CallableFib(i))); 
    		}
    		for(Future<Integer> re : results) {
        
    			try {
        
    				System.out.print(re.get()+" ");
    			}catch(InterruptedException e) {
        
    				System.out.println(e);
    			}catch(ExecutionException e) {
        
    				System.out.println(e);
    			}finally {
        
    				exec.shutdown();
    			}
    		}
    	}
    }

输出结果：

1 1 2 3 5 8 13 21 34 55