Home
last modified time | relevance | path

Searched refs:newStartedThread (Results 1 – 25 of 25) sorted by relevance

/libcore/jsr166-tests/src/test/java/jsr166/
DExchangerTest.java25 Thread t1 = newStartedThread(new CheckedRunnable() { in testExchange()
30 Thread t2 = newStartedThread(new CheckedRunnable() { in testExchange()
45 Thread t1 = newStartedThread(new CheckedRunnable() { in testTimedExchange()
50 Thread t2 = newStartedThread(new CheckedRunnable() { in testTimedExchange()
66 Thread t = newStartedThread(new CheckedInterruptedRunnable() { in testExchange_InterruptedException()
83 Thread t = newStartedThread(new CheckedInterruptedRunnable() { in testTimedExchange_InterruptedException()
99 Thread t = newStartedThread(new CheckedRunnable() { in testExchange_TimeoutException()
119 Thread t1 = newStartedThread(new CheckedInterruptedRunnable() { in testReplacementAfterExchange()
125 Thread t2 = newStartedThread(new CheckedRunnable() { in testReplacementAfterExchange()
132 Thread t3 = newStartedThread(new CheckedRunnable() { in testReplacementAfterExchange()
DCyclicBarrierTest.java99 Thread t = newStartedThread(new CheckedRunnable() { in testTwoParties()
171 Thread t = newStartedThread(new CheckedRunnable() { in testAwait3_TimeoutException()
190 Thread t1 = newStartedThread(new CheckedRunnable() { in testAwait4_Timeout_BrokenBarrier()
197 Thread t2 = newStartedThread(new CheckedRunnable() { in testAwait4_Timeout_BrokenBarrier()
218 Thread t1 = newStartedThread(new CheckedRunnable() { in testAwait5_Timeout_BrokenBarrier()
225 Thread t2 = newStartedThread(new CheckedRunnable() { in testAwait5_Timeout_BrokenBarrier()
276 Thread t1 = newStartedThread(new CheckedRunnable() { in testReset_NoBrokenBarrier()
280 Thread t2 = newStartedThread(new CheckedRunnable() { in testReset_NoBrokenBarrier()
296 Thread t = newStartedThread(new CheckedRunnable() { in testReset_Leakage()
326 Thread t1 = newStartedThread(new CheckedRunnable() { in testResetWithoutBreakage()
[all …]
DLockSupportTest.java100 Thread t = newStartedThread(new CheckedRunnable() { in testParkBeforeUnpark()
135 Thread t = newStartedThread(new CheckedRunnable() { in testParkAfterUnpark()
172 Thread t = newStartedThread(new CheckedRunnable() { in testParkBeforeInterrupt()
211 Thread t = newStartedThread(new CheckedRunnable() { in testParkAfterInterrupt()
243 Thread t = newStartedThread(new CheckedRunnable() { in testParkTimesOut()
281 Thread t = newStartedThread(new CheckedRunnable() { in testGetBlocker()
331 Thread t = newStartedThread(new CheckedRunnable() { in testPark0()
355 Thread t = newStartedThread(new CheckedRunnable() { in testParkNeg()
DCountDownLatchTest.java57 Thread t = newStartedThread(new CheckedRunnable() { in testAwait()
82 Thread t = newStartedThread(new CheckedRunnable() { in testTimedAwait()
106 Thread t = newStartedThread(new CheckedRunnable() { in testAwait_Interruptible()
137 Thread t = newStartedThread(new CheckedRunnable() { in testTimedAwait_Interruptible()
167 Thread t = newStartedThread(new CheckedRunnable() { in testAwaitTimeout()
DAbstractQueuedLongSynchronizerTest.java284 Thread t1 = newStartedThread(new InterruptedSyncRunnable(sync)); in testHasQueuedThreads()
287 Thread t2 = newStartedThread(new InterruptibleSyncRunnable(sync)); in testHasQueuedThreads()
344 Thread t1 = newStartedThread(new InterruptedSyncRunnable(sync)); in testGetFirstQueuedThread()
347 Thread t2 = newStartedThread(new InterruptibleSyncRunnable(sync)); in testGetFirstQueuedThread()
366 Thread t1 = newStartedThread(new InterruptedSyncRunnable(sync)); in testHasContended()
369 Thread t2 = newStartedThread(new InterruptibleSyncRunnable(sync)); in testHasContended()
444 Thread t1 = newStartedThread(new InterruptedSyncRunnable(sync)); in testGetSharedQueuedThreads_Exclusive()
447 Thread t2 = newStartedThread(new InterruptibleSyncRunnable(sync)); in testGetSharedQueuedThreads_Exclusive()
464 Thread t1 = newStartedThread(new CheckedInterruptedRunnable() { in testGetSharedQueuedThreads_Shared()
470 Thread t2 = newStartedThread(new CheckedRunnable() { in testGetSharedQueuedThreads_Shared()
[all …]
DAbstractQueuedSynchronizerTest.java287 Thread t1 = newStartedThread(new InterruptedSyncRunnable(sync)); in testHasQueuedThreads()
290 Thread t2 = newStartedThread(new InterruptibleSyncRunnable(sync)); in testHasQueuedThreads()
347 Thread t1 = newStartedThread(new InterruptedSyncRunnable(sync)); in testGetFirstQueuedThread()
350 Thread t2 = newStartedThread(new InterruptibleSyncRunnable(sync)); in testGetFirstQueuedThread()
369 Thread t1 = newStartedThread(new InterruptedSyncRunnable(sync)); in testHasContended()
372 Thread t2 = newStartedThread(new InterruptibleSyncRunnable(sync)); in testHasContended()
447 Thread t1 = newStartedThread(new InterruptedSyncRunnable(sync)); in testGetSharedQueuedThreads_Exclusive()
450 Thread t2 = newStartedThread(new InterruptibleSyncRunnable(sync)); in testGetSharedQueuedThreads_Exclusive()
467 Thread t1 = newStartedThread(new CheckedInterruptedRunnable() { in testGetSharedQueuedThreads_Shared()
473 Thread t2 = newStartedThread(new CheckedRunnable() { in testGetSharedQueuedThreads_Shared()
[all …]
DReentrantReadWriteLockTest.java300 Thread t = newStartedThread(new CheckedInterruptedRunnable() { in testWriteLockInterruptibly_Interruptible()
320 Thread t = newStartedThread(new CheckedInterruptedRunnable() { in testWriteTryLock_Interruptible()
340 Thread t = newStartedThread(new CheckedInterruptedRunnable() { in testReadLockInterruptibly_Interruptible()
360 Thread t = newStartedThread(new CheckedInterruptedRunnable() { in testReadTryLock_Interruptible()
396 Thread t = newStartedThread(new CheckedRunnable() { in testWriteTryLockWhenLocked()
414 Thread t = newStartedThread(new CheckedRunnable() { in testReadTryLockWhenLocked()
431 Thread t = newStartedThread(new CheckedRunnable() { in testMultipleReadLocks()
454 Thread t = newStartedThread(new CheckedRunnable() { in testWriteAfterReadLock()
480 Thread t1 = newStartedThread(new CheckedRunnable() { in testWriteAfterMultipleReadLocks()
488 Thread t2 = newStartedThread(new CheckedRunnable() { in testWriteAfterMultipleReadLocks()
[all …]
DSemaphoreTest.java223 Thread t = newStartedThread(new CheckedRunnable() { in testInterruptible()
274 Thread t1 = newStartedThread(new CheckedRunnable() { in testUninterruptible()
283 Thread t2 = newStartedThread(new CheckedRunnable() { in testUninterruptible()
314 Thread t1 = newStartedThread(new InterruptedLockRunnable(lock)); in testHasQueuedThreads()
317 Thread t2 = newStartedThread(new InterruptibleLockRunnable(lock)); in testHasQueuedThreads()
337 Thread t1 = newStartedThread(new InterruptedLockRunnable(lock)); in testGetQueueLength()
340 Thread t2 = newStartedThread(new InterruptibleLockRunnable(lock)); in testGetQueueLength()
361 Thread t1 = newStartedThread(new InterruptedLockRunnable(lock)); in testGetQueuedThreads()
364 Thread t2 = newStartedThread(new InterruptibleLockRunnable(lock)); in testGetQueuedThreads()
464 Thread t = newStartedThread(new InterruptibleLockRunnable(s)); in testSerialization()
[all …]
DPhaserTest.java301 threads.add(newStartedThread(new CheckedRunnable() { in testArrive2()
414 Thread t = newStartedThread(new CheckedRunnable() {
453 Thread t1 = newStartedThread(new CheckedRunnable() {
470 Thread t2 = newStartedThread(new CheckedRunnable() {
507 Thread t = newStartedThread(new CheckedRunnable() {
536 Thread t = newStartedThread(new CheckedRunnable() {
565 Thread t = newStartedThread(new CheckedRunnable() {
591 Thread t = newStartedThread(new CheckedRunnable() {
618 threads.add(newStartedThread(new CheckedRunnable() {
644 threads.add(newStartedThread(new CheckedRunnable() {
[all …]
DBlockingQueueTest.java207 Thread t = newStartedThread(new CheckedRunnable() { in testTimedPollWithOffer()
249 Thread t = newStartedThread(new CheckedRunnable() {
271 Thread t = newStartedThread(new CheckedRunnable() {
290 Thread t = newStartedThread(new CheckedRunnable() {
312 Thread t = newStartedThread(new CheckedRunnable() {
DLinkedTransferQueueTest.java193 Thread t = newStartedThread(new CheckedRunnable() { in testBlockingTake()
267 Thread t = newStartedThread(new CheckedRunnable() { in testInterruptedTimedPoll()
297 Thread t = newStartedThread(new CheckedRunnable() { in testTimedPollAfterInterrupt()
661 Thread t = newStartedThread(new CheckedRunnable() { in testDrainToWithActivePut()
705 Thread t = newStartedThread(new CheckedRunnable() { in testWaitingConsumer()
745 Thread t = newStartedThread(new CheckedRunnable() { in testTransfer2()
767 Thread first = newStartedThread(new CheckedRunnable() { in testTransfer3()
774 Thread interruptedThread = newStartedThread( in testTransfer3()
800 Thread t = newStartedThread(new CheckedRunnable() { in testTransfer4()
824 Thread t = newStartedThread(new CheckedRunnable() { in testTransfer5()
[all …]
DReentrantLockTest.java354 Thread t = newStartedThread(new CheckedInterruptedRunnable() { in testTryLock_Interruptible()
373 Thread t = newStartedThread(new CheckedRunnable() { in testTryLockWhenLocked()
390 Thread t = newStartedThread(new CheckedRunnable() { in testTryLock_Timeout()
437 Thread t = newStartedThread(new CheckedRunnable() { in testIsLocked()
469 Thread t = newStartedThread(new InterruptedLockRunnable(lock)); in testLockInterruptibly()
583 Thread t = newStartedThread(new CheckedRunnable() { in testAwait()
736 Thread t = newStartedThread(new CheckedRunnable() { in testHasWaiters()
888 Thread t1 = newStartedThread(new CheckedRunnable() { in testAwaitUninterruptibly()
899 Thread t2 = newStartedThread(new CheckedRunnable() { in testAwaitUninterruptibly()
941 Thread t = newStartedThread(new CheckedInterruptedRunnable() { in testInterruptible()
[all …]
DLinkedBlockingDequeTest.java551 Thread t = newStartedThread(new CheckedRunnable() { in testBlockingPut()
589 Thread t = newStartedThread(new CheckedRunnable() { in testPutWithTake()
621 Thread t = newStartedThread(new CheckedRunnable() { in testTimedOffer()
657 Thread t = newStartedThread(new CheckedRunnable() { in testBlockingTake()
729 Thread t = newStartedThread(new CheckedRunnable() { in testInterruptedTimedPoll()
783 Thread t = newStartedThread(new CheckedRunnable() { in testBlockingPutFirst()
821 Thread t = newStartedThread(new CheckedRunnable() { in testPutFirstWithTake()
853 Thread t = newStartedThread(new CheckedRunnable() { in testTimedOfferFirst()
889 Thread t = newStartedThread(new CheckedRunnable() { in testTakeFirstFromEmptyBlocksInterruptibly()
911 Thread t = newStartedThread(new CheckedRunnable() { in testTakeFirstFromEmptyAfterInterrupt()
[all …]
DFutureTaskTest.java409 Thread t = newStartedThread(task); in testCancelInterrupt()
485 Thread t = newStartedThread(task); in testCancelInterrupt_taskFails()
512 Thread t = newStartedThread(task); in testCancelNoInterrupt()
537 Thread t1 = newStartedThread(new CheckedRunnable() { in testGetRun()
543 Thread t2 = newStartedThread(new CheckedRunnable() { in testGetRun()
576 Thread t1 = newStartedThread(new CheckedRunnable() { in testGetSet()
582 Thread t2 = newStartedThread(new CheckedRunnable() { in testGetSet()
642 Thread t3 = newStartedThread(task); in testTimedGet_Cancellation()
709 Thread t = newStartedThread(new CheckedRunnable() { in testGet_interruptible()
738 Thread t = newStartedThread(new CheckedRunnable() { in testTimedGet_interruptible()
DSynchronousQueueTest.java102 Thread t = newStartedThread(new CheckedRunnable() { in testBlockingPut()
135 Thread t = newStartedThread(new CheckedRunnable() { in testPutWithTake()
168 Thread t = newStartedThread(new CheckedRunnable() { in testTimedOffer()
230 Thread t = newStartedThread(new CheckedRunnable() { in testTimedPollWithOffer()
544 Thread t = newStartedThread(new CheckedRunnable() {
567 Thread t1 = newStartedThread(new CheckedRunnable() {
572 Thread t2 = newStartedThread(new CheckedRunnable() {
DTimeUnitTest.java336 Thread t = newStartedThread(new CheckedRunnable() { in testTimedWait_IllegalMonitorException()
355 Thread t = newStartedThread(new CheckedRunnable() { in testTimedWait_Interruptible()
390 final Thread s = newStartedThread(new CheckedInterruptedRunnable() { in testTimedJoin_Interruptible()
394 final Thread t = newStartedThread(new CheckedRunnable() { in testTimedJoin_Interruptible()
425 Thread t = newStartedThread(new CheckedRunnable() { in testTimedSleep_Interruptible()
DThreadLocalRandomTest.java276 Thread first = newStartedThread(getRandomState);
282 Thread t = newStartedThread(getRandomState);
DLinkedBlockingQueueTest.java241 Thread t = newStartedThread(new CheckedRunnable() { in testBlockingPut()
279 Thread t = newStartedThread(new CheckedRunnable() { in testPutWithTake()
311 Thread t = newStartedThread(new CheckedRunnable() { in testTimedOffer()
347 Thread t = newStartedThread(new CheckedRunnable() { in testBlockingTake()
419 Thread t = newStartedThread(new CheckedRunnable() { in testInterruptedTimedPoll()
DPriorityBlockingQueueTest.java260 Thread t = newStartedThread(new CheckedRunnable() { in testPutWithTake()
276 Thread t = newStartedThread(new CheckedRunnable() { in testTimedOffer()
303 Thread t = newStartedThread(new CheckedRunnable() { in testBlockingTake()
375 Thread t = newStartedThread(new CheckedRunnable() { in testInterruptedTimedPoll()
DArrayBlockingQueueTest.java251 Thread t = newStartedThread(new CheckedRunnable() { in testBlockingPut()
289 Thread t = newStartedThread(new CheckedRunnable() { in testPutWithTake()
321 Thread t = newStartedThread(new CheckedRunnable() { in testTimedOffer()
357 Thread t = newStartedThread(new CheckedRunnable() { in testBlockingTake()
430 Thread t = newStartedThread(new CheckedRunnable() { in testInterruptedTimedPoll()
DDelayQueueTest.java293 Thread t = newStartedThread(new CheckedRunnable() { in testPutWithTake()
310 Thread t = newStartedThread(new CheckedRunnable() { in testTimedOffer()
337 Thread t = newStartedThread(new CheckedRunnable() { in testBlockingTake()
408 Thread t = newStartedThread(new CheckedRunnable() { in testInterruptedTimedPoll()
DExecutorsTest.java268 threads.add(newStartedThread(new CheckedRunnable() { in testTimedCallable()
DRecursiveActionTest.java418 t = newStartedThread(r); in testJoinIgnoresInterruptsOutsideForkJoinPool()
423 t = newStartedThread(r); in testJoinIgnoresInterruptsOutsideForkJoinPool()
DJSR166TestCase.java635 Thread newStartedThread(Runnable runnable) { in newStartedThread() method in JSR166TestCase
DThreadPoolExecutorTest.java1003 Thread t = newStartedThread(new CheckedInterruptedRunnable() { in testInterruptedSubmit()