Searched refs:waitingThread (Results 1 – 5 of 5) sorted by relevance
42 private WaitingThread waitingThread; field in WaitingThreadAborter51 if (waitingThread != null) in abort()52 waitingThread.interrupt(); in abort()62 public void setWaitingThread(WaitingThread waitingThread) { in setWaitingThread() argument63 this.waitingThread = waitingThread; in setWaitingThread()65 waitingThread.interrupt(); in setWaitingThread()
284 WaitingThread waitingThread = null;334 if (waitingThread == null) {335 waitingThread =337 aborter.setWaitingThread(waitingThread);342 rospl.queueThread(waitingThread);343 waitingThreads.add(waitingThread);344 success = waitingThread.await(deadline);351 rospl.removeThread(waitingThread);352 waitingThreads.remove(waitingThread);614 WaitingThread waitingThread = null;[all …]
133 private val waitingThread = atomic<Thread?>(null) constant138 waitingThread.value?.let { LockSupport.unpark(it) } in fireEvent()142 check(waitingThread.getAndSet(Thread.currentThread()) == null) in blockingAwait()147 waitingThread.value = null in blockingAwait()
200 Thread waitingThread = new Thread(interruptReporter); in runNInterruptsTest() local201 waitingThread.start(); in runNInterruptsTest()203 waitingThread.interrupt(); in runNInterruptsTest()219 Thread waitingThread = new Thread(wasInterrupted); in testMakeUninterruptible_plainFutureSanityCheck() local220 waitingThread.start(); in testMakeUninterruptible_plainFutureSanityCheck()221 waitingThread.interrupt(); in testMakeUninterruptible_plainFutureSanityCheck()