如何让线程池里面的线程按照顺序执行?

简介: 笔者今天看到一个有趣的面试题,如何让多个线程按照既定的顺序依次执行?比如每个线程输出一个整数,

笔者今天看到一个有趣的面试题,如何让多个线程按照既定的顺序依次执行?比如每个线程输出一个整数,


那么期望就是这样的: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(抛弃最旧的)


目录
相关文章
|
30天前
|
Java C#
C#学习系列相关之多线程(五)----线程池ThreadPool用法
C#学习系列相关之多线程(五)----线程池ThreadPool用法
|
1月前
|
Java
线程池中的空余线程是如何被回收的
线程池中的空余线程是如何被回收的
27 1
|
21天前
|
存储 算法 Java
【C/C++ 线程池设计思路】 深入探索线程池设计:任务历史记录的高效管理策略
【C/C++ 线程池设计思路】 深入探索线程池设计:任务历史记录的高效管理策略
67 0
|
18天前
|
Java 测试技术 Python
Python开启线程和线程池的方法
Python开启线程和线程池的方法
13 0
Python开启线程和线程池的方法
|
28天前
|
负载均衡 Java 数据处理
【C++ 并发 线程池】轻松掌握C++线程池:从底层原理到高级应用(三)
【C++ 并发 线程池】轻松掌握C++线程池:从底层原理到高级应用
50 2
|
28天前
|
存储 监控 Java
【C++ 并发 线程池】轻松掌握C++线程池:从底层原理到高级应用(二)
【C++ 并发 线程池】轻松掌握C++线程池:从底层原理到高级应用
35 1
|
28天前
|
负载均衡 安全 Java
【C++ 并发 线程池】轻松掌握C++线程池:从底层原理到高级应用(一)
【C++ 并发 线程池】轻松掌握C++线程池:从底层原理到高级应用
57 2
|
1月前
|
Java easyexcel 应用服务中间件
【二十五】springboot使用EasyExcel和线程池实现多线程导入Excel数据
【二十五】springboot使用EasyExcel和线程池实现多线程导入Excel数据
150 0
|
1月前
|
存储 Java
什么是线程池,线程池的状态,线程池的用法示例
什么是线程池,线程池的状态,线程池的用法示例
|
1月前
|
安全 Java 程序员
多线程案例-线程池
多线程案例-线程池

热门文章

最新文章

相关实验场景

更多