com.liferay.portal.kernel.concurrent.test

Class TestUtil

Object

com.liferay.portal.kernel.concurrent.test.TestUtil

public class TestUtil
extends Object

Author:

Shuyang Zhou

Field Summary

Fields

Modifier and Type	Field and Description
static long	KEEPALIVE_TIME
static long	KEEPALIVE_WAIT
static long	LONG_WAIT
static long	SHORT_WAIT

Constructor Summary

Constructors

Constructor and Description
TestUtil()

Method Summary

Modifier and Type	Method and Description
static void	closePool(com.liferay.portal.kernel.concurrent.ThreadPoolExecutor threadPoolExecutor)
static void	closePool(com.liferay.portal.kernel.concurrent.ThreadPoolExecutor threadPoolExecutor, boolean force)
static void	unblock(MarkerBlockingJob... markerBlockingJobs)
static void	waitUntilBlock(MarkerBlockingJob... markerBlockingJobs)
static void	waitUntilEnded(MarkerBlockingJob... markerBlockingJobs)

Methods inherited from class Object

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

Field Detail

KEEPALIVE_TIME

public static final long KEEPALIVE_TIME

See Also:

Constant Field Values

KEEPALIVE_WAIT

public static final long KEEPALIVE_WAIT

See Also:

Constant Field Values

LONG_WAIT

public static final long LONG_WAIT

See Also:

Constant Field Values

SHORT_WAIT

public static final long SHORT_WAIT

See Also:

Constant Field Values

Constructor Detail

TestUtil

public TestUtil()

Method Detail

closePool

public static void closePool(com.liferay.portal.kernel.concurrent.ThreadPoolExecutor threadPoolExecutor)

closePool

public static void closePool(com.liferay.portal.kernel.concurrent.ThreadPoolExecutor threadPoolExecutor,
                             boolean force)

unblock

public static void unblock(MarkerBlockingJob... markerBlockingJobs)

waitUntilBlock

public static void waitUntilBlock(MarkerBlockingJob... markerBlockingJobs)
                           throws InterruptedException

Throws:

InterruptedException

waitUntilEnded

public static void waitUntilEnded(MarkerBlockingJob... markerBlockingJobs)
                           throws InterruptedException

Throws:

InterruptedException