From 527dff1abdd43a861921dc5d8c01cfba8f05a0b1 Mon Sep 17 00:00:00 2001 From: ishland Date: Wed, 31 Jul 2024 21:55:46 +0800 Subject: [PATCH] change: no more ExecutorManager#schedulingMutex --- .../java/com/ishland/flowsched/executor/ExecutorManager.java | 5 +---- 1 file changed, 1 insertion(+), 4 deletions(-) diff --git a/src/main/java/com/ishland/flowsched/executor/ExecutorManager.java b/src/main/java/com/ishland/flowsched/executor/ExecutorManager.java index fa8e796..f3f8f65 100644 --- a/src/main/java/com/ishland/flowsched/executor/ExecutorManager.java +++ b/src/main/java/com/ishland/flowsched/executor/ExecutorManager.java @@ -13,7 +13,6 @@ public class ExecutorManager { private final DynamicPriorityQueue globalWorkQueue; private final ConcurrentMap lockListeners = new ConcurrentHashMap<>(); - private final Object schedulingMutex = new Object(); final Object workerMonitor = new Object(); private final WorkerThread[] workerThreads; @@ -164,9 +163,7 @@ private void wakeup() { } public boolean hasPendingTasks() { - synchronized (this.schedulingMutex) { - return this.globalWorkQueue.size() != 0; - } + return this.globalWorkQueue.size() != 0; } /**