Package org.jppf.utils.concurrent
package org.jppf.utils.concurrent
Utility and helper classes for concurrent programming.
Found in: jppf-common.jar
-
ClassDescriptionAn asynchronous logger that delegates to an underlying SLF4J logger asychronously.A set of utility methods to facilitate concurrent and multithreaded programming.This interface represents a condition to evaluate to either
trueorfalse.This interface handles exceptions raised by itsevaluate()method and returnsfalsewhen it happens.This class performs periodic deadlock checks and prints detailed deadlock information, along with a thread dump, to the log, the first time a deadlock is detected.A thread that prints out the call stack whenDebuggableThread.interrupt()is called.This class is for logging and debugging purposes.A non-fair lock implementation that allows assigning a readable and identifiable name andtoString().Custom thread factory used mostly to specify the names of created threads.A thread pool based on an ubounded queue which supports a core and maximum number of threads, along with a TTL for non-core threads.A thread pool based on an ubounded queue which supports a core and maximum number of threads, along with a TTL for non-core threads.Holds a mutable object reference witho no locking or synchronization mechanism.QueueHandler<E>Instances of this class handle an optionally bounded queue of elements.Builder class forQueueHandlerinstances.An operation applied to each element taken from the queue by the dequeuer thread(s).Callback invoked when a new peak queue size is reached.A boolean value on which a set of operations can be performed atomically.An integer value on which a set of operations can be performed atomically.A long value on which a set of operations can be performed atomically.AnObjectvalue on which a set of operations can be performed atomically.This class implements a goToSleep and a wakeUp method as wrappers toObject.wait()andObject.notifyAll()wrappers.Utility methods for creating, starting and manipulating threads.