Package com.inductiveautomation.sfc.api

Class ExecutionQueue

java.lang.Object

com.inductiveautomation.sfc.api.ExecutionQueue

public class ExecutionQueue
extends Object

Queues up submitted Runnables and executes them in serial on an ExecutorService.

Nested Class Summary

Nested Classes

Modifier and Type	Class	Description
class	ExecutionQueue.ThrowableCatchingRunnable

Constructor Summary

Constructors

Constructor	Description
ExecutionQueue(ExecutorService service, MDCUtils.MDCDetails logDetails)
ExecutionQueue(ExecutorService service, MDCUtils.MDCDetails logDetails, String identId)

Method Summary

Modifier and Type	Method	Description
void	beginTransaction()	If multiple commands must be put on the queue in an atomic manner, use this to begin a transaction.
void	closeTransaction()
void	pause()	Pause execution of queued Runnables.
void	resume()	Resume execution of queued Runnables.
void	submit(Runnable runnable)	Submit a Runnable to be executed.
void	submit(Runnable runnable, String logMsg)

Methods inherited from class java.lang.Object

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

Constructor Details

ExecutionQueue

public ExecutionQueue(ExecutorService service,
 MDCUtils.MDCDetails logDetails)

ExecutionQueue

public ExecutionQueue(ExecutorService service,
 MDCUtils.MDCDetails logDetails,
 String identId)

Method Details

beginTransaction

public void beginTransaction()

If multiple commands must be put on the queue in an atomic manner, use this to begin a transaction. All submissions will be queued in order with nothing else allowed until closeTransaction is called. Be sure to call closeTransaction in a finally block.

closeTransaction

public void closeTransaction()

submit

public void submit(Runnable runnable)

Submit a Runnable to be executed.

Parameters:

runnable - the Runnable to be executed.

submit

public void submit(Runnable runnable,
 String logMsg)

pause

public void pause()

Pause execution of queued Runnables.

resume

public void resume()

Resume execution of queued Runnables.