Searched refs:Worker (Results 1 – 3 of 3) sorted by relevance
455 private final HashSet<Worker> workers = new HashSet<>();578 private final class Worker class in ThreadPoolExecutor599 Worker(Runnable firstTask) { in Worker() method in ThreadPoolExecutor.Worker730 for (Worker w : workers) in checkShutdownAccess()746 for (Worker w : workers) in interruptWorkers()776 for (Worker w : workers) { in interruptIdleWorkers()914 Worker w = null; in addWorker()916 w = new Worker(firstTask); in addWorker()959 private void addWorkerFailed(Worker w) { in addWorkerFailed()985 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()
245 new Thread(new Worker(s), "additional worker").start(); in run()307 class Worker implements Support_HttpConstants, Runnable { class in Support_TestWebServer337 Worker(Socket s) { in Worker() method in Support_TestWebServer.Worker