Searched refs:writeThread (Results 1 – 3 of 3) sorted by relevance
511 WriteChannelThread writeThread = new WriteChannelThread(clientChannel, buf); in test_read_LByteBuffer_Blocking_ReadWriteRealLargeData() local512 writeThread.start(); in test_read_LByteBuffer_Blocking_ReadWriteRealLargeData()516 writeThread.join(); in test_read_LByteBuffer_Blocking_ReadWriteRealLargeData()518 if (writeThread.exception != null) { in test_read_LByteBuffer_Blocking_ReadWriteRealLargeData()519 throw writeThread.exception; in test_read_LByteBuffer_Blocking_ReadWriteRealLargeData()556 WriteChannelThread writeThread = new WriteChannelThread(clientChannel, buf); in test_read_LByteBuffer_NonBlocking_ReadWriteRealLargeData() local557 writeThread.start(); in test_read_LByteBuffer_NonBlocking_ReadWriteRealLargeData()561 writeThread.join(); in test_read_LByteBuffer_NonBlocking_ReadWriteRealLargeData()563 if (writeThread.exception != null) { in test_read_LByteBuffer_NonBlocking_ReadWriteRealLargeData()564 throw writeThread.exception; in test_read_LByteBuffer_NonBlocking_ReadWriteRealLargeData()[all …]
346 Thread writeThread = new Thread(writeRunnable); in test_write_I_MultiThread() local361 writeThread.start(); in test_write_I_MultiThread()368 while (writeThread.isAlive()) { in test_write_I_MultiThread()410 Thread writeThread = new Thread(writeRunnable); in test_write_$CII_MultiThread() local425 writeThread.start(); in test_write_$CII_MultiThread()432 while (writeThread.isAlive()) { in test_write_$CII_MultiThread()
297 Thread writeThread = new Thread(writeRunnable); in test_write_failsAfterReaderDead() local301 writeThread.start(); in test_write_failsAfterReaderDead()306 writeThread.join(); in test_write_failsAfterReaderDead()