Warning: session_start(): open(/var/lib/php/sessions/sess_rpn0nd0773ald759vu2p9sq65j, O_RDWR) failed: No space left on device (28) in /var/www/tb-usercake/models/config.php on line 51
Warning: session_start(): Failed to read session data: files (path: /var/lib/php/sessions) in /var/www/tb-usercake/models/config.php on line 51
sclass ConcurrentEvaluator {
new L functions;
L results = synchroList();
ExecutorService executorService;
O onNewResult; // Runnable or voidfunc(int)
volatile bool cancelled;
L threads = synchroList();
void add(O f) { functions.add(f); }
void addAll(Collection l) { functions.addAll(l); }
void start() {
executorService = Executors.newFixedThreadPool(coresToUse());
while (l(results) < l(functions)) results.add(null);
for _i over functions: {
final int i = _i;
executorService.execute(r {
threads.add(currentThread());
try {
results.set(i, pcallF(functions.get(i)));
ping();
onNewResult(i);
} finally {
threads.remove(currentThread());
}
});
}
}
void onNewResult(int i) { if (!cancelled) pcallF(onNewResult, i); }
L results() { ret cloneList(results); }
void cancel {
cancelled = true;
executorService.shutdownNow();
cancelThreads(cloneList(threads));
}
void cancelAndWait {
long time = sysNow();
cancel();
while (nempty(threads)) sleep(1);
sysDone("Cancelling evaluators", time, 10);
}
bool done() { ret empty(threads); }
}