org.threadly.test.concurrent

Class BlockingTestRunnable

java.lang.Object

org.threadly.test.concurrent.TestRunnable

org.threadly.test.concurrent.BlockingTestRunnable

All Implemented Interfaces:

java.lang.Runnable

public class BlockingTestRunnable
extends TestRunnable

An implementation of TestRunnable which will initially block the running thread with Object.wait() when handleRunStart() is invoked. The thread will remain blocked until unblock() is invoked.

Since:

1.0

Constructor Summary

Constructors

Constructor and Description
BlockingTestRunnable()

Method Summary

Modifier and Type	Method and Description
void	handleRunStart() Function to be overloaded by extending classes if more data or operations need to happen at the run point.
boolean	isUnblocked() Check if the task has been unblocked yet.
void	unblock() Invoke to unblock any current or future executions for this TestRunnable.

Methods inherited from class org.threadly.test.concurrent.TestRunnable

blockTillFinished, blockTillFinished, blockTillFinished, blockTillStarted, blockTillStarted, getCreationTime, getDelayTillFirstRun, getDelayTillRun, getDelayTillRun, getRunCount, getRunDelayInMillis, handleRunFinish, isRunning, ranConcurrently, ranOnce, run, setRunDelayInMillis

Methods inherited from class java.lang.Object

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

Constructor Detail

BlockingTestRunnable

public BlockingTestRunnable()

Method Detail

handleRunStart

public void handleRunStart()
                    throws java.lang.InterruptedException

Description copied from class: TestRunnable

Function to be overloaded by extending classes if more data or operations need to happen at the run point.

This is also the first call to be made in the runnable, but all necessary TestRunnable actions are in a finally block so it is safe to throw any exceptions necessary here.

Overrides:

handleRunStart in class TestRunnable

Throws:

java.lang.InterruptedException - only InterruptedExceptions will be swallowed

isUnblocked

public boolean isUnblocked()

Check if the task has been unblocked yet.

Returns:

true if the thread has been unblocked.

unblock

public void unblock()

Invoke to unblock any current or future executions for this TestRunnable. Once invoked no future blocking will occur. In general this should be invoked at the end of every test (fail or not) to avoid having left over blocked threads hanging around.