fix bug

EspoirX · Aug 10, 2022 · a2fc278 · a2fc278
1 parent db13420
commit a2fc278
Showing 1 changed file with 4 additions and 8 deletions.
diff --git a/optimustask/src/main/java/com/lzx/optimustask/OptimusTaskManager.kt b/optimustask/src/main/java/com/lzx/optimustask/OptimusTaskManager.kt
@@ -54,14 +54,10 @@ class OptimusTaskManager {
     private suspend fun sendTask(task: IOptimusTask): Boolean {
         return runCatching {
             if (checkChannelActive()) {
-                return if (!TaskQueueManager.hasTask(task)) {
-                    task.setSequence(atomicInteger.incrementAndGet())
-                    TaskQueueManager.addTask(task)
-                    channel.send(task)
-                    true
-                } else {
-                    false
-                }
+                task.setSequence(atomicInteger.incrementAndGet())
+                TaskQueueManager.addTask(task)
+                channel.send(task)
+                return true
             } else {
                 TaskQueueManager.removeTask(task)
                 cacheTaskNameList.remove(task.getTaskName())