org.opennms.test

Class ThreadLocker

java.lang.Object

org.opennms.test.ThreadLocker

public class ThreadLocker
extends Object

This class can be used to verify the number of threads that are calling a particular method. This is achieved by locking all of the threads that call MessageProducer#send and providing a callback (via a CompletableFuture) that is invoked once the desired number of threads is reached. If a larger number of threads than expected call MessageProducer#send, these are locked as well, and the number of these is provided by getNumExtraThreadsWaiting().

Author:

jwhite

Constructor Summary

Constructors

Constructor and Description
ThreadLocker()

Method Summary

Modifier and Type	Method and Description
int	getNumExtraThreadsWaiting()
void	park()
void	release()
CompletableFuture<Integer>	waitForThreads(int numThreads)

Methods inherited from class java.lang.Object

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

Constructor Detail

ThreadLocker

public ThreadLocker()

Method Detail

waitForThreads

public CompletableFuture<Integer> waitForThreads(int numThreads)

park

public void park()

release

public void release()

getNumExtraThreadsWaiting

public int getNumExtraThreadsWaiting()