Package org.webrtc

Class ThreadUtils

java.lang.Object

org.webrtc.ThreadUtils

public class ThreadUtils
extends Object

Nested Class Summary

Nested Classes

Modifier and Type	Class	Description
static interface	ThreadUtils.BlockingOperation	Utility interface to be used with executeUninterruptibly() to wait for blocking operations to complete without getting interrupted..
static class	ThreadUtils.ThreadChecker	Utility class to be used for checking that a method is called on the correct thread.

Constructor Summary

Constructors

Constructor	Description
ThreadUtils()

Method Summary

Modifier and Type	Method	Description
static void	awaitUninterruptibly(CountDownLatch latch)
static boolean	awaitUninterruptibly(CountDownLatch barrier, long timeoutMs)
(package private) static StackTraceElement[]	concatStackTraces(StackTraceElement[] inner, StackTraceElement[] outer)	Post `runner` to `handler`, at the front, and wait for completion.
static void	executeUninterruptibly(ThreadUtils.BlockingOperation operation)	Utility method to make sure a blocking operation is executed to completion without getting interrupted.
static void	joinUninterruptibly(Thread thread)
static boolean	joinUninterruptibly(Thread thread, long timeoutMs)

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Details

ThreadUtils

public ThreadUtils()

Method Details

executeUninterruptibly

public static void executeUninterruptibly(ThreadUtils.BlockingOperation operation)

Utility method to make sure a blocking operation is executed to completion without getting interrupted. This should be used in cases where the operation is waiting for some critical work, e.g. cleanup, that must complete before returning. If the thread is interrupted during the blocking operation, this function will re-run the operation until completion, and only then re-interrupt the thread.

joinUninterruptibly

public static boolean joinUninterruptibly(Thread thread,
 long timeoutMs)

joinUninterruptibly

public static void joinUninterruptibly(Thread thread)

awaitUninterruptibly

public static void awaitUninterruptibly(CountDownLatch latch)

awaitUninterruptibly

public static boolean awaitUninterruptibly(CountDownLatch barrier,
 long timeoutMs)

concatStackTraces

static StackTraceElement[] concatStackTraces(StackTraceElement[] inner,
 StackTraceElement[] outer)

Post `runner` to `handler`, at the front, and wait for completion.