笔者今天看到一个有趣的面试题,如何让多个线程按照既定的顺序依次执行?比如每个线程输出一个整数,
那么期望就是这样的:0,1,2,3,4,5,6,7,8,9.而不是0,2,4,1,3,5,8,7,9,6
乍一看,这不是反人性的考题吗?多线程本来就以乱序执行出名的。稍加思索,想到3种解决方案,分别用代码实现之。
方法1: 使用join方法
代码如下:
Thread t1 = new Thread(new Runnable() { @Override public void run() { try { Thread.sleep(1000); } catch (InterruptedException e) { e.printStackTrace(); } System.out.println("t1..."); } }); Thread t2 = new Thread(new Runnable() { @Override public void run() { try { Thread.sleep(1000); } catch (InterruptedException e) { e.printStackTrace(); } System.out.println("t2..."); } }); Thread t3 = new Thread(new Runnable() { @Override public void run() { System.out.println("t3..."); } }); try { t1.start(); t1.join(); t2.start(); t2.join(); t3.start(); } catch (InterruptedException e) { e.printStackTrace(); }
方法2:使用newSingleThreadExecutor
ExecutorService pool = Executors.newSingleThreadExecutor(); for (int i = 0; i < 1000; ++i) { final int number = i; pool.execute(() -> { System.out.println("I am " + number); }); } pool.shutdown();
方法3:使用ThreadPoolExecutor,设置它的核心线程数为1
ExecutorService pool = new ThreadPoolExecutor(1, 1000, 300, TimeUnit.SECONDS, new LinkedBlockingQueue(1000), Executors.defaultThreadFactory(), newThreadPoolExecutor.AbortPolicy()); for (int i = 0; i < 1000; ++i) { final int number = i; pool.execute(() -> { System.out.println("I am " + number); }); } pool.shutdown();
各个参数含义如下:
1、corePoolSize, 核心线程数,建议和cpu的核心数一样,当有任务提交,检测当前线程池内的线程数小于corePoolSize的话,新建线程执行任务,直到达到corePoolSize。线程池内的线程数大于等于corePoolSize时,将任务放入workQueue等待
2、maximumPoolSize,允许线程池内最大线程数,当队列满了之后,如果线程池内的线程数小于maximumPoolSize新建线程,如果大于等于执行拒绝策略。
3、keepAliveTime,线程最大空闲时间,如果设置60s,那么线程空闲60s后自动结束。
unit,时间单位分钟,秒等等。
4、workQueue,线程数超过corePoolSize存放任务的地方。
5、threadFactory,线程工厂,默认的即可。
6、handler,拒绝策略,分4种,AbortPolicy直接抛出异常、DiscardPolicy悄悄抛弃不执行、CallerRunsPolicy(调用者运行):该策略既不会抛弃任务也不会抛出异常,而是将这个任务退回给调用者,从而降低新任务的流量;、DiscardOldestPolicy(抛弃最旧的)