com.facebook.react.bridge.queue

Class MessageQueueThreadImpl

java.lang.Object

com.facebook.react.bridge.queue.MessageQueueThreadImpl

All Implemented Interfaces:

MessageQueueThread

public class MessageQueueThreadImpl
extends java.lang.Object
implements MessageQueueThread

Encapsulates a Thread that has a Looper running on it that can accept Runnables.

Method Summary

Modifier and Type	Method and Description
void	assertIsOnThread() Asserts isOnThread(), throwing a AssertionException (NOT an AssertionError) if the assertion fails.
<T> java.util.concurrent.Future<T>	callOnQueue(java.util.concurrent.Callable<T> callable) Runs the given Callable on this Thread.
static MessageQueueThreadImpl	create(MessageQueueThreadSpec spec, QueueThreadExceptionHandler exceptionHandler)
android.os.Looper	getLooper()
java.lang.String	getName()
boolean	isOnThread()
void	quitSynchronous() Quits this queue's Looper.
void	runOnQueue(java.lang.Runnable runnable) Runs the given Runnable on this Thread.
static MessageQueueThreadImpl	startNewBackgroundThread(java.lang.String name, long stackSize, QueueThreadExceptionHandler exceptionHandler) Creates and starts a new MessageQueueThreadImpl encapsulating a new Thread with a new Looper running on it.
static MessageQueueThreadImpl	startNewBackgroundThread(java.lang.String name, QueueThreadExceptionHandler exceptionHandler)

Methods inherited from class java.lang.Object

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

Method Detail

runOnQueue

public void runOnQueue(java.lang.Runnable runnable)

Runs the given Runnable on this Thread. It will be submitted to the end of the event queue even if it is being submitted from the same queue Thread.

Specified by:

runOnQueue in interface MessageQueueThread

callOnQueue

public <T> java.util.concurrent.Future<T> callOnQueue(java.util.concurrent.Callable<T> callable)

Description copied from interface: MessageQueueThread

Runs the given Callable on this Thread. It will be submitted to the end of the event queue even if it is being submitted from the same queue Thread.

Specified by:

callOnQueue in interface MessageQueueThread

isOnThread

public boolean isOnThread()

Specified by:

isOnThread in interface MessageQueueThread

Returns:

whether the current Thread is also the Thread associated with this MessageQueueThread.

assertIsOnThread

public void assertIsOnThread()

Asserts isOnThread(), throwing a AssertionException (NOT an AssertionError) if the assertion fails.

Specified by:

assertIsOnThread in interface MessageQueueThread

quitSynchronous

public void quitSynchronous()

Quits this queue's Looper. If that Looper was running on a different Thread than the current Thread, also waits for the last message being processed to finish and the Thread to die.

Specified by:

quitSynchronous in interface MessageQueueThread

getLooper

public android.os.Looper getLooper()

getName

public java.lang.String getName()

create

public static MessageQueueThreadImpl create(MessageQueueThreadSpec spec,
                                            QueueThreadExceptionHandler exceptionHandler)

startNewBackgroundThread

public static MessageQueueThreadImpl startNewBackgroundThread(java.lang.String name,
                                                              QueueThreadExceptionHandler exceptionHandler)

startNewBackgroundThread

public static MessageQueueThreadImpl startNewBackgroundThread(java.lang.String name,
                                                              long stackSize,
                                                              QueueThreadExceptionHandler exceptionHandler)

Creates and starts a new MessageQueueThreadImpl encapsulating a new Thread with a new Looper running on it. Give it a name for easier debugging and optionally a suggested stack size. When this method exits, the new MessageQueueThreadImpl is ready to receive events.