Przeglądaj źródła

Fix bug of not stopping immediately on CANCEL while PAUSED.

The service threads do not terminate immediately, but, instead
each service thread picks up one more job before terminating,
causing servicing more jobs which are not reported back to portal.
tags/1.0.12
ymlam 3 lat temu
rodzic
commit
053483a919
1 zmienionych plików z 2 dodań i 1 usunięć
  1. +2
    -1
      src/main/java/altk/comm/engine/Broadcast.java

+ 2
- 1
src/main/java/altk/comm/engine/Broadcast.java Wyświetl plik

@@ -290,7 +290,7 @@ public abstract class Broadcast
public void run() public void run()
{ {
myLogger.info("Thread starting..."); myLogger.info("Thread starting...");
while (! serviceThreadsShouldStop())
for (;;)
{ {
if (serviceThreadsShouldPause()) if (serviceThreadsShouldPause())
{ {
@@ -308,6 +308,7 @@ public abstract class Broadcast
} }
} }
} }
if (serviceThreadsShouldStop()) break;
// Get a batch of jobs, if available // Get a batch of jobs, if available
myLogger.debug("Looking for jobs"); myLogger.debug("Looking for jobs");
List<Job> batch = new ArrayList<Job>(); List<Job> batch = new ArrayList<Job>();


Ładowanie…
Anuluj
Zapisz