cn.hutool.core.thread

Class SyncFinisher

java.lang.Object

cn.hutool.core.thread.SyncFinisher

All Implemented Interfaces:

Closeable, AutoCloseable

public class SyncFinisher
extends Object
implements Closeable

线程同步结束器
在完成一组正在其他线程中执行的操作之前，它允许一个或多个线程一直等待。

 ps:
 //模拟1000个线程并发
 SyncFinisher sf = new SyncFinisher(1000);
 sf.addWorker(() -> {
      // 需要并发测试的业务代码
 });
 sf.start()
 

Since:

4.1.15

Author:

Looly

Nested Class Summary

Nested Classes

Modifier and Type	Class and Description
class	SyncFinisher.Worker 工作者，为一个线程

Constructor Summary

Constructors

Constructor and Description
SyncFinisher(int threadSize) 构造

Method Summary

Modifier and Type	Method and Description
SyncFinisher	addRepeatWorker(Runnable runnable) 增加定义的线程数同等数量的worker
SyncFinisher	addWorker(Runnable runnable) 增加工作线程
SyncFinisher	addWorker(SyncFinisher.Worker worker) 增加工作线程
void	clearWorker() 清空工作线程对象
void	close()
long	count() 剩余任务数
SyncFinisher	setBeginAtSameTime(boolean isBeginAtSameTime) 设置是否所有worker线程同时开始
SyncFinisher	setExceptionHandler(Thread.UncaughtExceptionHandler exceptionHandler) 设置异常处理
SyncFinisher	setExecutorService(ExecutorService executorService) 设置自定义线程池，默认为ExecutorBuilder创建的线程池
void	start() 开始工作 执行此方法后如果不再重复使用此对象，需调用stop()关闭回收资源。
void	start(boolean sync) 开始工作 执行此方法后如果不再重复使用此对象，需调用stop()关闭回收资源。
void	stop() 结束线程池。
void	stopNow() 立即结束线程池所有线程。

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Detail

SyncFinisher

public SyncFinisher(int threadSize)

构造

Parameters:

threadSize - 线程数

Method Detail

setExecutorService

public SyncFinisher setExecutorService(ExecutorService executorService)

设置自定义线程池，默认为ExecutorBuilder创建的线程池

Parameters:

executorService - 线程池

Returns:

this

Since:

5.8.33

setBeginAtSameTime

public SyncFinisher setBeginAtSameTime(boolean isBeginAtSameTime)

设置是否所有worker线程同时开始

Parameters:

isBeginAtSameTime - 是否所有worker线程同时开始

Returns:

this

setExceptionHandler

public SyncFinisher setExceptionHandler(Thread.UncaughtExceptionHandler exceptionHandler)

设置异常处理

Parameters:

exceptionHandler - 异常处理器

Returns:

this

Since:

5.8.19

addRepeatWorker

public SyncFinisher addRepeatWorker(Runnable runnable)

增加定义的线程数同等数量的worker

Parameters:

runnable - 工作线程

Returns:

this

addWorker

public SyncFinisher addWorker(Runnable runnable)

增加工作线程

Parameters:

runnable - 工作线程

Returns:

this

addWorker

public SyncFinisher addWorker(SyncFinisher.Worker worker)

增加工作线程

Parameters:

worker - 工作线程

Returns:

this

start

public void start()

开始工作
执行此方法后如果不再重复使用此对象，需调用stop()关闭回收资源。

start

public void start(boolean sync)

开始工作
执行此方法后如果不再重复使用此对象，需调用stop()关闭回收资源。

Parameters:

sync - 是否阻塞等待

Since:

4.5.8

stop

public void stop()

结束线程池。此方法执行两种情况：

1. 执行start(true)后，调用此方法结束线程池回收资源
2. 执行start(false)后，用户自行判断结束点执行此方法

Since:

5.6.6

stopNow

public void stopNow()

立即结束线程池所有线程。此方法执行两种情况：

1. 执行start(true)后，调用此方法结束线程池回收资源
2. 执行start(false)后，用户自行判断结束点执行此方法

Since:

5.8.11

clearWorker

public void clearWorker()

清空工作线程对象

count

public long count()

剩余任务数

Returns:

剩余任务数

close

public void close()
           throws IOException

Specified by:

close in interface Closeable

Specified by:

close in interface AutoCloseable

Throws:

IOException