Java多线程按指定顺序同步执行
笔者今天看到一个有趣的面试题，如何让多个线程按照既定的顺序依次执行？比如每个线程输出一个整数，
那么期望就是这样的：0，1，2，3，4，5，6，7，8，9. 而不是0，2，4，1，3，5，8，7，9，6
乍一看，这不是反人性的考题吗？多线程本来就以乱序执行出名的。稍加思索，想到3种解决方案，分别用代码实现之。
方法1 使用newSingleThreadExecutor
newSingleThreadExecutor返回仅仅包含一个线程的线程池,将多个任务交给此Executor时，这个线程池处理完一个任务后接着处理下一个任务，这样就保证了执行顺序，先提交先执行。如果当前线程意外终止，会创建一个新线程继续执行任务。
示例代码如下：
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();
方法2 使用join方法
When we call this method using a thread object, it suspends the execution of the calling thread until the object called finishes its execution.
英语原版其实很拗口，不好理解。简单点说，就是某个线程A调用join，其他线程就要乖乖等A执行完毕才能执行。
示例代码如下：
public class Worker implements Runnable {
private int number;
public Worker(int i) {
number = i;
}
@Override
public synchronized void run() {
System.out.println("I am " + number);
}
}
public class TestWorker {
public static void main(String[] args) {
for(int j=0;j<1000;++j) {
Thread thread = new Thread(new Worker(j));
thread.start();
try {
thread.join();
} catch (InterruptedException e) {
e.printStackTrace();
}
}
}
}
方法3 使用ThreadPoolExecutor，设置它的核心线程数为1
我们先分析一下ThreadPoolExecutor,其构造函数如下
public ThreadPoolExecutor(int corePoolSize,
int maximumPoolSize,
long keepAliveTime,
TimeUnit unit,
BlockingQueue<Runnable> workQueue,
ThreadFactory threadFactory,
RejectedExecutionHandler handler)
各个参数含义如下：
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（抛弃最旧的）
示例代码如下：
ExecutorService pool = new ThreadPoolExecutor(1, 1000, 300, TimeUnit.SECONDS,
new LinkedBlockingQueue<Runnable>(1000),Executors.defaultThreadFactory(),
new ThreadPoolExecutor.AbortPolicy());
for(int i=0;i<1000;++i) {
final int number = i;
pool.execute(()-> {
System.out.println("I am " + number);
} );
}
pool.shutdown();
4. 执行结果
I am 0 I am 1 I am 2 I am 3 I am 4 I am 5 I am 6 I am 7 I am 8 I am 9 I am 10 。。。 I am 990 I am 991 I am 992 I am 993 I am 994 I am 995 I am 996 I am 997 I am 998 I am 999
以上就是本文的全部内容，希望对大家的学习有所帮助，也希望大家多多支持我们。
相关推荐
-
java使用CountDownLatch等待多线程全部执行完成
前言 CountDownLatch 允许一个或多个线程等待其他线程完成操作. 应用场景 假如有一个列表的大量数据等待处理,最后全部处理完毕后返回处理结果.普通做法就是从头遍历,一个个顺序执行,这样单线程处理效率不高,我们希望使用多线程的方式处理,同时在主线程等待所有子线程处理完成. CountDownLatch的构造函数接收一个int类型的参数作为计数器,如果你想等待N个点完成,这里就传入N. 当我们调用一次CountDownLatch的countDown方法时,N就会减1,CountDownL
-
Java 多线程有序执行的几种方法总结
Java 多线程有序执行的几种方法总结 同事无意间提出了这个问题,亲自实践了两种方法.当然肯定还会有更多更好的方法. 方法一 import java.util.concurrent.atomic.AtomicInteger; public class OrderedThread1 { static AtomicInteger count = new AtomicInteger(0); public static void main(String[] args) throws Interrupte
-
Java多线程执行处理业务时间太久解决方法代码示例
背景:在政府开发了一个应用系统,主要功能是让企业填写企业资质信息,然后通过给定的公式,统计这一系列的信息,以得分的形式展示给政府领导查看.目前有1300家企业填报.由于得分是实时显示的,所以导致统计功能很慢. 代码运行流程: 1.查出1300企业信息 2.遍历1300企业信息,ji计算每家企业得分信息.每家预计时间为0.3秒.合计390秒.导致页面请求超时 3.导出(用jxl jar) 解决方案: 由于处理业务的,所以需要能有返回值的线程.用:Callable 直接上代码 1.调用线程的代码 L
-
java使用多线程读取超大文件
接上次写的"JAVA读取超大文件".在读取超过10G的文件时会发现一次读一行的速度实在是不能接受,想到使用多线程+FileChannel来做一个使用多线程版本. 基本思路如下: 1.计算出文件总大小 2.分段处理,计算出每个线程读取文件的开始与结束位置 (文件大小/线程数)*N,N是指第几个线程,这样能得到每个线程在读该文件的大概起始位置 使用"大概起始位置",作为读文件的开始偏移量(fileChannel.position("大概起始位置"))
-
Java多线程下解决资源竞争的7种方法详解
前言 一般情况下,只要涉及到多线程编程,程序的复杂性就会显著上升,性能显著下降,BUG出现的概率大大提升. 多线程编程本意是将一段程序并行运行,提升数据处理能力,但是由于大部分情况下都涉及到共有资源的竞争,所以修改资源 对象时必须加锁处理.但是锁的实现有很多种方法,下面就来一起了解一下在C#语言中几种锁的实现与其性能表现. 一.c#下的几种锁的运用方式 1.临界区,通过对多线程的串行化来访问公共资源或一段代码,速度快,适合控制数据访问. private static object obj = n
-
Java多线程--让主线程等待所有子线程执行完毕在执行
朋友让我帮忙写个程序从文本文档中导入数据到oracle数据库中,技术上没有什么难度,文档的格式都是固定的只要对应数据库中的字段解析就行了,关键在于性能. 数据量很大百万条记录,因此考虑到要用多线程并发执行,在写的过程中又遇到问题,我想统计所有子进程执行完毕总共的耗时,在第一个子进程创建前记录当前时间用System.currentTimeMillis()在最后一个子进程结束后记录当前时间,两次一减得到的时间差即为总共的用时,代码如下 long tStart = System.currentTime
-
利用Java多线程技术导入数据到Elasticsearch的方法步骤
前言 近期接到一个任务,需要改造现有从mysql往Elasticsearch导入数据MTE(mysqlToEs)小工具,由于之前采用单线程导入,千亿数据需要两周左右的时间才能导入完成,导入效率非常低.所以楼主花了3天的时间,利用java线程池框架Executors中的FixedThreadPool线程池重写了MTE导入工具,单台服务器导入效率提高十几倍(合理调整线程数据,效率更高). 关键技术栈 Elasticsearch jdbc ExecutorService\Thread sql 工具说明
-
java多线程处理执行solr创建索引示例
复制代码 代码如下: public class SolrIndexer implements Indexer, Searcher, DisposableBean { //~ Static fields/initializers ============================================= static final Logger logger = LoggerFactory.getLogger(SolrIndexer.class); private static fi
-
Java多线程按指定顺序同步执行
笔者今天看到一个有趣的面试题,如何让多个线程按照既定的顺序依次执行?比如每个线程输出一个整数, 那么期望就是这样的:0,1,2,3,4,5,6,7,8,9. 而不是0,2,4,1,3,5,8,7,9,6 乍一看,这不是反人性的考题吗?多线程本来就以乱序执行出名的.稍加思索,想到3种解决方案,分别用代码实现之. 方法1 使用newSingleThreadExecutor newSingleThreadExecutor返回仅仅包含一个线程的线程池,将多个任务交给此Executor时,这个线程池处理完
-
总结java多线程之互斥与同步解决方案
一.线程互斥与同步 互斥:指的是多个线程不能同时访问共享变量 同步:指的是多个线程按指定的顺序执行操作 在同时有多个线程运行过程中,如何达到互斥和同步呢? 加锁即可 在此使用黑马笔记中room例子来说明锁.(ps: 以前就了解锁,但总会记乱,发现使用形象化记忆后就很清楚) 解决互斥 锁就相当于上图的房子,里面放着会被并发访问的共享变量 此时绿色区域(owner)无线程,此时多个线程想并发访问房子里的共享变量,那么只允许其中一个线程进入房子访问,并把房门锁上. 剩下的没有拿到锁的线程只能在entr
-
微信小程序按顺序同步执行的两种方式
小程序按顺序执行的两种方式 1.回调函数执行,后一个方法写到前一个的回调函数中从而实现顺序执行,缺点是嵌套太多,代码混乱 2.async-await 同步执行,此方法等待前面方法执行完毕才继续后续执行.代码可读性好 以检查文本安全性为例给出两种不同方式代码以供参考 回调方式 /** * 同步检查是否包含敏感词 */ // async function checkString(content) { // try { // var res = await wx.cloud.callFunction(
-
Java多线程实现第三方数据同步
本文实例为大家分享了Java多线程实现第三方数据同步的具体代码,供大家参考,具体内容如下 一.场景 最近的一项开发任务是同步第三方数据,而第三方数据一般有存量数据和增量数据,存量数据有100w+.在得知此需求时,进行了一定的信息检索和工具学习,提前获取存量数据到目标库,再使用kettle进行存量数据转换:增量数据则根据业务方规定的请求时间,通过定时任务去获取增量数据并进行数据转换.在数据获取和转换时,我们应该要记录每一次的请求信息,便于溯源和数据对账!!! 二.获取数据的方式 2.1 递归方式
-
C++双线程调用网络摄像头与多线程调用多摄像头同步执行方法详细讲解
目录 一.使用双线程调用网络摄像头并执行算法 方法一 方法二 二.使用多线程调用多路摄像头并同步执行多个算法 在调用网络摄像头处理自己的算法时,当解码的速度与算法运行的速度差太多时,会出现类似下面的错误 error while decoding MB 148 4, bytestream 所以需要使用两个线程,一个线程调用摄像头,一个线程用来处理图像. 一.使用双线程调用网络摄像头并执行算法 方法一 #include <iostream> #include <thread> #inc
-
Java多线程编程之CountDownLatch同步工具使用实例
好像倒计时计数器,调用CountDownLatch对象的countDown方法就将计数器减1,当到达0时,所有等待者就开始执行. java.util.concurrent.CountDownLatch 一个同步辅助类,在完成一组正在其他线程中执行的操作之前,它允许一个或多个线程一直等待.用给定的计数初始化CountDownLatch.由于调用了countDown()方法,所以在当前计数到达零之前,await方法会一直受阻塞.之后,会释放所有等待的线程,await的所有后续调用都将立即返回.这种现
-
JAVA多线程CountDownLatch使用详解
前序: 上周测试给开发的同事所开发的模块提出了一个bug,并且还是偶现. 经过仔细查看代码,发现是在业务中启用了多线程,2个线程同时跑,但是新启动的2个线程必须保证一个完成之后另一个再继续运行,才能消除bug. 什么时候用? 多线程是在很多地方都会用到的,但是我们如果想要实现在某个特定的线程运行完之后,再启动另外一个线程呢,这个时候CountDownLatch就可以派上用场了 怎么用? 先看看普通的多线程代码: package code; public class MyThread extend
-
java多线程实现有序输出ABC
3个线程,线程1输出A,线程2输出B,线程3输出C,让这个3个线程循环有序地输出ABCABC- 看到这个题目,感觉很有意思,问题的本质是在多线程执行环境,控制线程的执行顺序,实现的方式有非常多种,本质上需要解决Java多线程环境下的线程执行的同步和利用锁机制来控制线程的执行顺序. 方式1:利用synchronized 这种方式也就是使用java内置的monitor机制,配合wait和notifyAll,代码如下: (1)利用volatile做线程间资源的同步访问,同时作为线程调度的标志: (2)
-
Java中保证线程顺序执行的操作代码
只要了解过多线程,我们就知道线程开始的顺序跟执行的顺序是不一样的.如果只是创建三个线程然后执行,最后的执行顺序是不可预期的.这是因为在创建完线程之后,线程执行的开始时间取决于CPU何时分配时间片,线程可以看成是相对于的主线程的一个异步操作. public class FIFOThreadExample { public synchronized static void foo(String name) { System.out.print(name); } public static void
-
ReentrantLock从源码解析Java多线程同步学习
目录 前言 管程 管程模型 MESA模型 主要特点 AQS 共享变量 资源访问方式 主要方法 队列 node节点等待状态 ReentrantLock源码分析 实例化ReentrantLock 加锁 A线程加锁成功 B线程尝试加锁 释放锁 总结 前言 如今多线程编程已成为了现代软件开发中的重要部分,而并发编程中的线程同步问题更是一道难以逾越的坎.在Java语言中,synchronized是最基本的同步机制,但它也存在着许多问题,比如可重入性不足.死锁等等.为了解决这些问题,Java提供了更加高级的