Only reschedule on negative pressure changes

Co-authored-by: krynju <[email protected]>

Author: jpsamaroo

src/sch/eager.jl

@@ -32,19 +32,24 @@ function init_eager()
     end
 end
 
-"Adjusts the scheduler's cached pressure indicator for the specified worker by
-the specified amount."
+"Adjusts the scheduler's cached pressure indicators for the specified worker by
+the specified amount, and signals the scheduler to try scheduling again if
+pressure decreased."
 function adjust_pressure!(h::SchedulerHandle, proctype::Type, pressure)
     uid = Dagger.get_tls().sch_uid
     lock(TASK_SYNC) do
         PROC_UTILIZATION[uid][proctype][] += pressure
-        notify(TASK_SYNC)
+        if pressure < 0
+            notify(TASK_SYNC)
+        end
     end
     exec!(_adjust_pressure!, h, myid(), proctype, pressure)
 end
 function _adjust_pressure!(ctx, state, task, tid, (pid, proctype, pressure))
     state.worker_pressure[pid][proctype] += pressure
-    put!(state.chan, RescheduleSignal())
+    if pressure < 0
+        put!(state.chan, RescheduleSignal())
+    end
     nothing
 end