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

2018-06-18 02:53:29来源:未知 阅读 ()

新老客户大回馈,云服务器低至5折

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

  

标签:

版权申明:本站文章部分自网络,如有侵权,请联系:west999com@outlook.com
特别注意:本站所有转载文章言论不代表本站观点,本站所提供的摄影照片,插画,设计作品,如需使用,请与原作者联系,版权归原作者所有

上一篇:Spring IOC容器的基本应用

下一篇:springmvc常用注解标签详解