fix: use double check to fix concurrent problem (#1909)
Co-authored-by: zhangwenhe <zhangwh@ehualu.com>
This commit is contained in:
parent
0a7b524bd1
commit
89b2072131
@ -57,9 +57,11 @@ public class Worker implements Runnable {
|
||||
try {
|
||||
if (workCenter.getLeader() != null && !workCenter.getLeader().equals(this)) {
|
||||
synchronized (workCenter) {
|
||||
workCenter.wait();
|
||||
if (workCenter.getLeader() != null && !workCenter.getLeader().equals(this)) {
|
||||
workCenter.wait();
|
||||
continue;
|
||||
}
|
||||
}
|
||||
continue;
|
||||
}
|
||||
final Task task = taskSet.getTask();
|
||||
synchronized (workCenter) {
|
||||
|
Loading…
x
Reference in New Issue
Block a user