A C F I N O R S T W 
All Classes All Packages

A

assertEquals(Object, Object) - Method in class net.jodah.concurrentunit.Waiter
Asserts that the expected values equals the actual value
assertFalse(boolean) - Method in class net.jodah.concurrentunit.Waiter
Asserts that the condition is false.
assertNotNull(Object) - Method in class net.jodah.concurrentunit.Waiter
Asserts that the object is not null.
assertNull(Object) - Method in class net.jodah.concurrentunit.Waiter
Asserts that the object is null.
assertThat(T, Matcher<? super T>) - Method in class net.jodah.concurrentunit.Waiter
Asserts that actual satisfies the condition specified by matcher.
assertTrue(boolean) - Method in class net.jodah.concurrentunit.Waiter
Asserts that the condition is true.
await() - Method in class net.jodah.concurrentunit.ConcurrentTestCase
 
await() - Method in class net.jodah.concurrentunit.internal.ReentrantCircuit
Waits for the circuit to be closed, aborting if interrupted.
await() - Method in class net.jodah.concurrentunit.Waiter
Waits until Waiter.resume() is called, or the test is failed.
await(long) - Method in class net.jodah.concurrentunit.ConcurrentTestCase
 
await(long) - Method in class net.jodah.concurrentunit.Waiter
Waits until the delay has elapsed, Waiter.resume() is called, or the test is failed.
await(long, int) - Method in class net.jodah.concurrentunit.ConcurrentTestCase
 
await(long, int) - Method in class net.jodah.concurrentunit.Waiter
Waits until the delay has elapsed, Waiter.resume() is called expectedResumes times, or the test is failed.
await(long, TimeUnit) - Method in class net.jodah.concurrentunit.ConcurrentTestCase
 
await(long, TimeUnit) - Method in class net.jodah.concurrentunit.internal.ReentrantCircuit
Waits for the waitDuration until the circuit has been closed, aborting if interrupted, returning true if the circuit is closed else false.
await(long, TimeUnit) - Method in class net.jodah.concurrentunit.Waiter
Waits until the delay has elapsed, Waiter.resume() is called, or the test is failed.
await(long, TimeUnit, int) - Method in class net.jodah.concurrentunit.ConcurrentTestCase
 
await(long, TimeUnit, int) - Method in class net.jodah.concurrentunit.Waiter
Waits until the delay has elapsed, Waiter.resume() is called expectedResumes times, or the test is failed.

C

circuit - Variable in class net.jodah.concurrentunit.Waiter
 
close() - Method in class net.jodah.concurrentunit.internal.ReentrantCircuit
Closes the circuit, releasing any waiting threads.
ConcurrentTestCase - Class in net.jodah.concurrentunit
Convenience support class, wrapping a Waiter.
ConcurrentTestCase() - Constructor for class net.jodah.concurrentunit.ConcurrentTestCase
 

F

fail() - Method in class net.jodah.concurrentunit.Waiter
Fails the current test.
fail(String) - Method in class net.jodah.concurrentunit.Waiter
Fails the current test for the given reason.
fail(Throwable) - Method in class net.jodah.concurrentunit.Waiter
Fails the current test with the given reason, sets the number of expected resumes to 0, and throws the reason as an AssertionError in the main test thread and in the current thread.
failure - Variable in class net.jodah.concurrentunit.Waiter
 
format(Object, Object) - Method in class net.jodah.concurrentunit.Waiter
 

I

interruptWaiters() - Method in class net.jodah.concurrentunit.internal.ReentrantCircuit
Interrupts waiting threads.
isClosed() - Method in class net.jodah.concurrentunit.internal.ReentrantCircuit
Returns whether the circuit is closed.
isClosed() - Method in class net.jodah.concurrentunit.internal.ReentrantCircuit.Sync
 

N

net.jodah.concurrentunit - package net.jodah.concurrentunit
 
net.jodah.concurrentunit.internal - package net.jodah.concurrentunit.internal
 

O

open() - Method in class net.jodah.concurrentunit.internal.ReentrantCircuit
Opens the circuit.
open() - Method in class net.jodah.concurrentunit.internal.ReentrantCircuit.Sync
 

R

ReentrantCircuit - Class in net.jodah.concurrentunit.internal
A circuit that accepts re-entrant ReentrantCircuit.open() and ReentrantCircuit.close() calls, allows waiting threads to be interrupted, and ensures fairness when releasing waiting threads.
ReentrantCircuit() - Constructor for class net.jodah.concurrentunit.internal.ReentrantCircuit
 
ReentrantCircuit.Sync - Class in net.jodah.concurrentunit.internal
Synchronization state of 0 = closed, 1 = open.
remainingResumes - Variable in class net.jodah.concurrentunit.Waiter
 
resume() - Method in class net.jodah.concurrentunit.ConcurrentTestCase
 
resume() - Method in class net.jodah.concurrentunit.Waiter
Resumes the waiter when the expected number of Waiter.resume() calls have occurred.
rethrow(Throwable) - Method in class net.jodah.concurrentunit.ConcurrentTestCase
 
rethrow(Throwable) - Method in class net.jodah.concurrentunit.Waiter
Rethrows the failure in the main test thread and in the current thread.

S

serialVersionUID - Static variable in class net.jodah.concurrentunit.internal.ReentrantCircuit.Sync
 
sneakyThrow(Throwable) - Static method in class net.jodah.concurrentunit.Waiter
 
sneakyThrow2(Throwable) - Static method in class net.jodah.concurrentunit.Waiter
 
sync - Variable in class net.jodah.concurrentunit.internal.ReentrantCircuit
 
Sync() - Constructor for class net.jodah.concurrentunit.internal.ReentrantCircuit.Sync
 

T

threadAssertEquals(Object, Object) - Method in class net.jodah.concurrentunit.ConcurrentTestCase
 
threadAssertFalse(boolean) - Method in class net.jodah.concurrentunit.ConcurrentTestCase
 
threadAssertNotNull(Object) - Method in class net.jodah.concurrentunit.ConcurrentTestCase
 
threadAssertNull(Object) - Method in class net.jodah.concurrentunit.ConcurrentTestCase
 
threadAssertTrue(boolean) - Method in class net.jodah.concurrentunit.ConcurrentTestCase
 
threadFail() - Method in class net.jodah.concurrentunit.ConcurrentTestCase
 
threadFail(String) - Method in class net.jodah.concurrentunit.ConcurrentTestCase
 
threadFail(Throwable) - Method in class net.jodah.concurrentunit.ConcurrentTestCase
 
TIMEOUT_MESSAGE - Static variable in class net.jodah.concurrentunit.Waiter
 
toString() - Method in class net.jodah.concurrentunit.internal.ReentrantCircuit
 
tryAcquireShared(int) - Method in class net.jodah.concurrentunit.internal.ReentrantCircuit.Sync
Opens the circuit if not a test.
tryReleaseShared(int) - Method in class net.jodah.concurrentunit.internal.ReentrantCircuit.Sync
Closes the circuit.

W

waiter - Variable in class net.jodah.concurrentunit.ConcurrentTestCase
 
Waiter - Class in net.jodah.concurrentunit
Waits on a test, carrying out assertions, until being resumed.
Waiter() - Constructor for class net.jodah.concurrentunit.Waiter
Creates a new Waiter.
A C F I N O R S T W 
All Classes All Packages