码迷,mamicode.com
首页 > 其他好文 > 详细

验证Future.get阻塞性,阻塞的是什么

时间:2018-03-10 14:13:14      阅读:230      评论:0      收藏:0      [点我收藏+]

标签:handler   col   list   mit   .sh   actor   locking   void   blocking   

package com.fengjr.p2passet.riskcontrol.web.loan;

import com.fengjr.p2passet.service.auto.thread.pool.ProcessRejectedExecutionHandler;
import com.fengjr.p2passet.service.auto.thread.pool.ThreadPool;
import com.google.common.collect.Lists;
import lombok.Data;

import java.util.ArrayList;
import java.util.List;
import java.util.concurrent.*;
import java.util.concurrent.locks.Condition;
import java.util.concurrent.locks.Lock;
import java.util.concurrent.locks.ReentrantLock;
public class Test {
    public static void main(String[] args) throws ExecutionException, InterruptedException {
        ExecutorService service = new ThreadPoolExecutor(5,10,5,TimeUnit.SECONDS,new LinkedBlockingQueue<Runnable>(20),Executors.defaultThreadFactory(),
                new ProcessRejectedExecutionHandler());
        List<Future<?>> futures = new ArrayList<Future<?>>(100);
        @Data
        class Temp {
            int iT;
        }

        List<Temp> list = new ArrayList(20);
        for (int i=0; i<20; i++) {
            Temp temp = new Temp();
            temp.setIT(i);

            list.add(temp);
        }
        for(int i=0;i<20;i++){
            final Temp temp = list.get(i);
            Future<?> future = service.submit( new Callable<String>() {
                @Override
                public String call() throws Exception {
                    String threadName = Thread.currentThread().getName();
                    System. out.println("线程任务" + temp.getIT() + ",线程"+threadName+"在进行计算");
                    if(temp.getIT() == 2){
                        System. out.println("提交的线程任务"+temp.getIT()+",线程"+threadName+"现在休眠");
                        Thread.sleep(5000);
                        System. out.println("提交的线程任务" + temp.getIT()+",线程"+threadName+",醒来!!!!");
                    }
                    //Thread.sleep(3000);
                    return "线程任务" + temp.getIT()+",线程名称"+threadName;
                }
            });
            futures.add(future);
        }
        //System. out.println("主线程---------------------" + Thread.currentThread ().getName() + "在执行任务" );
        for(Future<?> item:futures){
            try {
                System. out.println("线程运行结果---------------" + item.get());
            } catch (InterruptedException e) {
                e.printStackTrace();
            } catch (ExecutionException e) {
                e.printStackTrace();
            }
        }
        //System. out.println("--------------所有任务执行完毕" );
        service.shutdown();
    }
}

让我们看一下上面的程序执行结果:

线程任务0,线程pool-1-thread-1在进行计算
线程任务3,线程pool-1-thread-4在进行计算
线程任务1,线程pool-1-thread-2在进行计算
线程任务2,线程pool-1-thread-3在进行计算
线程任务7,线程pool-1-thread-1在进行计算
线程任务6,线程pool-1-thread-2在进行计算
线程任务5,线程pool-1-thread-4在进行计算
线程任务4,线程pool-1-thread-5在进行计算
线程任务10,线程pool-1-thread-4在进行计算
线程运行结果---------------线程任务0,线程名称pool-1-thread-1
线程任务9,线程pool-1-thread-2在进行计算
线程任务8,线程pool-1-thread-1在进行计算
提交的线程任务2,线程pool-1-thread-3现在休眠
线程任务14,线程pool-1-thread-1在进行计算
线程任务13,线程pool-1-thread-2在进行计算
线程运行结果---------------线程任务1,线程名称pool-1-thread-2
线程任务12,线程pool-1-thread-4在进行计算
线程任务11,线程pool-1-thread-5在进行计算
线程任务17,线程pool-1-thread-4在进行计算
线程任务16,线程pool-1-thread-2在进行计算
线程任务15,线程pool-1-thread-1在进行计算
线程任务19,线程pool-1-thread-4在进行计算
线程任务18,线程pool-1-thread-5在进行计算
提交的线程任务2,线程pool-1-thread-3,醒来!!!!
线程运行结果---------------线程任务2,线程名称pool-1-thread-3
线程运行结果---------------线程任务3,线程名称pool-1-thread-4
线程运行结果---------------线程任务4,线程名称pool-1-thread-5
线程运行结果---------------线程任务5,线程名称pool-1-thread-4
线程运行结果---------------线程任务6,线程名称pool-1-thread-2
线程运行结果---------------线程任务7,线程名称pool-1-thread-1
线程运行结果---------------线程任务8,线程名称pool-1-thread-1
线程运行结果---------------线程任务9,线程名称pool-1-thread-2
线程运行结果---------------线程任务10,线程名称pool-1-thread-4
线程运行结果---------------线程任务11,线程名称pool-1-thread-5
线程运行结果---------------线程任务12,线程名称pool-1-thread-4
线程运行结果---------------线程任务13,线程名称pool-1-thread-2
线程运行结果---------------线程任务14,线程名称pool-1-thread-1
线程运行结果---------------线程任务15,线程名称pool-1-thread-1
线程运行结果---------------线程任务16,线程名称pool-1-thread-2
线程运行结果---------------线程任务17,线程名称pool-1-thread-4
线程运行结果---------------线程任务18,线程名称pool-1-thread-5
线程运行结果---------------线程任务19,线程名称pool-1-thread-4

  

验证Future.get阻塞性,阻塞的是什么

标签:handler   col   list   mit   .sh   actor   locking   void   blocking   

原文地址:https://www.cnblogs.com/kuku123/p/8538622.html

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