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