Home
last modified time | relevance | path

Searched refs:joinUninterruptibly (Results 1 – 20 of 20) sorted by relevance

/external/guava/guava-tests/test/com/google/common/util/concurrent/
DInterruptionUtil.java100 joinUninterruptibly(interruptingThread, 2500, MILLISECONDS); in repeatedlyInterruptTestThread()
116 private static void joinUninterruptibly(Thread thread, long timeout, TimeUnit unit) { in joinUninterruptibly() method in InterruptionUtil
DUninterruptiblesTest.java22 import static com.google.common.util.concurrent.Uninterruptibles.joinUninterruptibly;
274 joinUninterruptibly(thread); in testJoinWithNoWait()
275 joinUninterruptibly(thread, 0, MILLISECONDS); in testJoinWithNoWait()
276 joinUninterruptibly(thread, -42, MILLISECONDS); in testJoinWithNoWait()
277 joinUninterruptibly(thread, LONG_DELAY_MS, MILLISECONDS); in testJoinWithNoWait()
771 Uninterruptibles.joinUninterruptibly(thread); in joinSuccessfully()
777 Uninterruptibles.joinUninterruptibly(thread, timeoutMillis, MILLISECONDS); in joinSuccessfully()
783 Uninterruptibles.joinUninterruptibly(thread, timeoutMillis, MILLISECONDS); in joinUnsuccessfully()
DSupplementalMonitorTest.java20 import static com.google.common.util.concurrent.Uninterruptibles.joinUninterruptibly;
126 joinUninterruptibly( in verifyOccupiedMethodsInAnotherThread()
DMoreExecutorsTest.java277 Uninterruptibles.joinUninterruptibly(waiter, 10, TimeUnit.SECONDS); in testDirectExecutorService_awaitTermination_missedSignal()
/external/guava/android/guava-tests/test/com/google/common/util/concurrent/
DInterruptionUtil.java100 joinUninterruptibly(interruptingThread, 2500, MILLISECONDS); in repeatedlyInterruptTestThread()
116 private static void joinUninterruptibly(Thread thread, long timeout, TimeUnit unit) { in joinUninterruptibly() method in InterruptionUtil
DUninterruptiblesTest.java22 import static com.google.common.util.concurrent.Uninterruptibles.joinUninterruptibly;
273 joinUninterruptibly(thread); in testJoinWithNoWait()
274 joinUninterruptibly(thread, 0, MILLISECONDS); in testJoinWithNoWait()
275 joinUninterruptibly(thread, -42, MILLISECONDS); in testJoinWithNoWait()
276 joinUninterruptibly(thread, LONG_DELAY_MS, MILLISECONDS); in testJoinWithNoWait()
750 Uninterruptibles.joinUninterruptibly(thread); in joinSuccessfully()
756 Uninterruptibles.joinUninterruptibly(thread, timeoutMillis, MILLISECONDS); in joinSuccessfully()
762 Uninterruptibles.joinUninterruptibly(thread, timeoutMillis, MILLISECONDS); in joinUnsuccessfully()
DSupplementalMonitorTest.java20 import static com.google.common.util.concurrent.Uninterruptibles.joinUninterruptibly;
126 joinUninterruptibly( in verifyOccupiedMethodsInAnotherThread()
DMoreExecutorsTest.java277 Uninterruptibles.joinUninterruptibly(waiter, 10, TimeUnit.SECONDS); in testDirectExecutorService_awaitTermination_missedSignal()
/external/guava/guava/src/com/google/common/util/concurrent/
DUninterruptibles.java158 public static void joinUninterruptibly(Thread toJoin) { in joinUninterruptibly() method in Uninterruptibles
184 public static void joinUninterruptibly(Thread toJoin, Duration timeout) { in joinUninterruptibly() method in Uninterruptibles
185 joinUninterruptibly(toJoin, toNanosSaturated(timeout), TimeUnit.NANOSECONDS); in joinUninterruptibly()
194 public static void joinUninterruptibly(Thread toJoin, long timeout, TimeUnit unit) { in joinUninterruptibly() method in Uninterruptibles
/external/webrtc/rtc_base/java/src/org/webrtc/
DThreadUtils.java82 public static boolean joinUninterruptibly(final Thread thread, long timeoutMs) { in joinUninterruptibly() method in ThreadUtils
105 public static void joinUninterruptibly(final Thread thread) { in joinUninterruptibly() method in ThreadUtils
/external/guava/android/guava/src/com/google/common/util/concurrent/
DUninterruptibles.java131 public static void joinUninterruptibly(Thread toJoin) { in joinUninterruptibly() method in Uninterruptibles
155 public static void joinUninterruptibly(Thread toJoin, long timeout, TimeUnit unit) { in joinUninterruptibly() method in Uninterruptibles
/external/webrtc/sdk/android/instrumentationtests/src/org/webrtc/
DCamera2CapturerTest.java152 ThreadUtils.joinUninterruptibly(looperThread); in close()
/external/webrtc/modules/audio_device/android/java/src/org/webrtc/voiceengine/
DWebRtcAudioRecord.java316 if (!ThreadUtils.joinUninterruptibly(audioThread, AUDIO_RECORD_THREAD_JOIN_TIMEOUT_MS)) { in stopRecording()
DWebRtcAudioTrack.java333 if (!ThreadUtils.joinUninterruptibly(audioThread, AUDIO_TRACK_THREAD_JOIN_TIMEOUT_MS)) { in stopPlayout()
/external/webrtc/sdk/android/src/java/org/webrtc/audio/
DWebRtcAudioTrack.java303 if (!ThreadUtils.joinUninterruptibly(audioThread, AUDIO_TRACK_THREAD_JOIN_TIMEOUT_MS)) { in stopPlayout()
DWebRtcAudioRecord.java394 if (!ThreadUtils.joinUninterruptibly(audioThread, AUDIO_RECORD_THREAD_JOIN_TIMEOUT_MS)) { in stopRecording()
/external/guava/android/guava-tests/test/com/google/common/hash/
DBloomFilterTest.java589 Uninterruptibles.joinUninterruptibly(t); in runThreadsAndReturnExceptions()
/external/webrtc/sdk/android/src/java/org/webrtc/
DHardwareVideoEncoder.java296 if (!ThreadUtils.joinUninterruptibly(outputThread, MEDIA_CODEC_RELEASE_TIMEOUT_MS)) { in release()
DAndroidVideoDecoder.java339 if (!ThreadUtils.joinUninterruptibly(outputThread, MEDIA_CODEC_RELEASE_TIMEOUT_MS)) { in releaseInternal()
/external/guava/guava-tests/test/com/google/common/hash/
DBloomFilterTest.java605 Uninterruptibles.joinUninterruptibly(t); in runThreadsAndReturnExceptions()