public class SyncFinisher extends Object
ps: //模拟1000个线程并发 SyncFinisher sf = new SyncFinisher(1000); sf.addWorker(() -> { // 需要并发测试的业务代码 }); sf.start()
Modifier and Type | Class and Description |
---|---|
class |
SyncFinisher.Worker
工作者,为一个线程
|
Constructor and Description |
---|
SyncFinisher(int threadSize)
构造
|
Modifier and Type | Method and Description |
---|---|
SyncFinisher |
addRepeatWorker(Runnable runnable)
增加定义的线程数同等数量的worker
|
SyncFinisher |
addWorker(Runnable runnable)
增加工作线程
|
SyncFinisher |
addWorker(SyncFinisher.Worker worker)
增加工作线程
|
void |
await()
Deprecated.
使用start方法指定是否阻塞等待
|
void |
clearWorker()
清空工作线程对象
|
long |
count()
剩余任务数
|
SyncFinisher |
setBeginAtSameTime(boolean isBeginAtSameTime)
设置是否所有worker线程同时开始
|
void |
start()
开始工作
|
void |
start(boolean sync)
开始工作
|
public SyncFinisher setBeginAtSameTime(boolean isBeginAtSameTime)
isBeginAtSameTime
- 是否所有worker线程同时开始public SyncFinisher addRepeatWorker(Runnable runnable)
runnable
- 工作线程public SyncFinisher addWorker(Runnable runnable)
runnable
- 工作线程public SyncFinisher addWorker(SyncFinisher.Worker worker)
worker
- 工作线程public void start()
public void start(boolean sync)
sync
- 是否阻塞等待@Deprecated public void await() throws InterruptedException
InterruptedException
- 用户中断public void clearWorker()
public long count()
Copyright © 2021. All rights reserved.