大橙子网站建设,新征程启航
为企业提供网站建设、域名注册、服务器等服务
package concurrent;
import java.util.Random;
import java.util.concurrent.Callable;
import java.util.concurrent.ExecutorService;
import java.util.concurrent.Executors;
import java.util.concurrent.Future;
/**
* @Auther:zhouhongliang
* @Date:2019/7/11
* @Description:
* Callable和Future一起使用
*/
public class CallableOne {
public static void main(String[] args) {
ExecutorService executorService = Executors.newFixedThreadPool(3);
Future zhangsan = executorService.submit(new MyCalllable("张三"));
Future lisi = executorService.submit(new MyCalllable("李四"));
Future wangwu = executorService.submit(new MyCalllable("王五"));
try {
//阻塞主线程 get()
System.out.println(zhangsan.get());
System.out.println(lisi.get());
//System.out.println(wangwu.get());
}catch (Exception e){
e.printStackTrace();
}
System.out.println("主线程执行完毕");
executorService.shutdown();
}
}
class MyCalllable implements Callable{
public MyCalllable(String name) {
this.name = name;
}
private String name;
public void setName(String name) {
this.name = name;
}
@Override
public Object call() throws Exception {
Integer speed = new Random().nextInt(100);
Integer course = new Integer(0);
for (int i=1;i<=10;i++){
course = speed * i;
System.out.println(name + " 前进了"+course+"米,"+speed+"/秒");
if ("张三".equals(name)){
Thread.sleep(100);
}else{
Thread.sleep(500);
}
}
return course;
}
}