多线程创建方式三之实现Callable接口

时间:2021-05-13 18:06:42

Callable 接口

  Java 5.0 在java.util.concurrent 提供了一个新的创建执行线程的方式:Callable 接口
  Callable 接口类似于Runnable,两者都是为那些其实例可能被另一个线程执行的类设计的。但是Runnable 不会返回结果,并且无法抛出经过检查的异常。
  Callable 需要依赖FutureTask ,FutureTask 也可以用作闭锁。

示例代码如下:

import java.util.concurrent.Callable;
import java.util.concurrent.ExecutionException;
import java.util.concurrent.FutureTask;

public class TestCallable {
public static void main(String[] args) {
Callable<Integer>callable = new MyCallable();
FutureTask<Integer>task[] = new FutureTask[10];
long start = System.currentTimeMillis();
for(int i=0;i<10;i++){
task[i] = new FutureTask<Integer>(callable);
new Thread(task[i]).start();
}

int num = 0;
while(num<10){
try {
System.out.println(task[num].get());
} catch (InterruptedException e) {
e.printStackTrace();
} catch (ExecutionException e) {
e.printStackTrace();
}
num++;
}
long end = System.currentTimeMillis();
System.out.println(end-start);
}
}


class MyCallable implements Callable<Integer> {

@Override
public Integer call() throws Exception {
int sum = 0;
for (int i = 0; i < Integer.MAX_VALUE; i++) {
sum += i;
}
return sum;
}

}

代码分析:
  main线程里,有三个线程,三个线程独立,task.get()只有等待对应线程完成后才会执行,两个for循环串行,第二个for循环相当于闭锁。所以最后可以打印出10个结果。而且,效率明显比串行执行10次循环效率高。

流程图分析:
多线程创建方式三之实现Callable接口