Searched refs:readerThread (Results 1 – 3 of 3) sorted by relevance
72 Thread readerThread; field in OldPipedWriterTest96 readerThread = new Thread(reader = new PReader(rd), "Constructor(Reader)"); in test_ConstructorLjava_io_PipedReader()97 readerThread.start(); in test_ConstructorLjava_io_PipedReader()139 readerThread = new Thread(reader = new PReader(rd), "connect"); in test_connectLjava_io_PipedReader()140 readerThread.start(); in test_connectLjava_io_PipedReader()161 readerThread = new Thread(reader = new PReader(pw), "flush"); in test_flush()162 readerThread.start(); in test_flush()205 readerThread = new Thread(reader = new PReader(pw), "writeCII"); in test_write$CII()206 readerThread.start(); in test_write$CII()216 readerThread.interrupt(); in test_write$CII()[all …]
81 private volatile long readerThread = 0; field in SocketChannelImpl321 readerThread = 0; in readerCleanup()367 readerThread = NativeThread.current(); in read()477 readerThread = NativeThread.current(); in read()683 readerThread = NativeThread.current(); in connect()756 readerThread = NativeThread.current(); in finishConnect()787 readerThread = 0; in finishConnect()830 if (readerThread != 0) in shutdownInput()831 NativeThread.signal(readerThread); in shutdownInput()892 if (readerThread != 0) in implCloseSelectableChannel()[all …]
70 private volatile long readerThread = 0; field in DatagramChannelImpl368 readerThread = NativeThread.current(); in receive()403 readerThread = 0; in receive()579 readerThread = NativeThread.current(); in read()585 readerThread = 0; in read()608 readerThread = NativeThread.current(); in read()614 readerThread = 0; in read()1050 if ((th = readerThread) != 0) in implCloseSelectableChannel()1147 readerThread = NativeThread.current(); in poll()1151 readerThread = 0; in poll()