Searched refs:Worker (Results 1 – 3 of 3) sorted by relevance
484 private final HashSet<Worker> workers = new HashSet<>();607 private final class Worker class in ThreadPoolExecutor628 Worker(Runnable firstTask) { in Worker() method in ThreadPoolExecutor.Worker759 for (Worker w : workers) in checkShutdownAccess()775 for (Worker w : workers) in interruptWorkers()805 for (Worker w : workers) { in interruptIdleWorkers()943 Worker w = null; in addWorker()945 w = new Worker(firstTask); in addWorker()988 private void addWorkerFailed(Worker w) { in addWorkerFailed()1014 private void processWorkerExit(Worker w, boolean completedAbruptly) { in processWorkerExit()[all …]
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()