Package com.telnyx.webrtc.lib

Class ThreadUtils

java.lang.Object

com.telnyx.webrtc.lib.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)
static void	checkIsOnMainThread()	Throws exception if called from other than main thread.
static void	executeUninterruptibly(ThreadUtils.BlockingOperation operation)	Utility method to make sure a blocking operation is executed to completion without getting interrupted.
static void	invokeAtFrontUninterruptibly(Handler handler, Runnable runner)	Post `runner` to `handler`, at the front, and wait for completion.
static <V> V	invokeAtFrontUninterruptibly(Handler handler, Callable<V> callable)	Post `callable` to `handler` and wait for the result.
static void	joinUninterruptibly(Thread thread)
static boolean	joinUninterruptibly(Thread thread, long timeoutMs)

Methods inherited from class java.lang.Object

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

Constructor Details

ThreadUtils

public ThreadUtils()

Method Details

checkIsOnMainThread

public static void checkIsOnMainThread()

Throws exception if called from other than main thread.

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)

invokeAtFrontUninterruptibly

public static <V> V invokeAtFrontUninterruptibly(Handler handler,
 Callable<V> callable)

Post `callable` to `handler` and wait for the result.

invokeAtFrontUninterruptibly

public static void invokeAtFrontUninterruptibly(Handler handler,
 Runnable runner)

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