Searched refs:Worker (Results 1 – 4 of 4) sorted by relevance
489 private final HashSet<Worker> workers = new HashSet<>();612 private final class Worker class in ThreadPoolExecutor633 Worker(Runnable firstTask) { in Worker() method in ThreadPoolExecutor.Worker764 for (Worker w : workers) in checkShutdownAccess()780 for (Worker w : workers) in interruptWorkers()810 for (Worker w : workers) { in interruptIdleWorkers()948 Worker w = null; in addWorker()950 w = new Worker(firstTask); in addWorker()993 private void addWorkerFailed(Worker w) { in addWorkerFailed()1019 private void processWorkerExit(Worker w, boolean completedAbruptly) { in processWorkerExit()[all …]
163 private void addWorkerFailed(java.util.concurrent.ThreadPoolExecutor.Worker w) { in addWorkerFailed()168 java.util.concurrent.ThreadPoolExecutor.Worker w, boolean completedAbruptly) { in processWorkerExit()176 final void runWorker(java.util.concurrent.ThreadPoolExecutor.Worker w) { in runWorker()393 private final java.util.HashSet<java.util.concurrent.ThreadPoolExecutor.Worker> workers;453 private final class Worker extends java.util.concurrent.locks.AbstractQueuedSynchronizer class in ThreadPoolExecutor456 Worker(java.lang.Runnable firstTask) { in Worker() method in ThreadPoolExecutor.Worker
331 static class Worker extends Thread { class in PipedInputStreamTest334 Worker(PipedOutputStream pos) { in Worker() method in PipedInputStreamTest.Worker352 Thread worker = new Worker(out); in test_read_after_write_close()
230 new Thread(new Worker(s).setDelay(mDelay), "additional worker").start(); in run()292 class Worker implements Support_HttpConstants, Runnable { class in Support_TestWebServer325 Worker(Socket s) { in Worker() method in Support_TestWebServer.Worker330 Worker setDelay(int delay) { in setDelay()