码迷,mamicode.com
首页 > 编程语言 > 详细

Java线程池,获取返回值

时间:2016-05-18 21:41:28      阅读:382      评论:0      收藏:0      [点我收藏+]

标签:

 

程序中使用的是Callable接口,可以获取线程的返回值。

 

package liuzh;

import java.util.LinkedList;
import java.util.List;
import java.util.concurrent.Callable;
import java.util.concurrent.ExecutionException;
import java.util.concurrent.Future;
import java.util.concurrent.LinkedBlockingDeque;
import java.util.concurrent.ThreadPoolExecutor;
import java.util.concurrent.TimeUnit;


class Task implements Callable<String> {
    private String filename;

    public Task(String filename) {
        this.filename = filename;
    }
    
    @Override
    public String call() throws Exception {
        try {
            Thread.sleep(1000);
        } catch (InterruptedException e) {
            e.printStackTrace();
        }
        System.out.println("完成 "+ filename);
        return "返回值" + filename;
    }
}

/**
 * 创建一个线程池,将50个任务分配进去,并发量最大为5
 * 运行结束后,输出每个线程返回的结束
 * title:ThreadPoolExecutorTest
 * descript:
 * @author liuzh
 * @date 2016年5月18日 下午8:16:26
 */
public class ThreadPoolExecutorTest {
    
    public void start() throws InterruptedException, ExecutionException {
        /**
         * 创建线程池,并发量最大为5
         * LinkedBlockingDeque,表示执行任务或者放入队列
         */
        ThreadPoolExecutor tpe = new ThreadPoolExecutor(5, 10, 0,
                TimeUnit.SECONDS, new LinkedBlockingDeque<Runnable>(),
                new ThreadPoolExecutor.CallerRunsPolicy());

        //存储线程的返回值
        List<Future<String>> results = new LinkedList<Future<String>>();
        
        for (int i = 0; i < 10; i++) {
            Task task = new Task(String.valueOf(i));
            System.out.println("放入线程池:" + i);
            //调用submit可以获得线程的返回值
            Future<String> result = tpe.submit(task);
            results.add(result);
            
        }

        //此函数表示不再接收新任务,
        //如果不调用,awaitTermination将一直阻塞
        tpe.shutdown();
        //1天,模拟永远等待
        System.out.println(tpe.awaitTermination(1, TimeUnit.DAYS));

        //输出结果
        for (int i = 0; i < 10; i++) {
            System.out.println(results.get(i).get());
        }

    }

    public static void main(String[] args) throws InterruptedException, ExecutionException {
        ThreadPoolExecutorTest test = new ThreadPoolExecutorTest();
        test.start();
    }

}

输出样例:

放入线程池:0
放入线程池:1
放入线程池:2
放入线程池:3
放入线程池:4
放入线程池:5
放入线程池:6
放入线程池:7
放入线程池:8
放入线程池:9
完成 1
完成 0
完成 2
完成 3
完成 4
完成 9
完成 6
完成 8
完成 5
完成 7
true
返回值0
返回值1
返回值2
返回值3
返回值4
返回值5
返回值6
返回值7
返回值8
返回值9

 

参考:http://www.cnblogs.com/vhua/p/5277694.html

        http://www.cnblogs.com/hzmark/archive/2013/01/21/JavaExecutor.html

Java线程池,获取返回值

标签:

原文地址:http://www.cnblogs.com/liu-zh/p/5506492.html

(0)
(0)
   
举报
评论 一句话评论(0
登录后才能评论!
© 2014 mamicode.com 版权所有  联系我们:gaon5@hotmail.com
迷上了代码!