Searched defs:worker (Results 1 – 6 of 6) sorted by relevance
149 ForkJoinWorkerThread worker = submitBusyTask(pool); in testSubmit() local179 var worker = (ForkJoinWorkerThread) Thread.currentThread(); in testGetQueuedTaskCount1() local233 ForkJoinWorkerThread worker; in submitBusyTask() local
35 ForkJoinWorkerThread worker = new WorkerThreadImpl(group, pool, true); in testCtorWithThreadGroup() local
196 Socket worker = server.accept(); in test_bindLjava_net_SocketAddress() local1011 Socket worker = server.accept(); in test_isBound() local1056 Socket worker = server.accept(); in test_isClosed() local1087 Socket worker = server.accept(); in test_isConnected() local1123 Socket worker = server.accept(); in test_isInputShutdown() local1160 Socket worker = server.accept(); in test_isOutputShutdown() local1216 Socket worker = server.accept(); in test_sendUrgentDataI() local1560 Socket worker = server.accept(); in test_shutdownInput() local1603 Socket worker = server.accept(); in test_shutdownOutput() local
47 Socket worker = pingServer.accept(); in test_getInputStream() local
2197 Socket worker = server.socket().accept(); in testReadByteBuffer_Direct2() local2915 SocketChannel worker = server.accept(); in test_write$LByteBuffer2() local2947 SocketChannel worker = server.accept(); in test_write$LByteBuffer_buffers() local2987 SocketChannel worker = server.accept(); in test_write$LByteBuffer_writes() local3031 SocketChannel worker = server.accept(); in test_write$LByteBuffer_invalid() local
352 Thread worker = new Worker(out); in test_read_after_write_close() local