lsm/hutool
1
0
Fork 0
mirror of https://gitee.com/dromara/hutool.git synced 2025-06-28 13:34:09 +08:00
Code Issues Actions Packages Projects Releases Wiki Activity

SyncFinisher线程同步结束器添加立即结束方法

Browse Source
This commit is contained in:
Looly 2022-11-26 12:13:39 +08:00
parent 8767b1edc1
commit d29b87c36f
2 changed files with 16 additions and 12 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

2
CHANGELOG.md
View File

@ -7,6 +7,8 @@
### 🐣新特性 ### 🐣新特性
* 【core 】 CharUtil.isBlankChar增加\u180e（pr#2738@Github） * 【core 】 CharUtil.isBlankChar增加\u180e（pr#2738@Github）
* 【core 】 SyncFinisher线程同步结束器添加立即结束方法（pr#879@Gitee）
*
### 🐞Bug修复 ### 🐞Bug修复
* 【json 】 修复普通byte数组转JSONArray时的异常（pr#875@Gitee） * 【json 】 修复普通byte数组转JSONArray时的异常（pr#875@Gitee）
* 【core 】 修复ArrayUtil.insert()不支持原始类型数组的问题（pr#874@Gitee） * 【core 】 修复ArrayUtil.insert()不支持原始类型数组的问题（pr#874@Gitee）

26
hutool-core/src/main/java/cn/hutool/core/thread/SyncFinisher.java
View File

@ -23,7 +23,6 @@ import java.util.concurrent.ExecutorService;
* sf.start() * sf.start()
* </pre> * </pre>
* *
*
* @author Looly * @author Looly
* @since 4.1.15 * @since 4.1.15
*/ */
@ -34,9 +33,13 @@ public class SyncFinisher implements Closeable {
private ExecutorService executorService; private ExecutorService executorService;
private boolean isBeginAtSameTime; private boolean isBeginAtSameTime;
/** 启动同步器，用于保证所有worker线程同时开始 */ /**
* 启动同步器，用于保证所有worker线程同时开始
*/
private final CountDownLatch beginLatch; private final CountDownLatch beginLatch;
/** 结束同步器，用于等待所有worker线程同时结束 */ /**
* 结束同步器，用于等待所有worker线程同时结束
*/
private CountDownLatch endLatch; private CountDownLatch endLatch;
/** /**
@ -123,7 +126,7 @@ public class SyncFinisher implements Closeable {
public void start(boolean sync) { public void start(boolean sync) {
endLatch = new CountDownLatch(workers.size()); endLatch = new CountDownLatch(workers.size());
if(null == this.executorService || this.executorService.isShutdown()){ if (null == this.executorService || this.executorService.isShutdown()) {
this.executorService = ThreadUtil.newExecutor(threadSize); this.executorService = ThreadUtil.newExecutor(threadSize);
} }
for (Worker worker : workers) { for (Worker worker : workers) {
@ -150,11 +153,11 @@ public class SyncFinisher implements Closeable {
* *
* @since 5.6.6 * @since 5.6.6
*/ */
public void stop(){ public void stop() {
if(null != this.executorService){ if (null != this.executorService) {
this.executorService.shutdown(); this.executorService.shutdown();
this.executorService = null;
} }
this.executorService = null;
clearWorker(); clearWorker();
} }
@ -166,13 +169,13 @@ public class SyncFinisher implements Closeable {
* <li>执行start(false)后，用户自行判断结束点执行此方法</li> * <li>执行start(false)后，用户自行判断结束点执行此方法</li>
* </ol> * </ol>
* *
* @since 5.6.6 * @since 5.8.11
*/ */
public void stopNow(){ public void stopNow() {
if(null != this.executorService){ if (null != this.executorService) {
this.executorService.shutdownNow(); this.executorService.shutdownNow();
this.executorService = null;
} }
this.executorService = null;
clearWorker(); clearWorker();
} }
@ -202,7 +205,6 @@ public class SyncFinisher implements Closeable {
* 工作者，为一个线程 * 工作者，为一个线程
* *
* @author xiaoleilu * @author xiaoleilu
*
*/ */
public abstract class Worker implements Runnable { public abstract class Worker implements Runnable {