大橙子网站建设,新征程启航

为企业提供网站建设、域名注册、服务器等服务

JAVA多线程Callable和Future使用示例

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;
    }
}

网页标题:JAVA多线程Callable和Future使用示例
本文路径:http://dzwzjz.com/article/pjepoj.html
在线咨询
服务热线
服务热线:028-86922220
TOP