Index
All Classes and Interfaces|All Packages|Constant Field Values
A
- assertEquals(Object, Object) - Method in class net.jodah.concurrentunit.Waiter
-
Asserts that the
expected
values equals theactual
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 bymatcher
. - 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 calledexpectedResumes
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 calledexpectedResumes
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 thereason
as anAssertionError
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()
andReentrantCircuit.close()
calls, allows waiting threads to be interrupted, and ensures fairness when releasingwaiting
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.
All Classes and Interfaces|All Packages|Constant Field Values