A B C D E F G H I J K L M N O P Q R S T U V W Y Z

A

AbstractCompletableExecutorService - Class in co.paralleluniverse.concurrent.util

Implements CompletableExecutorService execution methods atop the abstract Executor.execute(java.lang.Runnable) method.

AbstractCompletableExecutorService() - Constructor for class co.paralleluniverse.concurrent.util.AbstractCompletableExecutorService

AbstractFuture<V> - Class in co.paralleluniverse.strands

AbstractFuture() - Constructor for class co.paralleluniverse.strands.AbstractFuture

AbstractOwnableSynchronizer - Class in co.paralleluniverse.strands.concurrent

A synchronizer that may be exclusively owned by a strand.

AbstractOwnableSynchronizer() - Constructor for class co.paralleluniverse.strands.concurrent.AbstractOwnableSynchronizer

Empty constructor for use by subclasses.

AbstractQueuedLongSynchronizer - Class in co.paralleluniverse.strands.concurrent

A version of AbstractQueuedSynchronizer in which synchronization state is maintained as a long.

AbstractQueuedLongSynchronizer() - Constructor for class co.paralleluniverse.strands.concurrent.AbstractQueuedLongSynchronizer

Creates a new AbstractQueuedLongSynchronizer instance with initial synchronization state of zero.

AbstractQueuedLongSynchronizer.ConditionObject - Class in co.paralleluniverse.strands.concurrent

Condition implementation for a AbstractQueuedLongSynchronizer serving as the basis of a Lock implementation.

AbstractQueuedSynchronizer - Class in co.paralleluniverse.strands.concurrent

Provides a framework for implementing blocking locks and related synchronizers (semaphores, events, etc) that rely on first-in-first-out (FIFO) wait queues.

AbstractQueuedSynchronizer() - Constructor for class co.paralleluniverse.strands.concurrent.AbstractQueuedSynchronizer

Creates a new AbstractQueuedSynchronizer instance with initial synchronization state of zero.

AbstractQueuedSynchronizer.ConditionObject - Class in co.paralleluniverse.strands.concurrent

Condition implementation for a AbstractQueuedSynchronizer serving as the basis of a Lock implementation.

accept(InputStream, int, T) - Static method in class co.paralleluniverse.common.reflection.ASMUtil

accept(byte[], int, T) - Static method in class co.paralleluniverse.common.reflection.ASMUtil

accept(String, ClassLoader, int, T) - Static method in class co.paralleluniverse.common.reflection.ASMUtil

accept(Class<?>, int, T) - Static method in class co.paralleluniverse.common.reflection.ASMUtil

accept(URLClassLoader, ClassLoaderUtil.Visitor) - Static method in class co.paralleluniverse.common.reflection.ClassLoaderUtil

accept(ClassLoader, URL[], ClassLoaderUtil.Visitor) - Static method in class co.paralleluniverse.common.reflection.ClassLoaderUtil

accept() - Method in class co.paralleluniverse.fibers.io.FiberServerSocketChannel

Accepts a connection.

accessible(T) - Static method in class co.paralleluniverse.common.reflection.ReflectionUtil

acquire(long) - Method in class co.paralleluniverse.strands.concurrent.AbstractQueuedLongSynchronizer

Acquires in exclusive mode, ignoring interrupts.

acquire(int) - Method in class co.paralleluniverse.strands.concurrent.AbstractQueuedSynchronizer

Acquires in exclusive mode, ignoring interrupts.

acquire() - Method in class co.paralleluniverse.strands.concurrent.Semaphore

Acquires a permit from this semaphore, blocking until one is available, or the thread is interrupted.

acquire(int) - Method in class co.paralleluniverse.strands.concurrent.Semaphore

Acquires the given number of permits from this semaphore, blocking until all are available, or the thread is interrupted.

acquireInterruptibly(long) - Method in class co.paralleluniverse.strands.concurrent.AbstractQueuedLongSynchronizer

Acquires in exclusive mode, aborting if interrupted.

acquireInterruptibly(int) - Method in class co.paralleluniverse.strands.concurrent.AbstractQueuedSynchronizer

Acquires in exclusive mode, aborting if interrupted.

acquireShared(long) - Method in class co.paralleluniverse.strands.concurrent.AbstractQueuedLongSynchronizer

Acquires in shared mode, ignoring interrupts.

acquireShared(int) - Method in class co.paralleluniverse.strands.concurrent.AbstractQueuedSynchronizer

Acquires in shared mode, ignoring interrupts.

acquireSharedInterruptibly(long) - Method in class co.paralleluniverse.strands.concurrent.AbstractQueuedLongSynchronizer

Acquires in shared mode, aborting if interrupted.

acquireSharedInterruptibly(int) - Method in class co.paralleluniverse.strands.concurrent.AbstractQueuedSynchronizer

Acquires in shared mode, aborting if interrupted.

acquireUninterruptibly() - Method in class co.paralleluniverse.strands.concurrent.Semaphore

Acquires a permit from this semaphore, blocking until one is available.

acquireUninterruptibly(int) - Method in class co.paralleluniverse.strands.concurrent.Semaphore

Acquires the given number of permits from this semaphore, blocking until all are available.

Action2<S1,S2> - Interface in co.paralleluniverse.common.util

add(long) - Method in class co.paralleluniverse.common.monitoring.Counter

add(E) - Method in class co.paralleluniverse.common.util.ConcurrentSet

add(int, E) - Method in class co.paralleluniverse.common.util.Tuple

add(E) - Method in class co.paralleluniverse.concurrent.util.ConcurrentSkipListSet

Adds the specified element to this set if it is not already present.

add(E) - Method in class co.paralleluniverse.concurrent.util.DelayQueue

Inserts the specified element into this delay queue.

add(T...) - Method in interface co.paralleluniverse.strands.channels.Mix

add(T...) - Method in class co.paralleluniverse.strands.channels.ReceivePortGroup

add(E) - Method in class co.paralleluniverse.strands.queues.SingleConsumerQueue

addAll(int, Collection<? extends E>) - Method in class co.paralleluniverse.common.util.Tuple

addAll(Collection<? extends E>) - Method in class co.paralleluniverse.concurrent.util.SingleConsumerNonblockingProducerQueue

addClassLoadListener(Retransform.ClassLoadListener) - Static method in class co.paralleluniverse.fibers.instrument.Retransform

addExcludedPackage(String) - Method in class co.paralleluniverse.fibers.instrument.QuasarInstrumentor

addFileSet(FileSet) - Method in class co.paralleluniverse.fibers.instrument.InstrumentationTask

addFileSet(FileSet) - Method in class co.paralleluniverse.fibers.instrument.OldSuspendablesScanner

addFileSet(FileSet) - Method in class co.paralleluniverse.fibers.instrument.SuspendablesScanner

addPerfNotificationListener(NotificationListener, Object) - Method in class co.paralleluniverse.common.monitoring.MonitoringServices

addStructuralNotificationListener(NotificationListener, Object) - Method in class co.paralleluniverse.common.monitoring.MonitoringServices

addWaiver(String, String) - Static method in class co.paralleluniverse.fibers.instrument.Retransform

addWaiver(String, String) - Static method in class co.paralleluniverse.fibers.instrument.SuspendableHelper

afterTransform(String, Class, byte[]) - Method in interface co.paralleluniverse.fibers.instrument.Retransform.ClassLoadListener

agentmain(String, Instrumentation) - Static method in class co.paralleluniverse.fibers.instrument.JavaAgent

AnnotationUtil - Class in co.paralleluniverse.common.reflection

apply(S1, S2) - Method in interface co.paralleluniverse.common.util.Function2

apply(S1, S2, S3) - Method in interface co.paralleluniverse.common.util.Function3

apply(S1, S2, S3, S4) - Method in interface co.paralleluniverse.common.util.Function4

apply(S1, S2, S3, S4, S5) - Method in interface co.paralleluniverse.common.util.Function5

ArrayQueue<E> - Class in co.paralleluniverse.strands.queues

ArrayQueue(int) - Constructor for class co.paralleluniverse.strands.queues.ArrayQueue

arrive() - Method in class co.paralleluniverse.strands.concurrent.Phaser

Arrives at this phaser, without waiting for others to arrive.

arriveAndAwaitAdvance() - Method in class co.paralleluniverse.strands.concurrent.Phaser

Arrives at this phaser and awaits others.

arriveAndDeregister() - Method in class co.paralleluniverse.strands.concurrent.Phaser

Arrives at this phaser and deregisters from it without waiting for others to arrive.

ASMAPI - Static variable in class co.paralleluniverse.common.reflection.AnnotationUtil

ASMAPI - Static variable in class co.paralleluniverse.fibers.instrument.QuasarInstrumentor

ASMUtil - Class in co.paralleluniverse.common.reflection

asObjectInput(Input, Kryo) - Static method in class co.paralleluniverse.io.serialization.kryo.KryoUtil

asObjectOutput(Output, Kryo) - Static method in class co.paralleluniverse.io.serialization.kryo.KryoUtil

asReadLock() - Method in class co.paralleluniverse.strands.concurrent.StampedLock

Returns a plain Lock view of this StampedLock in which the Lock.lock() method is mapped to readLock(), and similarly for other methods.

asReadWriteLock() - Method in class co.paralleluniverse.strands.concurrent.StampedLock

Returns a ReadWriteLock view of this StampedLock in which the ReadWriteLock.readLock() method is mapped to asReadLock(), and ReadWriteLock.writeLock() to asWriteLock().

asSuspendable(Runnable) - Static method in class co.paralleluniverse.strands.SuspendableUtils

asSuspendable(Callable<V>) - Static method in class co.paralleluniverse.strands.SuspendableUtils

asSuspendableCallable(CheckedSuspendableCallable<V, E>) - Static method in class co.paralleluniverse.strands.SuspendableUtils

asWriteLock() - Method in class co.paralleluniverse.strands.concurrent.StampedLock

Returns a plain Lock view of this StampedLock in which the Lock.lock() method is mapped to writeLock(), and similarly for other methods.

asyncCompleted(V) - Method in class co.paralleluniverse.fibers.FiberAsync

This method must be called by the callback upon successful completion of the asynchronous operation.

AsyncCompletionStage<V> - Class in co.paralleluniverse.fibers.futures

Turns CompletableFutures into fiber-blocking operations.

asyncFailed(Throwable) - Method in class co.paralleluniverse.fibers.FiberAsync

This method must be called by the callback upon a failure of the asynchronous operation.

AsyncListenableFuture<V> - Class in co.paralleluniverse.fibers.futures

Turns Google Guava's ListenableFutures into a fiber-blocking operation.

availablePermits() - Method in class co.paralleluniverse.strands.concurrent.Semaphore

Returns the current number of permits available in this semaphore.

await() - Method in class co.paralleluniverse.strands.concurrent.AbstractQueuedLongSynchronizer.ConditionObject

Implements interruptible condition wait.

await(long, TimeUnit) - Method in class co.paralleluniverse.strands.concurrent.AbstractQueuedLongSynchronizer.ConditionObject

Implements timed condition wait.

await() - Method in class co.paralleluniverse.strands.concurrent.AbstractQueuedSynchronizer.ConditionObject

Implements interruptible condition wait.

await(long, TimeUnit) - Method in class co.paralleluniverse.strands.concurrent.AbstractQueuedSynchronizer.ConditionObject

Implements timed condition wait.

await() - Method in class co.paralleluniverse.strands.concurrent.CountDownLatch

Causes the current thread to wait until the latch has counted down to zero, unless the thread is interrupted.

await(long, TimeUnit) - Method in class co.paralleluniverse.strands.concurrent.CountDownLatch

Causes the current thread to wait until the latch has counted down to zero, unless the thread is interrupted, or the specified waiting time elapses.

await() - Method in class co.paralleluniverse.strands.concurrent.CyclicBarrier

Waits until all parties have invoked await on this barrier.

await(long, TimeUnit) - Method in class co.paralleluniverse.strands.concurrent.CyclicBarrier

Waits until all parties have invoked await on this barrier, or the specified waiting time elapses.

await(int) - Method in interface co.paralleluniverse.strands.Condition

await(int, long, TimeUnit) - Method in interface co.paralleluniverse.strands.Condition

await(int) - Method in class co.paralleluniverse.strands.ConditionSynchronizer

await(int, long, TimeUnit) - Method in class co.paralleluniverse.strands.ConditionSynchronizer

await(int) - Method in class co.paralleluniverse.strands.DoneSynchronizer

await(int, long, TimeUnit) - Method in class co.paralleluniverse.strands.DoneSynchronizer

awaitAdvance(int) - Method in class co.paralleluniverse.strands.concurrent.Phaser

Awaits the phase of this phaser to advance from the given phase value, returning immediately if the current phase is not equal to the given phase value or this phaser is terminated.

awaitAdvanceInterruptibly(int) - Method in class co.paralleluniverse.strands.concurrent.Phaser

Awaits the phase of this phaser to advance from the given phase value, throwing InterruptedException if interrupted while waiting, or returning immediately if the current phase is not equal to the given phase value or this phaser is terminated.

awaitAdvanceInterruptibly(int, long, TimeUnit) - Method in class co.paralleluniverse.strands.concurrent.Phaser

Awaits the phase of this phaser to advance from the given phase value or the given timeout to elapse, throwing InterruptedException if interrupted while waiting, or returning immediately if the current phase is not equal to the given phase value or this phaser is terminated.

awaitNanos(long) - Method in class co.paralleluniverse.strands.concurrent.AbstractQueuedLongSynchronizer.ConditionObject

Implements timed condition wait.

awaitNanos(long) - Method in class co.paralleluniverse.strands.concurrent.AbstractQueuedSynchronizer.ConditionObject

Implements timed condition wait.

awaitNanos(int, long) - Method in class co.paralleluniverse.strands.ConditionSynchronizer

awaitTermination(long, TimeUnit) - Method in class co.paralleluniverse.common.util.SameThreadExecutorService

awaitTermination(long, TimeUnit) - Method in class co.paralleluniverse.concurrent.util.ScheduledSingleThreadExecutor

awaitTermination(long, TimeUnit) - Method in class co.paralleluniverse.fibers.FiberTimedScheduler

awaitUninterruptibly() - Method in class co.paralleluniverse.strands.concurrent.AbstractQueuedLongSynchronizer.ConditionObject

Implements uninterruptible condition wait.

awaitUninterruptibly() - Method in class co.paralleluniverse.strands.concurrent.AbstractQueuedSynchronizer.ConditionObject

Implements uninterruptible condition wait.

awaitUntil(Date) - Method in class co.paralleluniverse.strands.concurrent.AbstractQueuedLongSynchronizer.ConditionObject

Implements absolute timed condition wait.

awaitUntil(Date) - Method in class co.paralleluniverse.strands.concurrent.AbstractQueuedSynchronizer.ConditionObject

Implements absolute timed condition wait.

B

BasicExtendedStackTraceElement(StackTraceElement, Class<?>, Method, int) - Constructor for class co.paralleluniverse.common.util.ExtendedStackTrace.BasicExtendedStackTraceElement

BasicExtendedStackTraceElement(StackTraceElement, Class<?>) - Constructor for class co.paralleluniverse.common.util.ExtendedStackTrace.BasicExtendedStackTraceElement

BasicExtendedStackTraceElement(StackTraceElement) - Constructor for class co.paralleluniverse.common.util.ExtendedStackTrace.BasicExtendedStackTraceElement

BasicQueue<E> - Interface in co.paralleluniverse.strands.queues

BasicSingleConsumerDoubleQueue - Interface in co.paralleluniverse.strands.queues

BasicSingleConsumerFloatQueue - Interface in co.paralleluniverse.strands.queues

BasicSingleConsumerIntQueue - Interface in co.paralleluniverse.strands.queues

BasicSingleConsumerLongQueue - Interface in co.paralleluniverse.strands.queues

BasicSingleConsumerQueue<E> - Interface in co.paralleluniverse.strands.queues

beforeTransform(String, Class, byte[]) - Method in interface co.paralleluniverse.fibers.instrument.Retransform.ClassLoadListener

bind(SocketAddress) - Method in class co.paralleluniverse.fibers.io.FiberServerSocketChannel

Binds the channel's socket to a local address and configures the socket to listen for connections.

bind(SocketAddress, int) - Method in class co.paralleluniverse.fibers.io.FiberServerSocketChannel

Binds the channel's socket to a local address and configures the socket to listen for connections.

bind(SocketAddress) - Method in class co.paralleluniverse.fibers.io.FiberSocketChannel

BLOCK_SIZE - Static variable in class co.paralleluniverse.strands.queues.SingleConsumerLinkedArrayObjectQueue

BoxQueue<E> - Class in co.paralleluniverse.strands.queues

BoxQueue(boolean, boolean) - Constructor for class co.paralleluniverse.strands.queues.BoxQueue

build() - Method in class co.paralleluniverse.strands.StrandFactoryBuilder

Creates and returns the StrandFactory that will create new strands based on this builder's settings.

builtinConsumer() - Method in class co.paralleluniverse.strands.queues.CircularBuffer

bulkRegister(int) - Method in class co.paralleluniverse.strands.concurrent.Phaser

Adds the given number of new unarrived parties to this phaser.

ByteArraySerializer - Interface in co.paralleluniverse.io.serialization

C

call(S1, S2) - Method in interface co.paralleluniverse.common.util.Action2

call() - Method in interface co.paralleluniverse.common.util.CheckedCallable

call() - Method in interface co.paralleluniverse.strands.CheckedSuspendableCallable

call(S) - Method in interface co.paralleluniverse.strands.SuspendableAction1

call(S1, S2) - Method in interface co.paralleluniverse.strands.SuspendableAction2

cancel(boolean) - Method in class co.paralleluniverse.fibers.Fiber

cancel(boolean) - Method in class co.paralleluniverse.strands.AbstractFuture

cancel(boolean) - Method in class co.paralleluniverse.strands.dataflow.Val

Throws UnsupportedOperationException.

capacity() - Method in class co.paralleluniverse.strands.channels.QueueChannel

capacity() - Method in interface co.paralleluniverse.strands.channels.StandardChannel

The channel's internal buffer capacity.

capacity() - Method in class co.paralleluniverse.strands.channels.TransferChannel

capacity() - Method in class co.paralleluniverse.strands.queues.ArrayQueue

capacity() - Method in interface co.paralleluniverse.strands.queues.BasicQueue

capacity() - Method in class co.paralleluniverse.strands.queues.BoxQueue

capacity() - Method in class co.paralleluniverse.strands.queues.CircularBuffer

capacity() - Method in class co.paralleluniverse.strands.queues.SingleConsumerQueue

CAPTURE_UNPARK_STACK - Static variable in class co.paralleluniverse.concurrent.forkjoin.ParkableForkJoinTask

ceiling(E) - Method in class co.paralleluniverse.concurrent.util.ConcurrentSkipListSet

Channel<Message> - Interface in co.paralleluniverse.strands.channels

A message-passing channel.

ChannelClosedException - Exception in co.paralleluniverse.strands.channels

ChannelClosedException() - Constructor for exception co.paralleluniverse.strands.channels.ChannelClosedException

ChannelClosedException(String) - Constructor for exception co.paralleluniverse.strands.channels.ChannelClosedException

ChannelClosedException(String, Throwable) - Constructor for exception co.paralleluniverse.strands.channels.ChannelClosedException

ChannelClosedException(Throwable) - Constructor for exception co.paralleluniverse.strands.channels.ChannelClosedException

ChannelClosedException(SendPort<?>) - Constructor for exception co.paralleluniverse.strands.channels.ChannelClosedException

ChannelClosedException(SendPort<?>, Throwable) - Constructor for exception co.paralleluniverse.strands.channels.ChannelClosedException

ChannelGroup - Class in co.paralleluniverse.fibers.io

A grouping of channels for the purpose of resource sharing.

ChannelGroup() - Constructor for class co.paralleluniverse.fibers.io.ChannelGroup

Channels - Class in co.paralleluniverse.strands.channels

A utility class for creating and manipulating channels.

Channels.OverflowPolicy - Enum in co.paralleluniverse.strands.channels

Determines how a channel behaves when its internal buffer (if it has one) overflows.

charAt(int) - Method in class co.paralleluniverse.common.util.Substring

CharSequences - Class in co.paralleluniverse.common.util

check(String, String) - Method in class co.paralleluniverse.fibers.instrument.MethodDatabase.ClassEntry

checkClass(File) - Method in class co.paralleluniverse.fibers.instrument.MethodDatabase

checkClass(String) - Method in class co.paralleluniverse.fibers.instrument.MethodDatabase

checkClosed() - Method in class co.paralleluniverse.strands.channels.QueuePrimitiveChannel

checkClosed() - Method in class co.paralleluniverse.strands.channels.SingleConsumerQueueChannel

checkClosed() - Method in class co.paralleluniverse.strands.channels.TickerChannelConsumer

CheckedCallable<V,E extends java.lang.Exception> - Interface in co.paralleluniverse.common.util

CheckedSuspendableCallable<V,E extends java.lang.Exception> - Interface in co.paralleluniverse.strands

This interface can represent any operation that may suspend the currently executing Strand (i.e.

CheckInstrumentationVisitor - Class in co.paralleluniverse.fibers.instrument

Check if a class contains suspendable methods.

CheckInstrumentationVisitor(MethodDatabase) - Constructor for class co.paralleluniverse.fibers.instrument.CheckInstrumentationVisitor

CircularBuffer<E> - Class in co.paralleluniverse.strands.queues

CircularBuffer.Consumer - Class in co.paralleluniverse.strands.queues

CircularDoubleBuffer - Class in co.paralleluniverse.strands.queues

CircularDoubleBuffer(int, boolean) - Constructor for class co.paralleluniverse.strands.queues.CircularDoubleBuffer

CircularDoubleBuffer.DoubleConsumer - Class in co.paralleluniverse.strands.queues

CircularFloatBuffer - Class in co.paralleluniverse.strands.queues

CircularFloatBuffer(int, boolean) - Constructor for class co.paralleluniverse.strands.queues.CircularFloatBuffer

CircularFloatBuffer.FloatConsumer - Class in co.paralleluniverse.strands.queues

CircularIntBuffer - Class in co.paralleluniverse.strands.queues

CircularIntBuffer(int, boolean) - Constructor for class co.paralleluniverse.strands.queues.CircularIntBuffer

CircularIntBuffer.IntConsumer - Class in co.paralleluniverse.strands.queues

CircularLongBuffer - Class in co.paralleluniverse.strands.queues

CircularLongBuffer(int, boolean) - Constructor for class co.paralleluniverse.strands.queues.CircularLongBuffer

CircularLongBuffer.LongConsumer - Class in co.paralleluniverse.strands.queues

CircularObjectBuffer<E> - Class in co.paralleluniverse.strands.queues

CircularObjectBuffer(int, boolean) - Constructor for class co.paralleluniverse.strands.queues.CircularObjectBuffer

ClassEntry(String) - Constructor for class co.paralleluniverse.fibers.instrument.MethodDatabase.ClassEntry

Classes - Class in co.paralleluniverse.fibers.instrument

This class contains hard-coded values with the names of the classes and methods relevant for instrumentation.

ClassLoaderMXBean - Interface in co.paralleluniverse.common.classloader

ClassLoaderUtil - Class in co.paralleluniverse.common.reflection

ClassLoaderUtil.Visitor - Interface in co.paralleluniverse.common.reflection

classToResource(String) - Static method in class co.paralleluniverse.common.reflection.ClassLoaderUtil

classToResource(Class<?>) - Static method in class co.paralleluniverse.common.reflection.ClassLoaderUtil

classToSlashed(String) - Static method in class co.paralleluniverse.common.reflection.ClassLoaderUtil

classToSlashed(Class<?>) - Static method in class co.paralleluniverse.common.reflection.ClassLoaderUtil

clazz - Variable in class co.paralleluniverse.common.monitoring.GenericRecordingDouble

clear() - Method in class co.paralleluniverse.common.monitoring.FlightRecorder

clear() - Method in class co.paralleluniverse.common.util.ConcurrentSet

clear() - Method in class co.paralleluniverse.concurrent.util.ConcurrentSkipListPriorityQueue

Removes all of the mappings from this map.

clear() - Method in class co.paralleluniverse.concurrent.util.ConcurrentSkipListSet

Removes all of the elements from this set.

clear() - Method in class co.paralleluniverse.concurrent.util.DelayQueue

Atomically removes all of the elements from this delay queue.

clear() - Method in class co.paralleluniverse.concurrent.util.SingleConsumerNonblockingProducerQueue

clear() - Method in class co.paralleluniverse.strands.queues.SingleConsumerQueue

clearValue() - Method in class co.paralleluniverse.strands.queues.CircularBuffer.Consumer

clone() - Method in class co.paralleluniverse.concurrent.util.ConcurrentSkipListPriorityQueue

Returns a shallow copy of this ConcurrentSkipListMap instance.

clone(Strand, SuspendableCallable<?>) - Static method in class co.paralleluniverse.strands.Strand

clone(Strand, SuspendableRunnable) - Static method in class co.paralleluniverse.strands.Strand

cloneThreadLocalMap(Object) - Static method in class co.paralleluniverse.concurrent.util.ThreadAccess

close() - Method in class co.paralleluniverse.fibers.io.FiberFileChannel

close() - Method in class co.paralleluniverse.fibers.io.FiberServerSocketChannel

close() - Method in class co.paralleluniverse.fibers.io.FiberSocketChannel

close() - Method in class co.paralleluniverse.strands.channels.DelegatingReceivePort

close(Throwable) - Method in class co.paralleluniverse.strands.channels.DelegatingSendPort

close() - Method in class co.paralleluniverse.strands.channels.DelegatingSendPort

close() - Method in interface co.paralleluniverse.strands.channels.PortAutoCloseable

Closes the channel so that no more messages could be sent to it.

close() - Method in class co.paralleluniverse.strands.channels.QueueChannel

close(Throwable) - Method in class co.paralleluniverse.strands.channels.QueueChannel

close() - Method in class co.paralleluniverse.strands.channels.ReceivePortGroup

close(Throwable) - Method in interface co.paralleluniverse.strands.channels.SendPort

Closes the channel so that no more messages could be sent to it, and signifies an exception occurred in the producer.

close(Throwable) - Method in class co.paralleluniverse.strands.channels.SplitSendPort

close() - Method in class co.paralleluniverse.strands.channels.SplitSendPort

close() - Method in class co.paralleluniverse.strands.channels.ThreadReceivePort

Closes the channel so that no more messages could be sent to it.

close() - Method in class co.paralleluniverse.strands.channels.ThreadSendPort

Closes the channel so that no more messages could be sent to it.

close() - Method in class co.paralleluniverse.strands.channels.TickerChannelConsumer

close() - Method in class co.paralleluniverse.strands.channels.Topic

close(Throwable) - Method in class co.paralleluniverse.strands.channels.Topic

close() - Method in class co.paralleluniverse.strands.channels.TransferChannel

close(Throwable) - Method in class co.paralleluniverse.strands.channels.TransferChannel

close() - Method in class co.paralleluniverse.strands.channels.ZippingReceivePort

close() - Method in class co.paralleluniverse.strands.dataflow.ValChannel

co.paralleluniverse.common.benchmark - package co.paralleluniverse.common.benchmark

co.paralleluniverse.common.classloader - package co.paralleluniverse.common.classloader

co.paralleluniverse.common.logging - package co.paralleluniverse.common.logging

co.paralleluniverse.common.monitoring - package co.paralleluniverse.common.monitoring

co.paralleluniverse.common.reflection - package co.paralleluniverse.common.reflection

co.paralleluniverse.common.test - package co.paralleluniverse.common.test

co.paralleluniverse.common.util - package co.paralleluniverse.common.util

co.paralleluniverse.concurrent.forkjoin - package co.paralleluniverse.concurrent.forkjoin

co.paralleluniverse.concurrent.util - package co.paralleluniverse.concurrent.util

co.paralleluniverse.fibers - package co.paralleluniverse.fibers

Fibers - lightweight threads

co.paralleluniverse.fibers.futures - package co.paralleluniverse.fibers.futures

Common future implementations as fiber-blocking operations

co.paralleluniverse.fibers.instrument - package co.paralleluniverse.fibers.instrument

Quasar continuations instrumentation

co.paralleluniverse.fibers.io - package co.paralleluniverse.fibers.io

Fiber-blocking NIO

co.paralleluniverse.io.serialization - package co.paralleluniverse.io.serialization

co.paralleluniverse.io.serialization.kryo - package co.paralleluniverse.io.serialization.kryo

co.paralleluniverse.remote - package co.paralleluniverse.remote

co.paralleluniverse.strands - package co.paralleluniverse.strands

Strands - abstractions over fibers and threads

co.paralleluniverse.strands.channels - package co.paralleluniverse.strands.channels

Channels - a CSP (Communicating Sequential Processes) construct

co.paralleluniverse.strands.channels.transfer - package co.paralleluniverse.strands.channels.transfer

co.paralleluniverse.strands.concurrent - package co.paralleluniverse.strands.concurrent

Concurrency primitives for strands - ports of java.util.concurrent classes compatible with strands

co.paralleluniverse.strands.dataflow - package co.paralleluniverse.strands.dataflow

co.paralleluniverse.strands.queues - package co.paralleluniverse.strands.queues

combine() - Method in class co.paralleluniverse.common.benchmark.Striped

combine() - Method in class co.paralleluniverse.common.benchmark.StripedHistogram

comparator() - Static method in class co.paralleluniverse.common.util.CharSequences

comparator() - Method in class co.paralleluniverse.concurrent.util.ConcurrentSkipListPriorityQueue

comparator() - Method in class co.paralleluniverse.concurrent.util.ConcurrentSkipListSet

compare(CharSequence, CharSequence) - Static method in class co.paralleluniverse.common.util.CharSequences

compareAndSetState(long, long) - Method in class co.paralleluniverse.strands.concurrent.AbstractQueuedLongSynchronizer

Atomically sets synchronization state to the given updated value if the current state value equals the expected value.

compareAndSetState(int, int) - Method in class co.paralleluniverse.strands.concurrent.AbstractQueuedSynchronizer

Atomically sets synchronization state to the given updated value if the current state value equals the expected value.

compareTo(Substring) - Method in class co.paralleluniverse.common.util.Substring

completableDecorator(ExecutorService) - Static method in class co.paralleluniverse.concurrent.util.CompletableExecutors

If the delegate executor was already an instance of CompletableExecutorService, it is returned untouched, and the rest of this documentation does not apply.

completableDecorator(ScheduledExecutorService) - Static method in class co.paralleluniverse.concurrent.util.CompletableExecutors

If the delegate executor was already an instance of CompletableScheduledExecutorService, it is returned untouched, and the rest of this documentation does not apply.

CompletableExecutors - Class in co.paralleluniverse.concurrent.util

CompletableExecutorService - Interface in co.paralleluniverse.concurrent.util

CompletableFutureTask<V> - Class in co.paralleluniverse.concurrent.util

CompletableScheduledExecutorService - Interface in co.paralleluniverse.concurrent.util

ConcurrentSet<E> - Class in co.paralleluniverse.common.util

ConcurrentSet(ConcurrentMap<E, Object>) - Constructor for class co.paralleluniverse.common.util.ConcurrentSet

ConcurrentSet(ConcurrentMap<E, Object>, Collection<E>) - Constructor for class co.paralleluniverse.common.util.ConcurrentSet

ConcurrentSkipListPriorityQueue<E> - Class in co.paralleluniverse.concurrent.util

ConcurrentSkipListPriorityQueue() - Constructor for class co.paralleluniverse.concurrent.util.ConcurrentSkipListPriorityQueue

Constructs a new, empty map, sorted according to the natural ordering of the keys.

ConcurrentSkipListPriorityQueue(Comparator<? super E>) - Constructor for class co.paralleluniverse.concurrent.util.ConcurrentSkipListPriorityQueue

Constructs a new, empty map, sorted according to the specified comparator.

ConcurrentSkipListPriorityQueue(Collection<? extends E>) - Constructor for class co.paralleluniverse.concurrent.util.ConcurrentSkipListPriorityQueue

ConcurrentSkipListSet<E> - Class in co.paralleluniverse.concurrent.util

A scalable concurrent NavigableSet implementation based on a ConcurrentSkipListMap.

ConcurrentSkipListSet() - Constructor for class co.paralleluniverse.concurrent.util.ConcurrentSkipListSet

Constructs a new, empty set that orders its elements according to their natural ordering.

ConcurrentSkipListSet(Comparator<? super E>) - Constructor for class co.paralleluniverse.concurrent.util.ConcurrentSkipListSet

Constructs a new, empty set that orders its elements according to the specified comparator.

ConcurrentSkipListSet(Collection<? extends E>) - Constructor for class co.paralleluniverse.concurrent.util.ConcurrentSkipListSet

Constructs a new set containing the elements in the specified collection, that orders its elements according to their natural ordering.

ConcurrentSkipListSet(SortedSet<E>) - Constructor for class co.paralleluniverse.concurrent.util.ConcurrentSkipListSet

Constructs a new set containing the same elements and using the same ordering as the specified sorted set.

Condition - Interface in co.paralleluniverse.strands

ConditionObject() - Constructor for class co.paralleluniverse.strands.concurrent.AbstractQueuedLongSynchronizer.ConditionObject

Creates a new ConditionObject instance.

ConditionObject() - Constructor for class co.paralleluniverse.strands.concurrent.AbstractQueuedSynchronizer.ConditionObject

Creates a new ConditionObject instance.

ConditionSelector - Class in co.paralleluniverse.strands

ConditionSelector(Object, Collection<Condition>) - Constructor for class co.paralleluniverse.strands.ConditionSelector

ConditionSelector(Object, Condition...) - Constructor for class co.paralleluniverse.strands.ConditionSelector

ConditionSynchronizer - Class in co.paralleluniverse.strands

ConditionSynchronizer(Object) - Constructor for class co.paralleluniverse.strands.ConditionSynchronizer

connect(SocketAddress) - Method in class co.paralleluniverse.fibers.io.FiberSocketChannel

Connects this channel.

connect(SocketAddress, long, TimeUnit) - Method in class co.paralleluniverse.fibers.io.FiberSocketChannel

Connects this channel.

Consumer() - Constructor for class co.paralleluniverse.strands.queues.CircularBuffer.Consumer

contains(Object) - Method in class co.paralleluniverse.common.util.ConcurrentSet

contains(Object) - Method in class co.paralleluniverse.common.util.Tuple

contains(Object) - Method in class co.paralleluniverse.concurrent.util.ConcurrentSkipListPriorityQueue

contains(Object) - Method in class co.paralleluniverse.concurrent.util.ConcurrentSkipListSet

Returns true if this set contains the specified element.

contains(Object) - Method in class co.paralleluniverse.concurrent.util.SingleConsumerNonblockingProducerQueue

containsAll(Collection<?>) - Method in class co.paralleluniverse.concurrent.util.SingleConsumerNonblockingProducerQueue

countDown() - Method in class co.paralleluniverse.strands.concurrent.CountDownLatch

Decrements the count of the latch, releasing all waiting threads if the count reaches zero.

CountDownLatch - Class in co.paralleluniverse.strands.concurrent

A synchronization aid that allows one or more threads to wait until a set of operations being performed in other threads completes.

CountDownLatch(int) - Constructor for class co.paralleluniverse.strands.concurrent.CountDownLatch

Constructs a CountDownLatch initialized with the given count.

Counter - Class in co.paralleluniverse.common.monitoring

Counter() - Constructor for class co.paralleluniverse.common.monitoring.Counter

counter(String) - Static method in class co.paralleluniverse.common.monitoring.Metrics

CpuUsageGaugeSet - Class in co.paralleluniverse.common.monitoring

A MetricSet that monitors CPU usage using HotSpot MBeans.

CpuUsageGaugeSet() - Constructor for class co.paralleluniverse.common.monitoring.CpuUsageGaugeSet

CpuUsageGaugeSet(MBeanServer) - Constructor for class co.paralleluniverse.common.monitoring.CpuUsageGaugeSet

crazyClojureOnceDisable(ClassLoader, String, Class<?>, ProtectionDomain, byte[]) - Static method in class co.paralleluniverse.fibers.instrument.JavaAgent

create(SendPort<Message>, Object) - Method in interface co.paralleluniverse.remote.RemoteChannelProxyFactory

create(SendPort<Message>, Object) - Static method in class co.paralleluniverse.remote.RemoteChannelProxyFactoryService

createInheritedMap(Object) - Static method in class co.paralleluniverse.concurrent.util.ThreadAccess

createThread(ForkJoinPool) - Method in class co.paralleluniverse.concurrent.forkjoin.ExtendedForkJoinWorkerFactory

current() - Static method in class co.paralleluniverse.strands.StrandLocalRandom

Returns the current thread's ThreadLocalRandom.

currentFiber() - Static method in class co.paralleluniverse.fibers.Fiber

Returns the active Fiber on this thread or NULL if no Fiber is running.

currentStrand - Static variable in class co.paralleluniverse.strands.Strand

currentStrand() - Static method in class co.paralleluniverse.strands.Strand

Returns the current strand.

CyclicBarrier - Class in co.paralleluniverse.strands.concurrent

A synchronization aid that allows a set of threads to all wait for each other to reach a common barrier point.

CyclicBarrier(int, Runnable) - Constructor for class co.paralleluniverse.strands.concurrent.CyclicBarrier

Creates a new CyclicBarrier that will trip when the given number of parties (threads) are waiting upon it, and which will execute the given barrier action when the barrier is tripped, performed by the last thread entering the barrier.

CyclicBarrier(int) - Constructor for class co.paralleluniverse.strands.concurrent.CyclicBarrier

Creates a new CyclicBarrier that will trip when the given number of parties (threads) are waiting upon it, and does not perform a predefined action when the barrier is tripped.

D

Debug - Class in co.paralleluniverse.common.util

Debug.StackTraceFilter - Interface in co.paralleluniverse.common.util

dec() - Method in class co.paralleluniverse.common.monitoring.Counter

DEC - Static variable in class co.paralleluniverse.concurrent.util.EnhancedAtomicLong

decorateTask(Runnable, RunnableScheduledFuture<V>) - Method in class co.paralleluniverse.concurrent.util.ScheduledSingleThreadExecutor

Modifies or replaces the task used to execute a runnable.

decorateTask(Callable<V>, RunnableScheduledFuture<V>) - Method in class co.paralleluniverse.concurrent.util.ScheduledSingleThreadExecutor

Modifies or replaces the task used to execute a callable.

DEFAULT_STACK_SIZE - Static variable in class co.paralleluniverse.fibers.Fiber

DefaultFiberScheduler - Class in co.paralleluniverse.fibers

The default FiberScheduler used to schedule fibers that do not specify a particular scheduler.

DefaultFiberScheduler() - Constructor for class co.paralleluniverse.fibers.DefaultFiberScheduler

DefaultSuspendableClassifier - Class in co.paralleluniverse.fibers.instrument

DefaultSuspendableClassifier(ClassLoader) - Constructor for class co.paralleluniverse.fibers.instrument.DefaultSuspendableClassifier

DelayQueue<E extends java.util.concurrent.Delayed> - Class in co.paralleluniverse.concurrent.util

An unbounded blocking queue of Delayed elements, in which an element can only be taken when its delay has expired.

DelayQueue() - Constructor for class co.paralleluniverse.concurrent.util.DelayQueue

Creates a new DelayQueue that is initially empty.

DelayQueue(Collection<? extends E>) - Constructor for class co.paralleluniverse.concurrent.util.DelayQueue

Creates a DelayQueue initially containing the elements of the given collection of Delayed instances.

DelegatingEquals - Interface in co.paralleluniverse.common.util

Represents an object that delegates its equals method to another, delegate, object.

DelegatingReceivePort<T> - Class in co.paralleluniverse.strands.channels

DelegatingReceivePort(ReceivePort<T>) - Constructor for class co.paralleluniverse.strands.channels.DelegatingReceivePort

DelegatingSendPort<T> - Class in co.paralleluniverse.strands.channels

DelegatingSendPort(SendPort<T>) - Constructor for class co.paralleluniverse.strands.channels.DelegatingSendPort

deq() - Method in interface co.paralleluniverse.strands.queues.QueueIterator

descendingIterator() - Method in class co.paralleluniverse.concurrent.util.ConcurrentSkipListSet

Returns an iterator over the elements in this set in descending order.

descendingSet() - Method in class co.paralleluniverse.concurrent.util.ConcurrentSkipListSet

Returns a reverse order view of the elements contained in this set.

DoneSynchronizer - Class in co.paralleluniverse.strands

DontInstrument - Annotation Type in co.paralleluniverse.fibers.instrument

Marks a method as suspendable.

doPark(boolean) - Method in class co.paralleluniverse.concurrent.forkjoin.ParkableForkJoinTask

DoubleChannel - Interface in co.paralleluniverse.strands.channels

A channel for primitive double messages.

DoubleConsumer() - Constructor for class co.paralleluniverse.strands.queues.CircularDoubleBuffer.DoubleConsumer

doubleNext() - Method in interface co.paralleluniverse.strands.queues.DoubleQueueIterator

DoubleQueueIterator - Interface in co.paralleluniverse.strands.queues

DoubleReceivePort - Interface in co.paralleluniverse.strands.channels

A primitive double channel's consumer-side interface.

DoubleSendPort - Interface in co.paralleluniverse.strands.channels

A primitive double channel's producer-side interface.

doubleValue() - Method in interface co.paralleluniverse.strands.queues.DoubleQueueIterator

drainPermits() - Method in class co.paralleluniverse.strands.concurrent.Semaphore

Acquires and returns all permits that are immediately available.

drainTo(Collection<? super E>) - Method in class co.paralleluniverse.concurrent.util.DelayQueue

drainTo(Collection<? super E>, int) - Method in class co.paralleluniverse.concurrent.util.DelayQueue

drainTo(Collection<? super E>) - Method in class co.paralleluniverse.concurrent.util.SingleConsumerNonblockingProducerQueue

drainTo(Collection<? super E>, int) - Method in class co.paralleluniverse.concurrent.util.SingleConsumerNonblockingProducerQueue

dump(String) - Method in class co.paralleluniverse.common.monitoring.FlightRecorder

dump(PrintStream) - Method in class co.paralleluniverse.common.monitoring.FlightRecorder

dump(String) - Method in interface co.paralleluniverse.common.monitoring.FlightRecorderMXBean

dumpAfter(long) - Static method in class co.paralleluniverse.common.util.Debug

dumpAfter(long, String) - Static method in class co.paralleluniverse.common.util.Debug

dumpClass(String, byte[]) - Static method in class co.paralleluniverse.fibers.instrument.Retransform

dumpInheritableThreadLocals() - Static method in class co.paralleluniverse.concurrent.util.ThreadUtil

dumpRecorder() - Static method in class co.paralleluniverse.common.util.Debug

dumpRecorder(String) - Static method in class co.paralleluniverse.common.util.Debug

dumpStack() - Static method in class co.paralleluniverse.common.util.Debug

dumpStack(PrintStream, Throwable) - Static method in class co.paralleluniverse.common.util.Debug

dumpStack(PrintStream, Throwable, Debug.StackTraceFilter) - Static method in class co.paralleluniverse.common.util.Debug

dumpStack() - Static method in class co.paralleluniverse.fibers.Fiber

dumpStack() - Static method in class co.paralleluniverse.strands.Strand

Prints a stack trace of the current strand to the standard error stream.

dumpThreadLocals() - Static method in class co.paralleluniverse.concurrent.util.ThreadUtil

dumpThreads() - Static method in class co.paralleluniverse.concurrent.util.ThreadUtil

E

element() - Method in class co.paralleluniverse.strands.queues.SingleConsumerQueue

EMERGENCY_UNBLOCKER - Static variable in class co.paralleluniverse.concurrent.forkjoin.ParkableForkJoinTask

emptyReceivePort() - Static method in class co.paralleluniverse.strands.channels.Channels

Returns an empty ReceivePort.

EnhancedAtomicLong - Class in co.paralleluniverse.concurrent.util

Extension of AtomicLong with useful methods based on CAS.

EnhancedAtomicLong() - Constructor for class co.paralleluniverse.concurrent.util.EnhancedAtomicLong

EnhancedAtomicReference<V> - Class in co.paralleluniverse.concurrent.util

Extension of AtomicReference with useful methods based on CAS.

EnhancedAtomicReference() - Constructor for class co.paralleluniverse.concurrent.util.EnhancedAtomicReference

enq(E) - Method in class co.paralleluniverse.strands.queues.ArrayQueue

enq(E) - Method in interface co.paralleluniverse.strands.queues.BasicQueue

enq(double) - Method in interface co.paralleluniverse.strands.queues.BasicSingleConsumerDoubleQueue

enq(float) - Method in interface co.paralleluniverse.strands.queues.BasicSingleConsumerFloatQueue

enq(int) - Method in interface co.paralleluniverse.strands.queues.BasicSingleConsumerIntQueue

enq(long) - Method in interface co.paralleluniverse.strands.queues.BasicSingleConsumerLongQueue

enq(E) - Method in class co.paralleluniverse.strands.queues.BoxQueue

enq(E) - Method in class co.paralleluniverse.strands.queues.CircularBuffer

enq(Double) - Method in class co.paralleluniverse.strands.queues.CircularDoubleBuffer

enq(double) - Method in class co.paralleluniverse.strands.queues.CircularDoubleBuffer

enq(Float) - Method in class co.paralleluniverse.strands.queues.CircularFloatBuffer

enq(float) - Method in class co.paralleluniverse.strands.queues.CircularFloatBuffer

enq(Integer) - Method in class co.paralleluniverse.strands.queues.CircularIntBuffer

enq(int) - Method in class co.paralleluniverse.strands.queues.CircularIntBuffer

enq(Long) - Method in class co.paralleluniverse.strands.queues.CircularLongBuffer

enq(long) - Method in class co.paralleluniverse.strands.queues.CircularLongBuffer

enq(E) - Method in class co.paralleluniverse.strands.queues.CircularObjectBuffer

enq(double) - Method in class co.paralleluniverse.strands.queues.SingleConsumerArrayDoubleQueue

enq(Double) - Method in class co.paralleluniverse.strands.queues.SingleConsumerArrayDoubleQueue

enq(float) - Method in class co.paralleluniverse.strands.queues.SingleConsumerArrayFloatQueue

enq(Float) - Method in class co.paralleluniverse.strands.queues.SingleConsumerArrayFloatQueue

enq(int) - Method in class co.paralleluniverse.strands.queues.SingleConsumerArrayIntQueue

enq(Integer) - Method in class co.paralleluniverse.strands.queues.SingleConsumerArrayIntQueue

enq(long) - Method in class co.paralleluniverse.strands.queues.SingleConsumerArrayLongQueue

enq(Long) - Method in class co.paralleluniverse.strands.queues.SingleConsumerArrayLongQueue

enq(E) - Method in class co.paralleluniverse.strands.queues.SingleConsumerArrayObjectQueue

enq(double) - Method in class co.paralleluniverse.strands.queues.SingleConsumerLinkedArrayDoubleQueue

enq(Double) - Method in class co.paralleluniverse.strands.queues.SingleConsumerLinkedArrayDoubleQueue

enq(float) - Method in class co.paralleluniverse.strands.queues.SingleConsumerLinkedArrayFloatQueue

enq(Float) - Method in class co.paralleluniverse.strands.queues.SingleConsumerLinkedArrayFloatQueue

enq(int) - Method in class co.paralleluniverse.strands.queues.SingleConsumerLinkedArrayIntQueue

enq(Integer) - Method in class co.paralleluniverse.strands.queues.SingleConsumerLinkedArrayIntQueue

enq(long) - Method in class co.paralleluniverse.strands.queues.SingleConsumerLinkedArrayLongQueue

enq(Long) - Method in class co.paralleluniverse.strands.queues.SingleConsumerLinkedArrayLongQueue

enq(E) - Method in class co.paralleluniverse.strands.queues.SingleConsumerLinkedArrayObjectQueue

enq(double) - Method in class co.paralleluniverse.strands.queues.SingleConsumerLinkedDoubleQueue

enq(Double) - Method in class co.paralleluniverse.strands.queues.SingleConsumerLinkedDoubleQueue

enq(float) - Method in class co.paralleluniverse.strands.queues.SingleConsumerLinkedFloatQueue

enq(Float) - Method in class co.paralleluniverse.strands.queues.SingleConsumerLinkedFloatQueue

enq(int) - Method in class co.paralleluniverse.strands.queues.SingleConsumerLinkedIntQueue

enq(Integer) - Method in class co.paralleluniverse.strands.queues.SingleConsumerLinkedIntQueue

enq(long) - Method in class co.paralleluniverse.strands.queues.SingleConsumerLinkedLongQueue

enq(Long) - Method in class co.paralleluniverse.strands.queues.SingleConsumerLinkedLongQueue

enq(E) - Method in class co.paralleluniverse.strands.queues.SingleConsumerLinkedObjectQueue

enq(E) - Method in class co.paralleluniverse.strands.queues.SingleConsumerQueue

equal(Object, Object) - Static method in class co.paralleluniverse.common.util.Objects

equals(MethodNode, MethodNode) - Static method in class co.paralleluniverse.common.reflection.ASMUtil

equals(ClassNode, ClassNode) - Static method in class co.paralleluniverse.common.reflection.ASMUtil

equals(CharSequence, CharSequence) - Static method in class co.paralleluniverse.common.util.CharSequences

equals(Object) - Method in interface co.paralleluniverse.common.util.DelegatingEquals

The equals method of a DelegatingEquals object, will usually be implemented thus:

equals(Object) - Method in class co.paralleluniverse.common.util.ExtendedStackTraceElement

equals(Object) - Method in class co.paralleluniverse.common.util.Pair

equals(Object) - Method in class co.paralleluniverse.common.util.Substring

equals(Object) - Method in class co.paralleluniverse.common.util.Tuple

equals(Object) - Method in class co.paralleluniverse.concurrent.util.ConcurrentSkipListSet

Compares the specified object with this set for equality.

equals(Object) - Method in class co.paralleluniverse.fibers.Fiber

equals(Object) - Method in class co.paralleluniverse.fibers.instrument.MethodDatabase.ClassEntry

equals(Object) - Method in class co.paralleluniverse.strands.channels.DelegatingReceivePort

equals(Object) - Method in class co.paralleluniverse.strands.channels.DelegatingSendPort

equals(Object) - Method in class co.paralleluniverse.strands.channels.Mix.State

equals(Object) - Method in class co.paralleluniverse.strands.channels.QueueChannel

equals(Object) - Method in class co.paralleluniverse.strands.channels.ThreadReceivePort

equals(Object) - Method in class co.paralleluniverse.strands.channels.ThreadSendPort

equals(Object) - Method in class co.paralleluniverse.strands.channels.TransferChannel

equals(Object, Object) - Static method in class co.paralleluniverse.strands.Strand

Tests whether two strands represent the same fiber or thread.

error(String, Throwable) - Method in interface co.paralleluniverse.fibers.instrument.Log

error(String, Throwable) - Method in class co.paralleluniverse.fibers.instrument.MethodDatabase

error(String, Throwable) - Method in class co.paralleluniverse.fibers.instrument.QuasarInstrumentor

evalAndUpdate(Predicate<Long>, Function<Long, Long>) - Method in class co.paralleluniverse.concurrent.util.EnhancedAtomicLong

Exceptions - Class in co.paralleluniverse.common.util

exec() - Method in class co.paralleluniverse.concurrent.forkjoin.ParkableForkJoinTask

exec1() - Method in class co.paralleluniverse.concurrent.forkjoin.ParkableForkJoinTask

execute(Runnable) - Method in class co.paralleluniverse.common.util.SameThreadExecutor

execute(Runnable) - Method in class co.paralleluniverse.common.util.SameThreadExecutorService

execute(Runnable) - Method in class co.paralleluniverse.concurrent.util.ScheduledSingleThreadExecutor

Executes command with zero required delay.

execute(Runnable) - Method in class co.paralleluniverse.fibers.FiberExecutorScheduler

execute() - Method in class co.paralleluniverse.fibers.instrument.InstrumentationTask

execute() - Method in class co.paralleluniverse.fibers.instrument.OldSuspendablesScanner

execute() - Method in class co.paralleluniverse.fibers.instrument.SuspendablesScanner

ExecutorServiceLatencyProbe - Class in co.paralleluniverse.common.monitoring

ExecutorServiceLatencyProbe(ExecutorService, int) - Constructor for class co.paralleluniverse.common.monitoring.ExecutorServiceLatencyProbe

exit() - Static method in class co.paralleluniverse.common.util.Debug

exit(int) - Static method in class co.paralleluniverse.common.util.Debug

exit(int, String) - Static method in class co.paralleluniverse.common.util.Debug

exit(Throwable, String) - Static method in class co.paralleluniverse.common.util.Debug

exit(Throwable) - Static method in class co.paralleluniverse.common.util.Debug

exit(int, Throwable, String) - Static method in class co.paralleluniverse.common.util.Debug

ExtendedForkJoinWorkerFactory - Class in co.paralleluniverse.concurrent.forkjoin

ExtendedForkJoinWorkerFactory(String) - Constructor for class co.paralleluniverse.concurrent.forkjoin.ExtendedForkJoinWorkerFactory

ExtendedForkJoinWorkerThread - Class in co.paralleluniverse.concurrent.forkjoin

ExtendedForkJoinWorkerThread(ForkJoinPool) - Constructor for class co.paralleluniverse.concurrent.forkjoin.ExtendedForkJoinWorkerThread

ExtendedStackTrace - Class in co.paralleluniverse.common.util

ExtendedStackTrace(Throwable) - Constructor for class co.paralleluniverse.common.util.ExtendedStackTrace

ExtendedStackTrace.BasicExtendedStackTraceElement - Class in co.paralleluniverse.common.util

ExtendedStackTraceElement - Class in co.paralleluniverse.common.util

ExtendedStackTraceElement(StackTraceElement) - Constructor for class co.paralleluniverse.common.util.ExtendedStackTraceElement

ExtendedStackTraceElement(StackTraceElement, Class<?>, Member, int) - Constructor for class co.paralleluniverse.common.util.ExtendedStackTraceElement

ExtendedStackTraceElement(Class<?>, Method, String, int, int) - Constructor for class co.paralleluniverse.common.util.ExtendedStackTraceElement

ExtendedStackTraceElement(String, String, String, int, Class<?>, Member, int) - Constructor for class co.paralleluniverse.common.util.ExtendedStackTraceElement

extendsOrImplements(String, MethodDatabase, String, String, String[]) - Static method in class co.paralleluniverse.fibers.instrument.SimpleSuspendableClassifier

ExternalizableKryoSerializer<T extends java.io.Externalizable> - Class in co.paralleluniverse.io.serialization.kryo

ExternalizableKryoSerializer() - Constructor for class co.paralleluniverse.io.serialization.kryo.ExternalizableKryoSerializer

ExtractSuperClass() - Constructor for class co.paralleluniverse.fibers.instrument.MethodDatabase.ExtractSuperClass

F

Fiber<V> - Class in co.paralleluniverse.fibers

A lightweight thread.

Fiber(String, FiberScheduler, int, SuspendableCallable<V>) - Constructor for class co.paralleluniverse.fibers.Fiber

Creates a new fiber from the given SuspendableCallable.

Fiber(String, int, SuspendableCallable<V>) - Constructor for class co.paralleluniverse.fibers.Fiber

Creates a new fiber from the given SuspendableCallable scheduled in the default fiber scheduler

Fiber(String, FiberScheduler, SuspendableCallable<V>) - Constructor for class co.paralleluniverse.fibers.Fiber

Creates a new Fiber from the given SuspendableCallable.

Fiber(FiberScheduler, SuspendableCallable<V>) - Constructor for class co.paralleluniverse.fibers.Fiber

Creates a new Fiber from the given SuspendableCallable.

Fiber(String, FiberScheduler, int, SuspendableRunnable) - Constructor for class co.paralleluniverse.fibers.Fiber

Creates a new Fiber from the given SuspendableRunnable.

Fiber(String, FiberScheduler, SuspendableRunnable) - Constructor for class co.paralleluniverse.fibers.Fiber

Creates a new Fiber from the given SuspendableRunnable.

Fiber(FiberScheduler, SuspendableRunnable) - Constructor for class co.paralleluniverse.fibers.Fiber

Creates a new Fiber from the given SuspendableRunnable.

Fiber(String, FiberScheduler, int) - Constructor for class co.paralleluniverse.fibers.Fiber

Creates a new Fiber subclassing the Fiber class and overriding the run method.

Fiber(String, FiberScheduler) - Constructor for class co.paralleluniverse.fibers.Fiber

Creates a new Fiber subclassing the Fiber class and overriding the run method.

Fiber(FiberScheduler) - Constructor for class co.paralleluniverse.fibers.Fiber

Creates a new Fiber subclassing the Fiber class and overriding the run method.

Fiber(String, SuspendableCallable<V>) - Constructor for class co.paralleluniverse.fibers.Fiber

Creates a new child Fiber from the given SuspendableCallable.

Fiber(SuspendableCallable<V>) - Constructor for class co.paralleluniverse.fibers.Fiber

Creates a new child Fiber from the given SuspendableCallable.

Fiber(String, int, SuspendableRunnable) - Constructor for class co.paralleluniverse.fibers.Fiber

Creates a new child Fiber from the given SuspendableRunnable.

Fiber(String, SuspendableRunnable) - Constructor for class co.paralleluniverse.fibers.Fiber

Creates a new child Fiber from the given SuspendableRunnable.

Fiber(SuspendableRunnable) - Constructor for class co.paralleluniverse.fibers.Fiber

Creates a new child Fiber from the given SuspendableRunnable.

Fiber(String, int) - Constructor for class co.paralleluniverse.fibers.Fiber

Creates a new child Fiber subclassing the Fiber class and overriding the run method.

Fiber(String) - Constructor for class co.paralleluniverse.fibers.Fiber

Creates a new child Fiber subclassing the Fiber class and overriding the run method.

Fiber() - Constructor for class co.paralleluniverse.fibers.Fiber

Creates a new child Fiber subclassing the Fiber class and overriding the run method.

Fiber(Fiber, SuspendableCallable<V>) - Constructor for class co.paralleluniverse.fibers.Fiber

Fiber(Fiber, SuspendableRunnable) - Constructor for class co.paralleluniverse.fibers.Fiber

Fiber(Fiber, FiberScheduler, SuspendableCallable<V>) - Constructor for class co.paralleluniverse.fibers.Fiber

Fiber(Fiber, FiberScheduler, SuspendableRunnable) - Constructor for class co.paralleluniverse.fibers.Fiber

FiberAsync<V,E extends java.lang.Throwable> - Class in co.paralleluniverse.fibers

A general helper class that transforms asynchronous requests to synchronous (fiber-blocking) calls.

FiberAsync() - Constructor for class co.paralleluniverse.fibers.FiberAsync

Same as `FiberAsync(false)`

FiberAsync(boolean) - Constructor for class co.paralleluniverse.fibers.FiberAsync

FiberControl - Class in co.paralleluniverse.fibers

FiberExecutorScheduler - Class in co.paralleluniverse.fibers

A fiber scheduler that uses a given Executor for scheduling.

FiberExecutorScheduler(String, Executor, MonitorType, boolean) - Constructor for class co.paralleluniverse.fibers.FiberExecutorScheduler

Creates a new fiber scheduler.

FiberExecutorScheduler(String, Executor) - Constructor for class co.paralleluniverse.fibers.FiberExecutorScheduler

Creates a new fiber scheduler with no monitor.

FiberFactory - Interface in co.paralleluniverse.fibers

Creates new fibers on demand.

FiberFileChannel - Class in co.paralleluniverse.fibers.io

A fiber-blocking version of FileChannel.

FiberForkJoinScheduler - Class in co.paralleluniverse.fibers

A ForkJoinPool based scheduler for fibers.

FiberForkJoinScheduler(String, int, Thread.UncaughtExceptionHandler, MonitorType, boolean) - Constructor for class co.paralleluniverse.fibers.FiberForkJoinScheduler

Creates a new fiber scheduler.

FiberForkJoinScheduler(String, int, MonitorType, boolean) - Constructor for class co.paralleluniverse.fibers.FiberForkJoinScheduler

Creates a new fiber scheduler using a default UncaughtExceptionHandler.

FiberForkJoinScheduler(String, int) - Constructor for class co.paralleluniverse.fibers.FiberForkJoinScheduler

Creates a new fiber scheduler using a default UncaughtExceptionHandler and no monitoring.

FiberInfo - Class in co.paralleluniverse.fibers

Current information about a fiber returned by FibersMXBean.

FiberInfo(long, String, Strand.State, Object, StackTraceElement[]) - Constructor for class co.paralleluniverse.fibers.FiberInfo

FiberInfo(long, String, Strand.State, String, StackTraceElement[]) - Constructor for class co.paralleluniverse.fibers.FiberInfo

fiberResumed() - Method in interface co.paralleluniverse.fibers.FibersMonitor

fiberResumed() - Method in class co.paralleluniverse.fibers.NoopFibersMonitor

FiberScheduler - Class in co.paralleluniverse.fibers

A thread-pool based scheduler for fibers.

FiberSchedulerTask - Interface in co.paralleluniverse.fibers

The Runnable tasks passed to a FiberExecutorScheduler's Executor implement this interface.

FiberServerSocketChannel - Class in co.paralleluniverse.fibers.io

A fiber-blocking version of ServerSocketChannel.

FiberServerSocketChannel() - Constructor for class co.paralleluniverse.fibers.io.FiberServerSocketChannel

FibersMonitor - Interface in co.paralleluniverse.fibers

FibersMXBean - Interface in co.paralleluniverse.fibers

An MXBean that monitors fibers scheduled by a single FiberScheduler.

FiberSocketChannel - Class in co.paralleluniverse.fibers.io

A fiber-blocking version of SocketChannel.

FiberSocketChannel() - Constructor for class co.paralleluniverse.fibers.io.FiberSocketChannel

fiberStarted(Fiber) - Method in interface co.paralleluniverse.fibers.FibersMonitor

fiberStarted(Fiber) - Method in class co.paralleluniverse.fibers.NoopFibersMonitor

fiberSuspended() - Method in interface co.paralleluniverse.fibers.FibersMonitor

fiberSuspended() - Method in class co.paralleluniverse.fibers.NoopFibersMonitor

fiberTerminated(Fiber) - Method in interface co.paralleluniverse.fibers.FibersMonitor

fiberTerminated(Fiber) - Method in class co.paralleluniverse.fibers.NoopFibersMonitor

FiberTimedScheduler - Class in co.paralleluniverse.fibers

FiberTimedScheduler(FiberScheduler, ThreadFactory, FibersMonitor) - Constructor for class co.paralleluniverse.fibers.FiberTimedScheduler

FiberTimedScheduler(FiberScheduler, FibersMonitor) - Constructor for class co.paralleluniverse.fibers.FiberTimedScheduler

FiberTimedScheduler(FiberScheduler) - Constructor for class co.paralleluniverse.fibers.FiberTimedScheduler

fiberTransform(FiberFactory, ReceivePort<S>, SendPort<T>, SuspendableAction2<? extends ReceivePort<? super S>, ? extends SendPort<? extends T>>) - Static method in class co.paralleluniverse.strands.channels.Channels

Spawns a fiber that transforms values read from the in channel and writes values to the out channel.

fiberTransform(ReceivePort<S>, SendPort<T>, SuspendableAction2<? extends ReceivePort<? super S>, ? extends SendPort<? extends T>>) - Static method in class co.paralleluniverse.strands.channels.Channels

Spawns a fiber that transforms values read from the in channel and writes values to the out channel.

fiberTransform(SuspendableAction2<? extends ReceivePort<? super T>, ? extends SendPort<? extends U>>, Channel<U>) - Method in class co.paralleluniverse.strands.channels.TransformingReceivePort

Spawns a fiber that transforms values read from this channel and writes values to the out channel.

fiberTransform(FiberFactory, SuspendableAction2<? extends ReceivePort<? super T>, ? extends SendPort<? extends U>>, Channel<U>) - Method in class co.paralleluniverse.strands.channels.TransformingReceivePort

Spawns a fiber that transforms values read from this channel and writes values to the out channel.

fiberTransform(SuspendableAction2<? extends ReceivePort<? super U>, ? extends SendPort<? extends T>>, Channel<U>) - Method in class co.paralleluniverse.strands.channels.TransformingSendPort

Spawns a fiber that transforms values read from the in channel and writes values to this channel.

fiberTransform(FiberFactory, SuspendableAction2<? extends ReceivePort<? super U>, ? extends SendPort<? extends T>>, Channel<U>) - Method in class co.paralleluniverse.strands.channels.TransformingSendPort

Spawns a fiber that transforms values read from the in channel and writes values to this channel.

FiberUtil - Class in co.paralleluniverse.fibers

Static utility methods for working with fibers.

FiberWriter - Interface in co.paralleluniverse.fibers

A callback used by Fiber.parkAndSerialize..

FIELD_NAME_METHOD_END - Static variable in annotation type co.paralleluniverse.fibers.Instrumented

FIELD_NAME_METHOD_OPTIMIZED - Static variable in annotation type co.paralleluniverse.fibers.Instrumented

FIELD_NAME_METHOD_START - Static variable in annotation type co.paralleluniverse.fibers.Instrumented

FIELD_NAME_SUSPENDABLE_CALL_SITE_NAMES - Static variable in annotation type co.paralleluniverse.fibers.Instrumented

FIELD_NAME_SUSPENDABLE_CALL_SITES - Static variable in annotation type co.paralleluniverse.fibers.Instrumented

FIELD_NAME_SUSPENDABLE_CALL_SITES_OFFSETS_AFTER_INSTR - Static variable in annotation type co.paralleluniverse.fibers.Instrumented

file - Variable in class co.paralleluniverse.fibers.instrument.InstrumentationTask.WorkListEntry

fillInStackTrace() - Method in error co.paralleluniverse.concurrent.forkjoin.ParkableForkJoinTask.Park

fillInStackTrace() - Method in exception co.paralleluniverse.fibers.RuntimeSuspendExecution

fillInStackTrace() - Method in exception co.paralleluniverse.fibers.SuspendExecution

fillInStackTrace() - Method in exception co.paralleluniverse.strands.channels.ReceivePort.EOFException

filter(StackTraceElement) - Method in interface co.paralleluniverse.common.util.Debug.StackTraceFilter

filter(ReceivePort<M>, Predicate<M>) - Static method in class co.paralleluniverse.strands.channels.Channels

Returns a ReceivePort that filters messages that satisfy a predicate from a given channel.

filter(Predicate<T>) - Method in class co.paralleluniverse.strands.channels.TransformingReceivePort

Returns a TransformingReceivePort that filters messages that satisfy a predicate from this given channel.

filter(Predicate<T>) - Method in class co.paralleluniverse.strands.channels.TransformingSendPort

Returns a TransformingSendPort that filters messages that satisfy a predicate before sending to this channel.

filterSend(SendPort<M>, Predicate<M>) - Static method in class co.paralleluniverse.strands.channels.Channels

Returns a SendPort that filters messages that satisfy a predicate before sending to a given channel.

finalize() - Method in class co.paralleluniverse.fibers.FiberTimedScheduler

FindAnnotatedMethods - Class in co.paralleluniverse.fibers.instrument

FindAnnotatedMethods(int, Class<Annotation>) - Constructor for class co.paralleluniverse.fibers.instrument.FindAnnotatedMethods

findClass(String) - Method in class co.paralleluniverse.fibers.instrument.QuasarURLClassLoader

findClass(String) - Method in class co.paralleluniverse.fibers.instrument.QuasarURLClassLoaderHelper

fire() - Method in class co.paralleluniverse.common.monitoring.ExecutorServiceLatencyProbe

first() - Method in class co.paralleluniverse.concurrent.util.ConcurrentSkipListSet

fjPool() - Method in class co.paralleluniverse.common.monitoring.ForkJoinPoolMonitor

fjPool() - Method in class co.paralleluniverse.common.monitoring.JMXForkJoinPoolMonitor

fjPool() - Method in class co.paralleluniverse.common.monitoring.MetricsForkJoinPoolMonitor

flatMap(ReceivePort<S>, Function<S, ReceivePort<T>>) - Static method in class co.paralleluniverse.strands.channels.Channels

Returns a ReceivePort that receives messages that are transformed by a given flat-mapping function from a given channel.

flatMap(Function<T, ReceivePort<U>>) - Method in class co.paralleluniverse.strands.channels.TransformingReceivePort

Returns a TransformingReceivePort that receives messages that are transformed by a given flat-mapping function from this channel.

flatMap(Channel<S>, Function<S, ReceivePort<T>>) - Method in class co.paralleluniverse.strands.channels.TransformingSendPort

Returns a SendPort that sends messages that are transformed by a given flat-mapping function into this channel.

FlatMappingReceivePort<S,T> - Class in co.paralleluniverse.strands.channels

FlatMappingReceivePort(ReceivePort<S>, Function<S, ReceivePort<T>>) - Constructor for class co.paralleluniverse.strands.channels.FlatMappingReceivePort

FlatMappingReceivePort(ReceivePort<S>) - Constructor for class co.paralleluniverse.strands.channels.FlatMappingReceivePort

flatMapSend(FiberFactory, Channel<S>, SendPort<T>, Function<S, ReceivePort<T>>) - Static method in class co.paralleluniverse.strands.channels.Channels

Returns a SendPort that sends messages that are transformed by a given flat-mapping function into a given channel.

flatMapSend(Channel<S>, SendPort<T>, Function<S, ReceivePort<T>>) - Static method in class co.paralleluniverse.strands.channels.Channels

FlightRecorder - Class in co.paralleluniverse.common.monitoring

FlightRecorder(String) - Constructor for class co.paralleluniverse.common.monitoring.FlightRecorder

flightRecorder - Static variable in class co.paralleluniverse.fibers.Fiber

FlightRecorder.Record - Class in co.paralleluniverse.common.monitoring

FlightRecorder.ThreadRecorder - Class in co.paralleluniverse.common.monitoring

FlightRecorderMessage - Class in co.paralleluniverse.common.monitoring

FlightRecorderMessage(String, String, String, Object[]) - Constructor for class co.paralleluniverse.common.monitoring.FlightRecorderMessage

FlightRecorderMessageFactory - Interface in co.paralleluniverse.common.monitoring

FlightRecorderMXBean - Interface in co.paralleluniverse.common.monitoring

FloatChannel - Interface in co.paralleluniverse.strands.channels

A channel for primitive float messages.

FloatConsumer() - Constructor for class co.paralleluniverse.strands.queues.CircularFloatBuffer.FloatConsumer

floatNext() - Method in interface co.paralleluniverse.strands.queues.FloatQueueIterator

FloatQueueIterator - Interface in co.paralleluniverse.strands.queues

FloatReceivePort - Interface in co.paralleluniverse.strands.channels

A primitive float channel's consumer-side interface.

FloatSendPort - Interface in co.paralleluniverse.strands.channels

A primitive float channel's producer-side interface.

floatValue() - Method in interface co.paralleluniverse.strands.queues.FloatQueueIterator

floor(E) - Method in class co.paralleluniverse.concurrent.util.ConcurrentSkipListSet

foo() - Method in class co.paralleluniverse.fibers.instrument.InstrumentationTKB

force(boolean) - Method in class co.paralleluniverse.fibers.io.FiberFileChannel

forceTermination() - Method in class co.paralleluniverse.strands.concurrent.Phaser

Forces this phaser to enter termination state.

forEach(ReceivePort<T>, SuspendableAction1<T>) - Static method in class co.paralleluniverse.strands.channels.Channels

Performs the given action on each message received by the given channel.

forEach(SuspendableAction1<T>) - Method in class co.paralleluniverse.strands.channels.TransformingReceivePort

Performs the given action on each message received by this channel.

fork1() - Method in class co.paralleluniverse.concurrent.forkjoin.ParkableForkJoinTask

ForkJoinInfo - Class in co.paralleluniverse.common.monitoring

ForkJoinInfo(int, int, int, long, long) - Constructor for class co.paralleluniverse.common.monitoring.ForkJoinInfo

ForkJoinPoolMonitor - Class in co.paralleluniverse.common.monitoring

ForkJoinPoolMonitor(String, ForkJoinPool) - Constructor for class co.paralleluniverse.common.monitoring.ForkJoinPoolMonitor

ForkJoinPoolMonitor.Status - Enum in co.paralleluniverse.common.monitoring

ForkJoinPoolMXBean - Interface in co.paralleluniverse.common.monitoring

ForkJoinUtil - Class in co.paralleluniverse.concurrent.forkjoin

format(LogRecord) - Method in class co.paralleluniverse.common.logging.SimpleFormatter

from(ThreadFactory) - Static method in class co.paralleluniverse.strands.StrandFactoryBuilder

Converts a ThreadFactory into a StrandFactory.

from(FiberFactory) - Static method in class co.paralleluniverse.strands.StrandFactoryBuilder

Converts a FiberFactory into a StrandFactory.

Function2<S1,S2,T> - Interface in co.paralleluniverse.common.util

Function3<S1,S2,S3,T> - Interface in co.paralleluniverse.common.util

Function4<S1,S2,S3,S4,T> - Interface in co.paralleluniverse.common.util

Function5<S1,S2,S3,S4,S5,T> - Interface in co.paralleluniverse.common.util

G

GenericRecordingDouble - Class in co.paralleluniverse.common.monitoring

GenericRecordingDouble(Class, int) - Constructor for class co.paralleluniverse.common.monitoring.GenericRecordingDouble

GenericRecordingDouble(String, int) - Constructor for class co.paralleluniverse.common.monitoring.GenericRecordingDouble

GenericRecordingDouble(Object, String) - Constructor for class co.paralleluniverse.common.monitoring.GenericRecordingDouble

GenericRecordingDouble(Object) - Constructor for class co.paralleluniverse.common.monitoring.GenericRecordingDouble

get() - Method in class co.paralleluniverse.common.benchmark.Striped

get() - Method in class co.paralleluniverse.common.monitoring.Counter

get() - Method in class co.paralleluniverse.common.monitoring.FlightRecorder

get() - Method in class co.paralleluniverse.common.util.ExtendedStackTrace

get(int) - Method in class co.paralleluniverse.common.util.Pair

get(int) - Method in class co.paralleluniverse.common.util.Tuple

get() - Method in class co.paralleluniverse.fibers.Fiber

get(long, TimeUnit) - Method in class co.paralleluniverse.fibers.Fiber

get(List<Fiber<V>>) - Static method in class co.paralleluniverse.fibers.FiberUtil

Blocks on the input fibers and creates a new list from the results.

get(Fiber<V>...) - Static method in class co.paralleluniverse.fibers.FiberUtil

Blocks on the input fibers and creates a new list from the results.

get(long, TimeUnit, List<Fiber<V>>) - Static method in class co.paralleluniverse.fibers.FiberUtil

Blocks on the input fibers and creates a new list from the results.

get(long, TimeUnit, Fiber<V>...) - Static method in class co.paralleluniverse.fibers.FiberUtil

Blocks on the input fibers and creates a new list from the results.

get(CompletionStage<V>) - Static method in class co.paralleluniverse.fibers.futures.AsyncCompletionStage

Blocks the current strand (either fiber or thread) until the given future completes, and returns its result.

get(CompletionStage<V>, long, TimeUnit) - Static method in class co.paralleluniverse.fibers.futures.AsyncCompletionStage

Blocks the current strand (either fiber or thread) until the given future completes - but no longer than the given timeout - and returns its result.

get(CompletionStage<V>, Timeout) - Static method in class co.paralleluniverse.fibers.futures.AsyncCompletionStage

Blocks the current strand (either fiber or thread) until the given future completes - but no longer than the given timeout - and returns its result.

get(ListenableFuture<V>) - Static method in class co.paralleluniverse.fibers.futures.AsyncListenableFuture

Blocks the current strand (either fiber or thread) until the given future completes, and returns its result.

get(ListenableFuture<V>, long, TimeUnit) - Static method in class co.paralleluniverse.fibers.futures.AsyncListenableFuture

Blocks the current strand (either fiber or thread) until the given future completes - but no longer than the given timeout - and returns its result.

get(ListenableFuture<V>, Timeout) - Static method in class co.paralleluniverse.fibers.futures.AsyncListenableFuture

Blocks the current strand (either fiber or thread) until the given future completes - but no longer than the given timeout - and returns its result.

get() - Method in interface co.paralleluniverse.fibers.Joinable

get(long, TimeUnit) - Method in interface co.paralleluniverse.fibers.Joinable

get() - Method in class co.paralleluniverse.fibers.SchedulerLocal

Returns the scheduler-local value of this SchedulerLocal.

get() - Method in class co.paralleluniverse.fibers.TrueThreadLocal

get() - Method in class co.paralleluniverse.strands.AbstractFuture

get(long, TimeUnit) - Method in class co.paralleluniverse.strands.AbstractFuture

get() - Method in class co.paralleluniverse.strands.dataflow.Val

Returns the delayed value, blocking until it has been set.

get(long, TimeUnit) - Method in class co.paralleluniverse.strands.dataflow.Val

Returns the delayed value, blocking until it has been set, but no longer than the given timeout.

get(Timeout) - Method in class co.paralleluniverse.strands.dataflow.Val

get() - Method in class co.paralleluniverse.strands.dataflow.Var

Returns the Var's current value (more precisely: it returns the oldest value in the maintained history that has not yet been returned), unless this Var does not yet have a value; only in that case will this method block.

get() - Method in class co.paralleluniverse.strands.Strand

get(long, TimeUnit) - Method in class co.paralleluniverse.strands.Strand

getActiveCount() - Method in class co.paralleluniverse.concurrent.util.ScheduledSingleThreadExecutor

Returns the approximate number of threads that are actively executing tasks.

getActiveThreadCount() - Method in class co.paralleluniverse.common.monitoring.ForkJoinInfo

getActiveThreadCount() - Method in interface co.paralleluniverse.common.monitoring.ForkJoinPoolMXBean

getActiveThreadCount() - Method in class co.paralleluniverse.common.monitoring.JMXForkJoinPoolMonitor

getAllFiberIds() - Method in interface co.paralleluniverse.fibers.FibersMXBean

The IDs of all fibers in the scheduler.

getAndClearReadValue() - Method in class co.paralleluniverse.strands.queues.CircularBuffer.Consumer

getAndReset() - Method in class co.paralleluniverse.common.monitoring.Counter

getArrivedParties() - Method in class co.paralleluniverse.strands.concurrent.Phaser

Returns the number of registered parties that have arrived at the current phase of this phaser.

getAsyncMode() - Method in interface co.paralleluniverse.common.monitoring.ForkJoinPoolMXBean

getAsyncMode() - Method in class co.paralleluniverse.common.monitoring.JMXForkJoinPoolMonitor

getAux() - Method in class co.paralleluniverse.common.monitoring.FlightRecorder.ThreadRecorder

getBlocker() - Method in class co.paralleluniverse.concurrent.forkjoin.ParkableForkJoinTask

getBlocker() - Method in class co.paralleluniverse.fibers.Fiber

getBlocker() - Method in class co.paralleluniverse.fibers.FiberInfo

The fiber's current blocker.

getBlocker() - Method in class co.paralleluniverse.strands.Strand

Returns the blocker object supplied to the most recent invocation of a park method that has not yet unblocked, or null if not blocked.

getBytecodeIndex() - Method in class co.paralleluniverse.common.util.ExtendedStackTraceElement

getCallsiteDesc(String) - Static method in class co.paralleluniverse.fibers.instrument.SuspendableHelper

getCallsiteName(String) - Static method in class co.paralleluniverse.fibers.instrument.SuspendableHelper

getCallsiteOwner(String) - Static method in class co.paralleluniverse.fibers.instrument.SuspendableHelper

getClass(String, ClassLoader) - Static method in class co.paralleluniverse.common.reflection.ASMUtil

getClass(Class<?>) - Static method in class co.paralleluniverse.common.reflection.ASMUtil

getClass(Type) - Static method in class co.paralleluniverse.common.reflection.ReflectionUtil

getClassEntry(String) - Method in class co.paralleluniverse.fibers.instrument.MethodDatabase

getClassifier() - Method in class co.paralleluniverse.fibers.instrument.MethodDatabase

getClassInputStream(String, ClassLoader) - Static method in class co.paralleluniverse.common.reflection.ASMUtil

getClassInputStream(Class<?>) - Static method in class co.paralleluniverse.common.reflection.ASMUtil

getClassLoaderInfo(ClassLoader) - Static method in class co.paralleluniverse.common.util.Debug

getClassName() - Method in class co.paralleluniverse.common.util.ExtendedStackTraceElement

Returns the fully qualified name of the class containing the execution point represented by this stack trace element.

getClassName() - Method in exception co.paralleluniverse.fibers.instrument.UnableToInstrumentException

getClassNode(InputStream, boolean) - Static method in class co.paralleluniverse.common.reflection.ASMUtil

getClassNode(String, ClassLoader, boolean) - Static method in class co.paralleluniverse.common.reflection.ASMUtil

getClassNode(Class<?>, boolean) - Static method in class co.paralleluniverse.common.reflection.ASMUtil

getClazz() - Method in class co.paralleluniverse.common.monitoring.FlightRecorderMessage

getCloseException() - Method in class co.paralleluniverse.strands.channels.QueueChannel

getCommonSuperClass(String, String) - Method in class co.paralleluniverse.fibers.instrument.MethodDatabase

getContextClassLoader(Thread) - Static method in class co.paralleluniverse.concurrent.util.ThreadAccess

getContinueExistingPeriodicTasksAfterShutdownPolicy() - Method in class co.paralleluniverse.concurrent.util.ScheduledSingleThreadExecutor

Gets the policy on whether to continue executing existing periodic tasks even when this executor has been shutdown.

getCount() - Method in class co.paralleluniverse.strands.concurrent.CountDownLatch

Returns the current count.

getCurrent() - Static method in class co.paralleluniverse.concurrent.forkjoin.ParkableForkJoinTask

getCurrentPid() - Static method in class co.paralleluniverse.common.util.ProcessUtil

getCurrentRun() - Static method in class co.paralleluniverse.fibers.Fiber

getDeclaringClass() - Method in class co.paralleluniverse.common.util.ExtendedStackTrace.BasicExtendedStackTraceElement

getDeclaringClass() - Method in class co.paralleluniverse.common.util.ExtendedStackTraceElement

getDefaultUncaughtExceptionHandler() - Static method in class co.paralleluniverse.fibers.Fiber

Returns the default handler invoked when a fiber abruptly terminates due to an uncaught exception.

getDescriptor(Member) - Static method in class co.paralleluniverse.common.reflection.ASMUtil

getDescriptor(Member) - Static method in class co.paralleluniverse.common.util.ExtendedStackTrace

getDirectSuperClass(String) - Method in class co.paralleluniverse.fibers.instrument.MethodDatabase

getDouble(int) - Method in class co.paralleluniverse.fibers.Stack

getDoubleValue() - Method in class co.paralleluniverse.strands.queues.CircularDoubleBuffer.DoubleConsumer

getDumpFile() - Static method in class co.paralleluniverse.common.util.Debug

getExclusiveOwnerStrand() - Method in class co.paralleluniverse.strands.concurrent.AbstractOwnableSynchronizer

Returns the strand last set by setExclusiveOwnerStrand, or null if never set.

getExclusiveQueuedStrands() - Method in class co.paralleluniverse.strands.concurrent.AbstractQueuedLongSynchronizer

Returns a collection containing strands that may be waiting to acquire in exclusive mode.

getExclusiveQueuedStrands() - Method in class co.paralleluniverse.strands.concurrent.AbstractQueuedSynchronizer

Returns a collection containing strands that may be waiting to acquire in exclusive mode.

getExecuteExistingDelayedTasksAfterShutdownPolicy() - Method in class co.paralleluniverse.concurrent.util.ScheduledSingleThreadExecutor

Gets the policy on whether to execute existing delayed tasks even when this executor has been shutdown.

getExecutor() - Static method in class co.paralleluniverse.common.util.SameThreadExecutor

getExecutor() - Method in class co.paralleluniverse.fibers.FiberExecutorScheduler

getExecutor() - Method in class co.paralleluniverse.fibers.FiberForkJoinScheduler

getExecutor() - Method in class co.paralleluniverse.fibers.FiberScheduler

getExecutorService() - Static method in class co.paralleluniverse.common.util.SameThreadExecutorService

getFiber() - Method in interface co.paralleluniverse.fibers.FiberSchedulerTask

getFiberInfo(long, boolean) - Method in interface co.paralleluniverse.fibers.FibersMXBean

Returns a FiberInfo object for a single fiber.

getFiberInfo(long[], boolean) - Method in interface co.paralleluniverse.fibers.FibersMXBean

Returns an array FiberInfo objects for a set of fibers.

getFiberSerializer() - Static method in class co.paralleluniverse.fibers.Fiber

Returns a ByteArraySerializer capable of serializing an object graph containing fibers.

getFiberSerializer(boolean) - Static method in class co.paralleluniverse.fibers.Fiber

Returns a ByteArraySerializer capable of serializing an object graph containing fibers.

getFileName() - Method in class co.paralleluniverse.common.util.ExtendedStackTraceElement

Returns the name of the source file containing the execution point represented by this stack trace element.

getFirst() - Method in class co.paralleluniverse.common.util.Pair

getFirstQueuedStrand() - Method in class co.paralleluniverse.strands.concurrent.AbstractQueuedLongSynchronizer

Returns the first (longest-waiting) strand in the queue, or null if no strands are currently queued.

getFirstQueuedStrand() - Method in class co.paralleluniverse.strands.concurrent.AbstractQueuedSynchronizer

Returns the first (longest-waiting) strand in the queue, or null if no strands are currently queued.

getFloat(int) - Method in class co.paralleluniverse.fibers.Stack

getFloatValue() - Method in class co.paralleluniverse.strands.queues.CircularFloatBuffer.FloatConsumer

getForkJoinPool() - Method in class co.paralleluniverse.fibers.FiberForkJoinScheduler

getGenericParameterType(Class<?>, Class<?>, int) - Static method in class co.paralleluniverse.common.reflection.ReflectionUtil

getGlobalFlightRecorder() - Static method in class co.paralleluniverse.common.util.Debug

getHighestTrackableValue() - Method in class co.paralleluniverse.common.benchmark.StripedHistogram

get the configured highestTrackableValue

getHistogramDataCorrectedForCoordinatedOmission(long) - Method in class co.paralleluniverse.common.benchmark.StripedHistogram

Provide access to the histogram's data set, corrected for coordinated omission.

getHoldCount() - Method in class co.paralleluniverse.strands.concurrent.ReentrantLock

Queries the number of holds on this lock by the current strand.

getHoldCount() - Method in class co.paralleluniverse.strands.concurrent.ReentrantReadWriteLock.WriteLock

Queries the number of holds on this write lock by the current strand.

getId() - Method in class co.paralleluniverse.fibers.Fiber

getId() - Method in class co.paralleluniverse.fibers.FiberInfo

The fiber's ID.

getId() - Method in class co.paralleluniverse.strands.Strand

Returns the strand's id.

getInfo() - Method in interface co.paralleluniverse.common.monitoring.ForkJoinPoolMXBean

getInfo() - Method in class co.paralleluniverse.common.monitoring.JMXForkJoinPoolMonitor

getInheritableThreadLocals(Thread) - Static method in class co.paralleluniverse.concurrent.util.ThreadAccess

getInheritableThreadLocalsString() - Static method in class co.paralleluniverse.concurrent.util.ThreadUtil

getInheritedAccessControlContext(Thread) - Static method in class co.paralleluniverse.concurrent.util.ThreadAccess

getInnerClassesEntries(String) - Method in class co.paralleluniverse.fibers.instrument.MethodDatabase

getInstance() - Static method in class co.paralleluniverse.common.monitoring.MonitoringServices

getInstance() - Static method in class co.paralleluniverse.fibers.DefaultFiberScheduler

Returns the The default FiberScheduler instance.

getInstance() - Static method in class co.paralleluniverse.io.serialization.Serialization

getInstrumentor() - Static method in class co.paralleluniverse.fibers.instrument.Retransform

getInt(int) - Method in class co.paralleluniverse.fibers.Stack

getInterfaces() - Method in class co.paralleluniverse.fibers.instrument.MethodDatabase.ClassEntry

getInterruptStack() - Method in class co.paralleluniverse.fibers.Fiber

getInterruptStack() - Method in class co.paralleluniverse.strands.Strand

Returns an InterruptedException that was created when the Strand.interrupt() method was called, and can be used to retrieve the stack trace of the strand that interrupted this strand.

getIntValue() - Method in class co.paralleluniverse.strands.queues.CircularIntBuffer.IntConsumer

getJarOfClass(String) - Static method in class co.paralleluniverse.common.util.Debug

getJarOfClass(Class<?>) - Static method in class co.paralleluniverse.common.util.Debug

getKryo() - Method in class co.paralleluniverse.io.serialization.kryo.KryoSerializer

getKryo() - Static method in class co.paralleluniverse.io.serialization.Serialization

getLastIndexRead() - Method in class co.paralleluniverse.strands.channels.TickerChannelConsumer

getLatency() - Method in interface co.paralleluniverse.common.monitoring.ForkJoinPoolMXBean

getLatency() - Method in class co.paralleluniverse.common.monitoring.JMXForkJoinPoolMonitor

getLineNumber() - Method in class co.paralleluniverse.common.util.ExtendedStackTraceElement

Returns the line number of the source line containing the execution point represented by this stack trace element.

getLocalAddress() - Method in class co.paralleluniverse.fibers.io.FiberServerSocketChannel

getLocalAddress() - Method in class co.paralleluniverse.fibers.io.FiberSocketChannel

getLog() - Method in class co.paralleluniverse.fibers.instrument.MethodDatabase

getLog() - Method in class co.paralleluniverse.fibers.instrument.QuasarInstrumentor

getLong(int) - Method in class co.paralleluniverse.fibers.Stack

getLongValue() - Method in class co.paralleluniverse.strands.queues.CircularLongBuffer.LongConsumer

getMatchingConstructor(Class<T>, Class<?>...) - Static method in class co.paralleluniverse.common.reflection.ReflectionUtil

getMbeanName() - Method in class co.paralleluniverse.common.monitoring.JMXForkJoinPoolMonitor

getMeanTimedWakeupLatency() - Method in interface co.paralleluniverse.fibers.FibersMXBean

The average latency between the time fibers in the scheduler have asked to be awakened (by a sleep or any other timed wait) and the time they've actually been awakened in the last 5 seconds.

getMethod() - Method in class co.paralleluniverse.common.monitoring.FlightRecorderMessage

getMethod(MethodNode, List<MethodNode>) - Static method in class co.paralleluniverse.common.reflection.ASMUtil

getMethod(MethodNode, ClassNode) - Static method in class co.paralleluniverse.common.reflection.ASMUtil

getMethod() - Method in class co.paralleluniverse.common.util.ExtendedStackTrace.BasicExtendedStackTraceElement

getMethod(ExtendedStackTraceElement) - Method in class co.paralleluniverse.common.util.ExtendedStackTrace

getMethod() - Method in class co.paralleluniverse.common.util.ExtendedStackTraceElement

getMethodDatabase(ClassLoader) - Method in class co.paralleluniverse.fibers.instrument.QuasarInstrumentor

getMethodDB(ClassLoader) - Static method in class co.paralleluniverse.fibers.instrument.Retransform

getMethodDesc() - Method in exception co.paralleluniverse.fibers.instrument.UnableToInstrumentException

getMethodName() - Method in class co.paralleluniverse.common.util.ExtendedStackTraceElement

Returns the name of the method containing the execution point represented by this stack trace element.

getMethodName() - Method in exception co.paralleluniverse.fibers.instrument.UnableToInstrumentException

getMethods(Class<?>) - Method in class co.paralleluniverse.common.util.ExtendedStackTrace

getMetrics() - Method in class co.paralleluniverse.common.monitoring.CpuUsageGaugeSet

getMode() - Method in class co.paralleluniverse.strands.channels.Mix.State

getMonitor() - Method in class co.paralleluniverse.concurrent.forkjoin.MonitoredForkJoinPool

getMonitor() - Method in class co.paralleluniverse.fibers.Fiber

getMonitor() - Method in class co.paralleluniverse.fibers.FiberScheduler

getName(Member) - Static method in class co.paralleluniverse.common.util.ExtendedStackTrace

getName() - Method in class co.paralleluniverse.concurrent.forkjoin.MonitoredForkJoinPool

getName() - Method in class co.paralleluniverse.fibers.Fiber

getName() - Method in class co.paralleluniverse.fibers.FiberInfo

The fiber's name.

getName() - Method in class co.paralleluniverse.fibers.FiberScheduler

getName() - Method in class co.paralleluniverse.fibers.instrument.CheckInstrumentationVisitor

getName() - Method in class co.paralleluniverse.strands.Strand

Returns the strand's name.

getNext() - Method in class co.paralleluniverse.strands.dataflow.Var

Blocks until a new value has been set and returns it.

getNoLocals() - Method in class co.paralleluniverse.fibers.Fiber

Deprecated.

getNumActiveFibers() - Method in interface co.paralleluniverse.fibers.FibersMXBean

The number of non-terminated fibers in the scheduler.

getNumberOfSignificantValueDigits() - Method in class co.paralleluniverse.common.benchmark.StripedHistogram

get the configured numberOfSignificantValueDigits

getNumberWaiting() - Method in class co.paralleluniverse.strands.concurrent.CyclicBarrier

Returns the number of parties currently waiting at the barrier.

getNumRunnableFibers() - Method in interface co.paralleluniverse.fibers.FibersMXBean

The number of fibers currently in the RUNNING state.

getNumWaitingFibers() - Method in interface co.paralleluniverse.fibers.FibersMXBean

The number of fibers that are currently blocking.

getObject(int) - Method in class co.paralleluniverse.fibers.Stack

getOption(SocketOption<T>) - Method in class co.paralleluniverse.fibers.io.FiberServerSocketChannel

getOption(SocketOption<T>) - Method in class co.paralleluniverse.fibers.io.FiberSocketChannel

getOrCreateClassEntry(String, String) - Method in class co.paralleluniverse.fibers.instrument.MethodDatabase

getOrLoadClassEntry(String) - Method in class co.paralleluniverse.fibers.instrument.MethodDatabase

getOverflowPolicy() - Method in class co.paralleluniverse.strands.channels.QueueChannel

getOwner() - Method in class co.paralleluniverse.strands.channels.SingleConsumerQueueChannel

getOwner() - Method in class co.paralleluniverse.strands.concurrent.ReentrantLock

Returns the strand that currently owns this lock, or null if not owned.

getOwner() - Method in class co.paralleluniverse.strands.concurrent.ReentrantReadWriteLock

Returns the strand that currently owns the write lock, or null if not owned.

getPackageVersion(String) - Static method in class co.paralleluniverse.common.util.Debug

getParallelism() - Method in interface co.paralleluniverse.common.monitoring.ForkJoinPoolMXBean

getParallelism() - Method in class co.paralleluniverse.common.monitoring.JMXForkJoinPoolMonitor

getParameterTypes(Member) - Static method in class co.paralleluniverse.common.reflection.ReflectionUtil

getParent() - Method in class co.paralleluniverse.strands.concurrent.Phaser

Returns the parent of this phaser, or null if none.

getParties() - Method in class co.paralleluniverse.strands.concurrent.CyclicBarrier

Returns the number of parties required to trip this barrier.

getPerformanceTimerPeriod() - Method in class co.paralleluniverse.common.monitoring.MonitoringServices

getPerformanceTimerPeriod() - Method in interface co.paralleluniverse.common.monitoring.MonitoringServicesMXBean

getPhase() - Method in class co.paralleluniverse.strands.concurrent.Phaser

Returns the current phase number.

getPool() - Static method in class co.paralleluniverse.concurrent.forkjoin.ForkJoinUtil

getPoolSize() - Method in interface co.paralleluniverse.common.monitoring.ForkJoinPoolMXBean

getPoolSize() - Method in class co.paralleluniverse.common.monitoring.JMXForkJoinPoolMonitor

getPoolSize() - Method in class co.paralleluniverse.concurrent.util.ScheduledSingleThreadExecutor

Returns the current number of threads in the pool.

getPriority() - Method in class co.paralleluniverse.fibers.Fiber

Returns this fiber's priority.

getPriority() - Method in class co.paralleluniverse.strands.Strand

Returns this strand's priority.

getQueuedReaderStrands() - Method in class co.paralleluniverse.strands.concurrent.ReentrantReadWriteLock

Returns a collection containing strands that may be waiting to acquire the read lock.

getQueuedStrands() - Method in class co.paralleluniverse.strands.concurrent.AbstractQueuedLongSynchronizer

Returns a collection containing strands that may be waiting to acquire.

getQueuedStrands() - Method in class co.paralleluniverse.strands.concurrent.AbstractQueuedSynchronizer

Returns a collection containing strands that may be waiting to acquire.

getQueuedStrands() - Method in class co.paralleluniverse.strands.concurrent.ReentrantLock

Returns a collection containing strands that may be waiting to acquire this lock.

getQueuedStrands() - Method in class co.paralleluniverse.strands.concurrent.ReentrantReadWriteLock

Returns a collection containing strands that may be waiting to acquire either the read or write lock.

getQueuedStrands() - Method in class co.paralleluniverse.strands.concurrent.Semaphore

Returns a collection containing threads that may be waiting to acquire.

getQueuedSubmissionCount() - Method in interface co.paralleluniverse.common.monitoring.ForkJoinPoolMXBean

getQueuedSubmissionCount() - Method in class co.paralleluniverse.common.monitoring.JMXForkJoinPoolMonitor

getQueuedSumbmissionCount() - Method in class co.paralleluniverse.common.monitoring.ForkJoinInfo

getQueuedTaskCount() - Method in class co.paralleluniverse.common.monitoring.ForkJoinInfo

getQueuedTaskCount() - Method in interface co.paralleluniverse.common.monitoring.ForkJoinPoolMXBean

getQueuedTaskCount() - Method in class co.paralleluniverse.common.monitoring.JMXForkJoinPoolMonitor

getQueuedWriterStrands() - Method in class co.paralleluniverse.strands.concurrent.ReentrantReadWriteLock

Returns a collection containing strands that may be waiting to acquire the write lock.

getQueueLength() - Method in class co.paralleluniverse.fibers.FiberExecutorScheduler

getQueueLength() - Method in class co.paralleluniverse.fibers.FiberForkJoinScheduler

getQueueLength() - Method in class co.paralleluniverse.fibers.FiberScheduler

getQueueLength() - Method in class co.paralleluniverse.fibers.FiberTimedScheduler

getQueueLength() - Method in class co.paralleluniverse.strands.channels.QueueChannel

getQueueLength() - Method in class co.paralleluniverse.strands.concurrent.AbstractQueuedLongSynchronizer

Returns an estimate of the number of strands waiting to acquire.

getQueueLength() - Method in class co.paralleluniverse.strands.concurrent.AbstractQueuedSynchronizer

Returns an estimate of the number of strands waiting to acquire.

getQueueLength() - Method in class co.paralleluniverse.strands.concurrent.ReentrantLock

Returns an estimate of the number of strands waiting to acquire this lock.

getQueueLength() - Method in class co.paralleluniverse.strands.concurrent.ReentrantReadWriteLock

Returns an estimate of the number of strands waiting to acquire either the read or write lock.

getQueueLength() - Method in class co.paralleluniverse.strands.concurrent.Semaphore

Returns an estimate of the number of threads waiting to acquire.

getReadableDescriptor(String) - Static method in class co.paralleluniverse.common.reflection.ASMUtil

getReadHoldCount() - Method in class co.paralleluniverse.strands.concurrent.ReentrantReadWriteLock

Queries the number of reentrant read holds on this lock by the current strand.

getReadLockCount() - Method in class co.paralleluniverse.strands.concurrent.ReentrantReadWriteLock

Queries the number of read locks held for this lock.

getReason() - Method in exception co.paralleluniverse.fibers.instrument.UnableToInstrumentException

getRecordingDouble() - Method in interface co.paralleluniverse.common.monitoring.RecordingDouble

getRecords() - Method in class co.paralleluniverse.common.benchmark.StripedLongTimeSeries

getRecords() - Method in class co.paralleluniverse.common.benchmark.StripedTimeSeries

getRecords() - Method in class co.paralleluniverse.common.monitoring.FlightRecorder

getRegisteredParties() - Method in class co.paralleluniverse.strands.concurrent.Phaser

Returns the number of parties registered at this phaser.

getRemoteAddress() - Method in class co.paralleluniverse.fibers.io.FiberSocketChannel

Returns the remote address to which this channel's socket is connected.

getRemoveOnCancelPolicy() - Method in class co.paralleluniverse.concurrent.util.ScheduledSingleThreadExecutor

Gets the policy on whether cancelled tasks should be immediately removed from the work queue at time of cancellation.

getResourceAsStream(String) - Method in class co.paralleluniverse.fibers.instrument.QuasarURLClassLoader

getResult() - Method in class co.paralleluniverse.fibers.FiberAsync

Returns the result of the asynchronous operation if it has completed, or throws an exception if it completed unsuccessfully.

getRoot() - Method in class co.paralleluniverse.strands.concurrent.Phaser

Returns the root ancestor of this phaser, which is the same as this phaser if it has no parent.

getRunawayFibers() - Method in interface co.paralleluniverse.fibers.FibersMXBean

The fibers (and respective stack traces) that are currently holding their thread for a lengthy duration, either due to blocking or a lengthy loop.

getRunnable() - Method in class co.paralleluniverse.strands.SuspendableUtils.VoidSuspendableCallable

getRunningFibers() - Method in class co.paralleluniverse.fibers.FiberExecutorScheduler

getRunningThreadCount() - Method in class co.paralleluniverse.common.monitoring.ForkJoinInfo

getRunningThreadCount() - Method in interface co.paralleluniverse.common.monitoring.ForkJoinPoolMXBean

getRunningThreadCount() - Method in class co.paralleluniverse.common.monitoring.JMXForkJoinPoolMonitor

getScheduler() - Method in class co.paralleluniverse.fibers.Fiber

getSecond() - Method in class co.paralleluniverse.common.util.Pair

getSharedQueuedStrands() - Method in class co.paralleluniverse.strands.concurrent.AbstractQueuedLongSynchronizer

Returns a collection containing strands that may be waiting to acquire in shared mode.

getSharedQueuedStrands() - Method in class co.paralleluniverse.strands.concurrent.AbstractQueuedSynchronizer

Returns a collection containing strands that may be waiting to acquire in shared mode.

getSnapshot() - Method in class co.paralleluniverse.common.monitoring.LatencyStatsReservoir

getSnapshot() - Method in class co.paralleluniverse.common.monitoring.SimpleReservoir

getSolo() - Method in class co.paralleluniverse.strands.channels.Mix.State

getSoloEffect() - Method in interface co.paralleluniverse.strands.channels.Mix

getSoloEffect() - Method in class co.paralleluniverse.strands.channels.ReceivePortGroup

getSourceDebugInfo() - Method in class co.paralleluniverse.fibers.instrument.MethodDatabase.ClassEntry

getSourceName() - Method in class co.paralleluniverse.fibers.instrument.MethodDatabase.ClassEntry

getSpuriousWakeups() - Method in interface co.paralleluniverse.fibers.FibersMXBean

getStack() - Static method in class co.paralleluniverse.fibers.Stack

getStackTrace() - Method in class co.paralleluniverse.fibers.Fiber

getStackTrace() - Method in class co.paralleluniverse.fibers.FiberInfo

The fiber's current call stack.

getStackTrace() - Method in class co.paralleluniverse.strands.Strand

Returns an array of stack trace elements representing the stack dump of this strand.

getStackTraceElement() - Method in class co.paralleluniverse.common.util.ExtendedStackTraceElement

getState() - Method in class co.paralleluniverse.concurrent.forkjoin.ParkableForkJoinTask

getState() - Method in class co.paralleluniverse.fibers.Fiber

getState() - Method in class co.paralleluniverse.fibers.FiberInfo

The fiber's current state.

getState(T...) - Method in interface co.paralleluniverse.strands.channels.Mix

getState(T...) - Method in class co.paralleluniverse.strands.channels.ReceivePortGroup

getState() - Method in class co.paralleluniverse.strands.concurrent.AbstractQueuedLongSynchronizer

Returns the current value of synchronization state.

getState() - Method in class co.paralleluniverse.strands.concurrent.AbstractQueuedSynchronizer

Returns the current value of synchronization state.

getState() - Method in class co.paralleluniverse.strands.Strand

Returns the strand's current running state.

getStatus() - Method in interface co.paralleluniverse.common.monitoring.ForkJoinPoolMXBean

getStatus() - Method in class co.paralleluniverse.common.monitoring.JMXForkJoinPoolMonitor

getStealCount() - Method in class co.paralleluniverse.common.monitoring.ForkJoinInfo

getStealCount() - Method in interface co.paralleluniverse.common.monitoring.ForkJoinPoolMXBean

getStealCount() - Method in class co.paralleluniverse.common.monitoring.JMXForkJoinPoolMonitor

getStrand() - Method in class co.paralleluniverse.strands.channels.QueuePrimitiveChannel

getStrand() - Method in class co.paralleluniverse.strands.channels.SingleConsumerQueueChannel

getStrand() - Method in interface co.paralleluniverse.strands.Stranded

getStructuraltimerPeriod() - Method in class co.paralleluniverse.common.monitoring.MonitoringServices

getStructuraltimerPeriod() - Method in interface co.paralleluniverse.common.monitoring.MonitoringServicesMXBean

getSubscribers() - Method in class co.paralleluniverse.strands.channels.Topic

Provides read-only access to subscribers for extentions.

getSuperName() - Method in class co.paralleluniverse.fibers.instrument.MethodDatabase.ClassEntry

getSync() - Method in class co.paralleluniverse.strands.dataflow.Val

getTarget() - Method in class co.paralleluniverse.concurrent.forkjoin.ExtendedForkJoinWorkerThread

getTarget(Thread) - Static method in class co.paralleluniverse.concurrent.forkjoin.ParkableForkJoinTask

getTarget(Thread) - Static method in class co.paralleluniverse.concurrent.util.ThreadAccess

getTarget() - Method in class co.paralleluniverse.fibers.Fiber

getTask() - Method in class co.paralleluniverse.fibers.Fiber

getThread() - Method in class co.paralleluniverse.common.monitoring.FlightRecorder.ThreadRecorder

getThreadLocals(Thread) - Static method in class co.paralleluniverse.concurrent.util.ThreadAccess

getThreadLocalsString() - Static method in class co.paralleluniverse.concurrent.util.ThreadUtil

getThreadLocalsString(Object) - Static method in class co.paralleluniverse.concurrent.util.ThreadUtil

getTimedQueueLength() - Method in interface co.paralleluniverse.fibers.FibersMXBean

getTotalRecs() - Method in class co.paralleluniverse.common.benchmark.StripedLongTimeSeries.ThreadRecorder

getTotalRecs() - Method in class co.paralleluniverse.common.benchmark.StripedTimeSeries.ThreadRecorder

getTotalRecs() - Method in class co.paralleluniverse.common.monitoring.FlightRecorder.ThreadRecorder

getTransferred() - Method in class co.paralleluniverse.strands.channels.transfer.Pipeline

getTypes(Object...) - Static method in class co.paralleluniverse.common.reflection.ReflectionUtil

getUnarrivedParties() - Method in class co.paralleluniverse.strands.concurrent.Phaser

Returns the number of registered parties that have not yet arrived at the current phase of this phaser.

getUncaughtExceptionHandler() - Method in class co.paralleluniverse.fibers.Fiber

Returns the handler invoked when this fiber abruptly terminates due to an uncaught exception.

getUncaughtExceptionHandler() - Method in class co.paralleluniverse.strands.Strand

Returns the handler invoked when this strand abruptly terminates due to an uncaught exception.

getUnderlying() - Method in class co.paralleluniverse.fibers.Fiber

getUnderlying() - Method in class co.paralleluniverse.strands.Strand

Returns the underlying object of this strand, namely a Thread or a Fiber.

getUnparker() - Method in class co.paralleluniverse.concurrent.forkjoin.ParkableForkJoinTask

getUnparkStackTrace() - Method in class co.paralleluniverse.concurrent.forkjoin.ParkableForkJoinTask

getUnsafe() - Static method in class co.paralleluniverse.common.util.UtilUnsafe

getUnsafe1() - Static method in class co.paralleluniverse.common.util.UtilUnsafe

getURLs() - Method in interface co.paralleluniverse.common.classloader.ClassLoaderMXBean

getValue() - Method in class co.paralleluniverse.strands.queues.CircularBuffer.Consumer

getValue() - Method in class co.paralleluniverse.strands.queues.CircularDoubleBuffer.DoubleConsumer

getValue() - Method in class co.paralleluniverse.strands.queues.CircularFloatBuffer.FloatConsumer

getValue() - Method in class co.paralleluniverse.strands.queues.CircularIntBuffer.IntConsumer

getValue() - Method in class co.paralleluniverse.strands.queues.CircularLongBuffer.LongConsumer

getWaitingConsumerCount() - Method in class co.paralleluniverse.strands.channels.TransferChannel

getWaitingStrands() - Method in class co.paralleluniverse.strands.concurrent.AbstractQueuedLongSynchronizer.ConditionObject

Returns a collection containing those strands that may be waiting on this Condition.

getWaitingStrands(AbstractQueuedLongSynchronizer.ConditionObject) - Method in class co.paralleluniverse.strands.concurrent.AbstractQueuedLongSynchronizer

Returns a collection containing those strands that may be waiting on the given condition associated with this synchronizer.

getWaitingStrands() - Method in class co.paralleluniverse.strands.concurrent.AbstractQueuedSynchronizer.ConditionObject

Returns a collection containing those strands that may be waiting on this Condition.

getWaitingStrands(AbstractQueuedSynchronizer.ConditionObject) - Method in class co.paralleluniverse.strands.concurrent.AbstractQueuedSynchronizer

Returns a collection containing those strands that may be waiting on the given condition associated with this synchronizer.

getWaitingStrands(Condition) - Method in class co.paralleluniverse.strands.concurrent.ReentrantLock

Returns a collection containing those strands that may be waiting on the given condition associated with this lock.

getWaitingStrands(Condition) - Method in class co.paralleluniverse.strands.concurrent.ReentrantReadWriteLock

Returns a collection containing those strands that may be waiting on the given condition associated with the write lock.

getWaitQueueLength() - Method in class co.paralleluniverse.strands.concurrent.AbstractQueuedLongSynchronizer.ConditionObject

Returns an estimate of the number of strands waiting on this condition.

getWaitQueueLength(AbstractQueuedLongSynchronizer.ConditionObject) - Method in class co.paralleluniverse.strands.concurrent.AbstractQueuedLongSynchronizer

Returns an estimate of the number of strands waiting on the given condition associated with this synchronizer.

getWaitQueueLength() - Method in class co.paralleluniverse.strands.concurrent.AbstractQueuedSynchronizer.ConditionObject

Returns an estimate of the number of strands waiting on this condition.

getWaitQueueLength(AbstractQueuedSynchronizer.ConditionObject) - Method in class co.paralleluniverse.strands.concurrent.AbstractQueuedSynchronizer

Returns an estimate of the number of strands waiting on the given condition associated with this synchronizer.

getWaitQueueLength(Condition) - Method in class co.paralleluniverse.strands.concurrent.ReentrantLock

Returns an estimate of the number of strands waiting on the given condition associated with this lock.

getWaitQueueLength(Condition) - Method in class co.paralleluniverse.strands.concurrent.ReentrantReadWriteLock

Returns an estimate of the number of strands waiting on the given condition associated with the write lock.

getWinner() - Method in class co.paralleluniverse.strands.channels.Selector

getWriteHoldCount() - Method in class co.paralleluniverse.strands.concurrent.ReentrantReadWriteLock

Queries the number of reentrant write holds on this lock by the current strand.

globToPattern(String) - Static method in class co.paralleluniverse.common.util.Strings

globToRegex(String) - Static method in class co.paralleluniverse.common.util.Strings

grabValue(int) - Method in class co.paralleluniverse.strands.queues.CircularBuffer.Consumer

group(ReceivePort<? extends M>...) - Static method in class co.paralleluniverse.strands.channels.Channels

Returns a ReceivePort that receives messages from a set of channels.

group(Collection<? extends ReceivePort<? extends M>>) - Static method in class co.paralleluniverse.strands.channels.Channels

Returns a ReceivePort that receives messages from a set of channels.

gt(long) - Static method in class co.paralleluniverse.concurrent.util.EnhancedAtomicLong

H

hasAnnotation(String, List<AnnotationNode>) - Static method in class co.paralleluniverse.common.reflection.ASMUtil

hasAnnotation(Class, List<AnnotationNode>) - Static method in class co.paralleluniverse.common.reflection.ASMUtil

hasAnnotation(String, ClassNode) - Static method in class co.paralleluniverse.common.reflection.ASMUtil

hasAnnotation(Class, ClassNode) - Static method in class co.paralleluniverse.common.reflection.ASMUtil

hasAnnotation(String, MethodNode) - Static method in class co.paralleluniverse.common.reflection.ASMUtil

hasAnnotation(Class, MethodNode) - Static method in class co.paralleluniverse.common.reflection.ASMUtil

hasAnnotation(String, FieldNode) - Static method in class co.paralleluniverse.common.reflection.ASMUtil

hasAnnotation(Class, FieldNode) - Static method in class co.paralleluniverse.common.reflection.ASMUtil

hasClassAnnotation(Class<? extends Annotation>, byte[]) - Static method in class co.paralleluniverse.common.reflection.AnnotationUtil

hasClassAnnotation(Class<? extends Annotation>, InputStream) - Static method in class co.paralleluniverse.common.reflection.AnnotationUtil

hasContended() - Method in class co.paralleluniverse.strands.concurrent.AbstractQueuedLongSynchronizer

Queries whether any strands have ever contended to acquire this synchronizer; that is if an acquire method has ever blocked.

hasContended() - Method in class co.paralleluniverse.strands.concurrent.AbstractQueuedSynchronizer

Queries whether any strands have ever contended to acquire this synchronizer; that is if an acquire method has ever blocked.

hashCode - Variable in class co.paralleluniverse.common.monitoring.GenericRecordingDouble

hashCode(CharSequence) - Static method in class co.paralleluniverse.common.util.CharSequences

hashCode() - Method in class co.paralleluniverse.common.util.ExtendedStackTraceElement

hashCode() - Method in class co.paralleluniverse.common.util.Pair

hashCode() - Method in class co.paralleluniverse.common.util.Substring

hashCode() - Method in class co.paralleluniverse.common.util.Tuple

hashCode() - Method in class co.paralleluniverse.fibers.Fiber

hashCode() - Method in class co.paralleluniverse.fibers.instrument.MethodDatabase.ClassEntry

hashCode() - Method in class co.paralleluniverse.strands.channels.DelegatingReceivePort

hashCode() - Method in class co.paralleluniverse.strands.channels.DelegatingSendPort

hashCode() - Method in class co.paralleluniverse.strands.channels.Mix.State

hashCode() - Method in class co.paralleluniverse.strands.channels.ThreadReceivePort

hashCode() - Method in class co.paralleluniverse.strands.channels.ThreadSendPort

hasMessage() - Method in interface co.paralleluniverse.strands.channels.DoubleReceivePort

Tests whether a value is pending in the channel.

hasMessage() - Method in interface co.paralleluniverse.strands.channels.FloatReceivePort

Tests whether a value is pending in the channel.

hasMessage() - Method in interface co.paralleluniverse.strands.channels.IntReceivePort

Tests whether a value is pending in the channel.

hasMessage() - Method in interface co.paralleluniverse.strands.channels.LongReceivePort

Tests whether a value is pending in the channel.

hasMessage() - Method in class co.paralleluniverse.strands.channels.QueuePrimitiveChannel

hasMessage() - Method in class co.paralleluniverse.strands.channels.TickerChannelConsumer

hasMethod(MethodNode, List<MethodNode>) - Static method in class co.paralleluniverse.common.reflection.ASMUtil

hasMethod(MethodNode, ClassNode) - Static method in class co.paralleluniverse.common.reflection.ASMUtil

hasNext() - Method in interface co.paralleluniverse.strands.queues.BasicSingleConsumerQueue

hasNext() - Method in class co.paralleluniverse.strands.queues.CircularBuffer.Consumer

hasNext() - Method in class co.paralleluniverse.strands.queues.CircularBuffer

hasNext() - Method in class co.paralleluniverse.strands.queues.SingleConsumerQueue

hasQueuedPredecessors() - Method in class co.paralleluniverse.strands.concurrent.AbstractQueuedLongSynchronizer

Queries whether any strands have been waiting to acquire longer than the current strand.

hasQueuedPredecessors() - Method in class co.paralleluniverse.strands.concurrent.AbstractQueuedSynchronizer

Queries whether any strands have been waiting to acquire longer than the current strand.

hasQueuedStrand(Strand) - Method in class co.paralleluniverse.strands.concurrent.ReentrantLock

Queries whether the given strand is waiting to acquire this lock.

hasQueuedStrand(Strand) - Method in class co.paralleluniverse.strands.concurrent.ReentrantReadWriteLock

Queries whether the given strand is waiting to acquire either the read or write lock.

hasQueuedStrands() - Method in class co.paralleluniverse.strands.concurrent.AbstractQueuedLongSynchronizer

Queries whether any strands are waiting to acquire.

hasQueuedStrands() - Method in class co.paralleluniverse.strands.concurrent.AbstractQueuedSynchronizer

Queries whether any strands are waiting to acquire.

hasQueuedStrands() - Method in class co.paralleluniverse.strands.concurrent.ReentrantLock

Queries whether any strands are waiting to acquire this lock.

hasQueuedStrands() - Method in class co.paralleluniverse.strands.concurrent.ReentrantReadWriteLock

Queries whether any strands are waiting to acquire the read or write lock.

hasQueuedStrands() - Method in class co.paralleluniverse.strands.concurrent.Semaphore

Queries whether any threads are waiting to acquire.

hasWaiters() - Method in class co.paralleluniverse.strands.concurrent.AbstractQueuedLongSynchronizer.ConditionObject

Queries whether any strands are waiting on this condition.

hasWaiters(AbstractQueuedLongSynchronizer.ConditionObject) - Method in class co.paralleluniverse.strands.concurrent.AbstractQueuedLongSynchronizer

Queries whether any strands are waiting on the given condition associated with this synchronizer.

hasWaiters() - Method in class co.paralleluniverse.strands.concurrent.AbstractQueuedSynchronizer.ConditionObject

Queries whether any strands are waiting on this condition.

hasWaiters(AbstractQueuedSynchronizer.ConditionObject) - Method in class co.paralleluniverse.strands.concurrent.AbstractQueuedSynchronizer

Queries whether any strands are waiting on the given condition associated with this synchronizer.

hasWaiters(Condition) - Method in class co.paralleluniverse.strands.concurrent.ReentrantLock

Queries whether any strands are waiting on the given condition associated with this lock.

hasWaiters(Condition) - Method in class co.paralleluniverse.strands.concurrent.ReentrantReadWriteLock

Queries whether any strands are waiting on the given condition associated with the write lock.

headSet(E, boolean) - Method in class co.paralleluniverse.concurrent.util.ConcurrentSkipListSet

headSet(E) - Method in class co.paralleluniverse.concurrent.util.ConcurrentSkipListSet

here() - Static method in class co.paralleluniverse.common.util.ExtendedStackTrace

hex(long) - Static method in class co.paralleluniverse.common.logging.LoggingUtils

hex(int) - Static method in class co.paralleluniverse.common.logging.LoggingUtils

higher(E) - Method in class co.paralleluniverse.concurrent.util.ConcurrentSkipListSet

highestEquivalentValue(long) - Method in class co.paralleluniverse.common.benchmark.StripedHistogram

Get the highest value that is equivalent to the given value within the histogram's resolution.

histogram(String) - Static method in class co.paralleluniverse.common.monitoring.Metrics

I

identity(Object) - Static method in class co.paralleluniverse.common.util.Objects

inc() - Method in class co.paralleluniverse.common.monitoring.Counter

index - Variable in class co.paralleluniverse.common.monitoring.FlightRecorder.Record

index() - Method in class co.paralleluniverse.strands.channels.SelectAction

index() - Method in class co.paralleluniverse.strands.channels.SelectActionImpl

indexOf(Object) - Method in class co.paralleluniverse.common.util.Tuple

inForkJoinPool() - Static method in class co.paralleluniverse.concurrent.forkjoin.ForkJoinUtil

inheritThreadLocals() - Method in class co.paralleluniverse.fibers.Fiber

Causes the current strand's thread-locals to be inherited by this fiber.

init(int, int) - Method in class co.paralleluniverse.common.monitoring.FlightRecorder

initialValue(FiberScheduler) - Method in class co.paralleluniverse.fibers.SchedulerLocal

Computes the initial value for the current FiberScheduler.

instance - Static variable in class co.paralleluniverse.common.monitoring.MonitoringServices

instance - Static variable in exception co.paralleluniverse.strands.channels.ReceivePort.EOFException

instance - Static variable in class co.paralleluniverse.strands.DoneSynchronizer

InstrumentationTask - Class in co.paralleluniverse.fibers.instrument

Instrumentation ANT task

InstrumentationTask() - Constructor for class co.paralleluniverse.fibers.instrument.InstrumentationTask

InstrumentationTask.WorkListEntry - Class in co.paralleluniverse.fibers.instrument

InstrumentationTKB - Class in co.paralleluniverse.fibers.instrument

InstrumentationTKB() - Constructor for class co.paralleluniverse.fibers.instrument.InstrumentationTKB

instrumentClass(ClassLoader, String, byte[]) - Method in class co.paralleluniverse.fibers.instrument.QuasarInstrumentor

instrumentClass(ClassLoader, String, InputStream) - Method in class co.paralleluniverse.fibers.instrument.QuasarInstrumentor

Instrumented - Annotation Type in co.paralleluniverse.fibers

Marks a class or a method as instrumented - for internal use only! It must never be used in Java source code.

instrumentResourceStream(String, InputStream) - Method in class co.paralleluniverse.fibers.instrument.QuasarURLClassLoaderHelper

IntChannel - Interface in co.paralleluniverse.strands.channels

A channel for primitive int messages.

IntConsumer() - Constructor for class co.paralleluniverse.strands.queues.CircularIntBuffer.IntConsumer

interrupt() - Method in class co.paralleluniverse.fibers.Fiber

interrupt() - Method in class co.paralleluniverse.strands.Strand

Interrupts this strand.

interrupted() - Static method in class co.paralleluniverse.fibers.Fiber

interrupted() - Method in class co.paralleluniverse.fibers.FiberAsync

Called when the fiber calling run is interrupted during the call.

interrupted() - Static method in class co.paralleluniverse.strands.Strand

Tests whether the current strand has been interrupted.

interruptTask() - Method in class co.paralleluniverse.strands.AbstractFuture

intNext() - Method in interface co.paralleluniverse.strands.queues.IntQueueIterator

IntQueueIterator - Interface in co.paralleluniverse.strands.queues

IntReceivePort - Interface in co.paralleluniverse.strands.channels

A primitive int channel's consumer-side interface.

IntSendPort - Interface in co.paralleluniverse.strands.channels

A primitive int channel's producer-side interface.

intValue() - Method in interface co.paralleluniverse.strands.queues.IntQueueIterator

intValue(int) - Method in class co.paralleluniverse.strands.queues.SingleConsumerArrayIntQueue

invokeAll(Collection<? extends Callable<T>>) - Method in interface co.paralleluniverse.concurrent.util.CompletableExecutorService

invokeAll(Collection<? extends Callable<T>>, long, TimeUnit) - Method in interface co.paralleluniverse.concurrent.util.CompletableExecutorService

IOStreamSerializer - Interface in co.paralleluniverse.io.serialization

isActive() - Static method in class co.paralleluniverse.fibers.instrument.JavaAgent

isAlive() - Method in class co.paralleluniverse.fibers.Fiber

isAlive() - Method in class co.paralleluniverse.strands.Strand

Tests whether this strand is alive, namely it has been started but not yet terminated.

isAllowBlocking() - Method in class co.paralleluniverse.fibers.instrument.QuasarInstrumentor

isAllowMonitors() - Method in class co.paralleluniverse.fibers.instrument.QuasarInstrumentor

isAlreadyInstrumented() - Method in class co.paralleluniverse.fibers.instrument.CheckInstrumentationVisitor

isAOT() - Method in class co.paralleluniverse.fibers.instrument.QuasarInstrumentor

isAssertionsEnabled() - Static method in class co.paralleluniverse.common.util.Debug

isAssignable(Class<?>[], Class<?>[], boolean) - Static method in class co.paralleluniverse.common.reflection.ReflectionUtil

isAssignable(Class<?>, Class<?>, boolean) - Static method in class co.paralleluniverse.common.reflection.ReflectionUtil

isAssignableFrom(Class<?>, String, ClassLoader) - Static method in class co.paralleluniverse.common.reflection.ASMUtil

isAssignableFrom(String, String, ClassLoader) - Static method in class co.paralleluniverse.common.reflection.ASMUtil

isBroken() - Method in class co.paralleluniverse.strands.concurrent.CyclicBarrier

Queries if this barrier is in a broken state.

isCallSiteInstrumented(Member, int, int, ExtendedStackTraceElement[], int) - Static method in class co.paralleluniverse.fibers.instrument.SuspendableHelper

isCancelled() - Method in class co.paralleluniverse.fibers.Fiber

isCancelled() - Method in class co.paralleluniverse.strands.AbstractFuture

isCancelled() - Method in class co.paralleluniverse.strands.dataflow.Val

isCI() - Static method in class co.paralleluniverse.common.util.Debug

isClassFile(String) - Static method in class co.paralleluniverse.common.reflection.ClassLoaderUtil

isClosed() - Method in class co.paralleluniverse.strands.channels.DelegatingReceivePort

isClosed() - Method in class co.paralleluniverse.strands.channels.FlatMappingReceivePort

isClosed() - Method in interface co.paralleluniverse.strands.channels.PortAutoCloseable

Tests whether the channel has been closed and no more messages await in the channel.

isClosed() - Method in class co.paralleluniverse.strands.channels.QueueChannel

This method must only be called by the channel's owner (the receiver)

isClosed() - Method in class co.paralleluniverse.strands.channels.ReceivePortGroup

isClosed() - Method in class co.paralleluniverse.strands.channels.ThreadReceivePort

Tests whether the channel has been closed and no more messages await in the channel.

isClosed() - Method in class co.paralleluniverse.strands.channels.TickerChannelConsumer

isClosed() - Method in class co.paralleluniverse.strands.channels.TransferChannel

isClosed() - Method in class co.paralleluniverse.strands.channels.ZippingReceivePort

isClosed() - Method in class co.paralleluniverse.strands.dataflow.ValChannel

isCompleted() - Method in class co.paralleluniverse.fibers.FiberAsync

Tests whether or not the asynchronous operation represented by this `FiberAsyc` has completed.

isCurrentFiber() - Static method in class co.paralleluniverse.fibers.Fiber

Tests whether current code is executing in a fiber.

isCurrentFiber() - Static method in class co.paralleluniverse.strands.Strand

Tests whether this function is called within a fiber.

isCurrentThreadInScheduler() - Method in class co.paralleluniverse.fibers.FiberExecutorScheduler

isCurrentThreadInScheduler() - Method in class co.paralleluniverse.fibers.FiberForkJoinScheduler

isCurrentThreadInScheduler() - Method in class co.paralleluniverse.fibers.FiberScheduler

isData() - Method in class co.paralleluniverse.strands.channels.SelectActionImpl

isDebug() - Static method in class co.paralleluniverse.common.util.Debug

isDebug() - Method in class co.paralleluniverse.fibers.instrument.MethodDatabase

isDebug() - Method in class co.paralleluniverse.fibers.instrument.QuasarInstrumentor

isDebugger() - Static method in class co.paralleluniverse.common.util.Debug

isDone() - Method in class co.paralleluniverse.fibers.Fiber

isDone() - Method in interface co.paralleluniverse.fibers.Joinable

isDone() - Method in class co.paralleluniverse.strands.AbstractFuture

isDone() - Method in class co.paralleluniverse.strands.channels.SelectAction

Tests whether this operation is the one operation that has been selected and completed by the selector.

isDone() - Method in class co.paralleluniverse.strands.dataflow.Val

isDone() - Method in class co.paralleluniverse.strands.Strand

isEmpty() - Method in class co.paralleluniverse.common.util.ConcurrentSet

isEmpty() - Method in class co.paralleluniverse.concurrent.util.ConcurrentSkipListPriorityQueue

Returns true if this map contains no key-value mappings.

isEmpty() - Method in class co.paralleluniverse.concurrent.util.ConcurrentSkipListSet

Returns true if this set contains no elements.

isEmpty() - Method in class co.paralleluniverse.concurrent.util.SingleConsumerNonblockingProducerQueue

isEmpty() - Method in class co.paralleluniverse.strands.queues.ArrayQueue

isEmpty() - Method in interface co.paralleluniverse.strands.queues.BasicQueue

isEmpty() - Method in class co.paralleluniverse.strands.queues.BoxQueue

isEmpty() - Method in class co.paralleluniverse.strands.queues.CircularBuffer.Consumer

isEmpty() - Method in class co.paralleluniverse.strands.queues.CircularBuffer

isEmpty() - Method in class co.paralleluniverse.strands.queues.SingleConsumerQueue

isEmptyOrTrue(String) - Static method in class co.paralleluniverse.common.util.SystemProperties

Returns the value of a system property which defaults to false.

isException(String) - Method in class co.paralleluniverse.fibers.instrument.MethodDatabase

isExcluded(String) - Method in class co.paralleluniverse.fibers.instrument.QuasarInstrumentor

isExpired(E) - Method in class co.paralleluniverse.concurrent.util.SingleConsumerNonblockingProducerDelayQueue

isExpired() - Method in class co.paralleluniverse.strands.Timeout

Tests whether the timeout has expired.

isFair() - Method in class co.paralleluniverse.strands.concurrent.ReentrantLock

Returns true if this lock has fairness set true.

isFair() - Method in class co.paralleluniverse.strands.concurrent.ReentrantReadWriteLock

Returns true if this lock has fairness set true.

isFair() - Method in class co.paralleluniverse.strands.concurrent.Semaphore

Returns true if this semaphore has fairness set true.

isFiber() - Method in class co.paralleluniverse.fibers.Fiber

isFiber() - Method in class co.paralleluniverse.strands.Strand

Tests whether this strand is a fiber.

isFiberThread(Thread) - Static method in class co.paralleluniverse.fibers.FiberForkJoinScheduler

isFirstInStackOrPushed() - Method in class co.paralleluniverse.fibers.Stack

called when nextMethodEntry returns 0

isHeldByCurrentStrand() - Method in class co.paralleluniverse.strands.concurrent.ReentrantLock

Queries if this lock is held by the current strand.

isHeldByCurrentStrand() - Method in class co.paralleluniverse.strands.concurrent.ReentrantReadWriteLock.WriteLock

Queries if this write lock is held by the current strand.

isHeldExclusively() - Method in class co.paralleluniverse.strands.concurrent.AbstractQueuedLongSynchronizer

Returns true if synchronization is held exclusively with respect to the current (calling) strand.

isHeldExclusively() - Method in class co.paralleluniverse.strands.concurrent.AbstractQueuedSynchronizer

Returns true if synchronization is held exclusively with respect to the current (calling) strand.

isInstrumented() - Method in class co.paralleluniverse.fibers.instrument.MethodDatabase.ClassEntry

isInstrumented(Class) - Static method in class co.paralleluniverse.fibers.instrument.Retransform

isInstrumented(Class) - Static method in class co.paralleluniverse.fibers.instrument.SuspendableHelper

isInstrumented(Member) - Static method in class co.paralleluniverse.fibers.instrument.SuspendableHelper

isInterface() - Method in class co.paralleluniverse.fibers.instrument.MethodDatabase.ClassEntry

isInterrupted() - Method in class co.paralleluniverse.fibers.Fiber

isInterrupted() - Method in class co.paralleluniverse.strands.Strand

Tests whether this strand has been interrupted.

isInvocationHandlerInvocation(String, String) - Static method in class co.paralleluniverse.fibers.instrument.MethodDatabase

isJavaAgentActive() - Static method in class co.paralleluniverse.fibers.instrument.SuspendableHelper

isJDK(String) - Static method in class co.paralleluniverse.fibers.instrument.MethodDatabase

isLocked() - Method in class co.paralleluniverse.strands.concurrent.ReentrantLock

Queries if this lock is held by any strand.

isMethodHandleInvocation(String, String) - Static method in class co.paralleluniverse.fibers.instrument.MethodDatabase

isMethodSuspendable(String, String, String, int) - Method in class co.paralleluniverse.fibers.instrument.MethodDatabase

isNativeMethod() - Method in class co.paralleluniverse.common.util.ExtendedStackTraceElement

Returns true if the method containing the execution point represented by this stack trace element is a native method.

isNotFalse(String) - Static method in class co.paralleluniverse.common.util.SystemProperties

Returns the value of a system property which defaults to true.

isOpen() - Method in class co.paralleluniverse.fibers.io.FiberFileChannel

isOpen() - Method in class co.paralleluniverse.fibers.io.FiberServerSocketChannel

isOpen() - Method in class co.paralleluniverse.fibers.io.FiberSocketChannel

isOptimized(Member) - Static method in class co.paralleluniverse.fibers.instrument.SuspendableHelper

isOwnerAlive() - Method in class co.paralleluniverse.strands.channels.SingleConsumerQueueChannel

isPerformanceUpdates() - Method in class co.paralleluniverse.common.monitoring.MonitoringServices

isPerformanceUpdates() - Method in interface co.paralleluniverse.common.monitoring.MonitoringServicesMXBean

isProblematicClass(String) - Static method in class co.paralleluniverse.fibers.instrument.MethodDatabase

isQueued(Strand) - Method in class co.paralleluniverse.strands.concurrent.AbstractQueuedLongSynchronizer

Returns true if the given strand is currently queued.

isQueued(Strand) - Method in class co.paralleluniverse.strands.concurrent.AbstractQueuedSynchronizer

Returns true if the given strand is currently queued.

isReadLocked() - Method in class co.paralleluniverse.strands.concurrent.StampedLock

Returns true if the lock is currently held non-exclusively.

isRecording() - Method in class co.paralleluniverse.concurrent.forkjoin.ParkableForkJoinTask

isRecordingLevel(int) - Method in class co.paralleluniverse.fibers.Fiber

isRecordStackTraces() - Static method in class co.paralleluniverse.common.util.Debug

isReflectInvocation(String, String) - Static method in class co.paralleluniverse.fibers.instrument.MethodDatabase

isRegistered() - Method in class co.paralleluniverse.common.monitoring.JMXForkJoinPoolMonitor

isShutdown() - Method in class co.paralleluniverse.common.util.SameThreadExecutorService

isShutdown() - Method in class co.paralleluniverse.concurrent.util.ScheduledSingleThreadExecutor

isShutdown() - Method in class co.paralleluniverse.fibers.FiberTimedScheduler

isSingleConsumer() - Method in class co.paralleluniverse.strands.channels.QueueChannel

isSingleConsumer() - Method in interface co.paralleluniverse.strands.channels.StandardChannel

Whether or not the channel supports a single consumer only.

isSingleConsumer() - Method in class co.paralleluniverse.strands.channels.TransferChannel

isSingleProducer() - Method in class co.paralleluniverse.strands.channels.QueueChannel

isSingleProducer() - Method in interface co.paralleluniverse.strands.channels.StandardChannel

Whether or not the channel supports a single producer only.

isSingleProducer() - Method in class co.paralleluniverse.strands.channels.TransferChannel

isSingleProducer() - Method in class co.paralleluniverse.strands.queues.CircularBuffer

isStructuralUpdates() - Method in class co.paralleluniverse.common.monitoring.MonitoringServices

isStructuralUpdates() - Method in interface co.paralleluniverse.common.monitoring.MonitoringServicesMXBean

isSuperSuspendable(String, String, String) - Method in class co.paralleluniverse.fibers.instrument.SimpleSuspendableClassifier

isSuspendable(MethodDatabase, String, String, boolean, String, String, String[], String, String, String, String[]) - Method in class co.paralleluniverse.fibers.instrument.DefaultSuspendableClassifier

isSuspendable(String) - Method in class co.paralleluniverse.fibers.instrument.MethodDatabase.ClassEntry

isSuspendable(ClassLoader, String, String) - Static method in class co.paralleluniverse.fibers.instrument.Retransform

isSuspendable(String, String, String) - Method in class co.paralleluniverse.fibers.instrument.SimpleSuspendableClassifier

isSuspendable(MethodDatabase, String, String, boolean, String, String, String[], String, String, String, String[]) - Method in class co.paralleluniverse.fibers.instrument.SimpleSuspendableClassifier

isSuspendable(MethodDatabase, String, String, boolean, String, String, String[], String, String, String, String[]) - Method in interface co.paralleluniverse.fibers.instrument.SuspendableClassifier

isSyntheticAccess(String, String) - Static method in class co.paralleluniverse.fibers.instrument.MethodDatabase

isSyntheticAndNotLambda(Member) - Static method in class co.paralleluniverse.fibers.instrument.SuspendableHelper

isTerminated() - Method in class co.paralleluniverse.common.util.SameThreadExecutorService

isTerminated() - Method in class co.paralleluniverse.concurrent.util.ScheduledSingleThreadExecutor

isTerminated() - Method in class co.paralleluniverse.fibers.Fiber

isTerminated() - Method in class co.paralleluniverse.fibers.FiberTimedScheduler

isTerminated() - Method in class co.paralleluniverse.strands.concurrent.Phaser

Returns true if this phaser has been terminated.

isTerminated() - Method in class co.paralleluniverse.strands.Strand

Tests whether this strand has terminated.

isTickerChannel(ReceivePort<?>) - Static method in class co.paralleluniverse.strands.channels.Channels

Tests whether a given channel is a ticker channel, namely a channel with a bounded buffer and an overflow policy of DISPLACE.

isUnitTest() - Static method in class co.paralleluniverse.common.util.Debug

isVerbose() - Method in class co.paralleluniverse.fibers.instrument.MethodDatabase

isVerbose() - Method in class co.paralleluniverse.fibers.instrument.QuasarInstrumentor

isWaiver(String, String) - Static method in class co.paralleluniverse.fibers.instrument.Retransform

isWaiver(String, String) - Static method in class co.paralleluniverse.fibers.instrument.SuspendableHelper

isWriteLocked() - Method in class co.paralleluniverse.strands.concurrent.ReentrantReadWriteLock

Queries if the write lock is held by any strand.

isWriteLocked() - Method in class co.paralleluniverse.strands.concurrent.StampedLock

Returns true if the lock is currently held exclusively.

isWriteLockedByCurrentStrand() - Method in class co.paralleluniverse.strands.concurrent.ReentrantReadWriteLock

Queries if the write lock is held by the current strand.

iterator() - Method in class co.paralleluniverse.common.benchmark.Striped

iterator() - Method in class co.paralleluniverse.common.util.ConcurrentSet

iterator() - Method in class co.paralleluniverse.common.util.ExtendedStackTrace

iterator() - Method in class co.paralleluniverse.common.util.Tuple

iterator() - Method in class co.paralleluniverse.concurrent.util.ConcurrentSkipListPriorityQueue

iterator() - Method in class co.paralleluniverse.concurrent.util.ConcurrentSkipListSet

Returns an iterator over the elements in this set in ascending order.

iterator() - Method in class co.paralleluniverse.concurrent.util.DelayQueue

Returns an iterator over all the elements (both expired and unexpired) in this queue.

iterator() - Method in class co.paralleluniverse.concurrent.util.SingleConsumerNonblockingProducerQueue

iterator() - Method in class co.paralleluniverse.strands.queues.SingleConsumerArrayDoubleQueue

iterator() - Method in class co.paralleluniverse.strands.queues.SingleConsumerArrayFloatQueue

iterator() - Method in class co.paralleluniverse.strands.queues.SingleConsumerArrayIntQueue

iterator() - Method in class co.paralleluniverse.strands.queues.SingleConsumerArrayLongQueue

iterator() - Method in class co.paralleluniverse.strands.queues.SingleConsumerLinkedArrayDoubleQueue

iterator() - Method in class co.paralleluniverse.strands.queues.SingleConsumerLinkedArrayFloatQueue

iterator() - Method in class co.paralleluniverse.strands.queues.SingleConsumerLinkedArrayIntQueue

iterator() - Method in class co.paralleluniverse.strands.queues.SingleConsumerLinkedArrayLongQueue

iterator() - Method in class co.paralleluniverse.strands.queues.SingleConsumerLinkedDoubleQueue

iterator() - Method in class co.paralleluniverse.strands.queues.SingleConsumerLinkedFloatQueue

iterator() - Method in class co.paralleluniverse.strands.queues.SingleConsumerLinkedIntQueue

iterator() - Method in class co.paralleluniverse.strands.queues.SingleConsumerLinkedLongQueue

iterator() - Method in class co.paralleluniverse.strands.queues.SingleConsumerQueue

J

JavaAgent - Class in co.paralleluniverse.fibers.instrument

JavaAgent() - Constructor for class co.paralleluniverse.fibers.instrument.JavaAgent

JDKSerializer - Class in co.paralleluniverse.io.serialization

JDKSerializer() - Constructor for class co.paralleluniverse.io.serialization.JDKSerializer

JMXForkJoinPoolMonitor - Class in co.paralleluniverse.common.monitoring

JMXForkJoinPoolMonitor(String, ForkJoinPool) - Constructor for class co.paralleluniverse.common.monitoring.JMXForkJoinPoolMonitor

join() - Method in class co.paralleluniverse.fibers.Fiber

join(long, TimeUnit) - Method in class co.paralleluniverse.fibers.Fiber

join() - Method in interface co.paralleluniverse.fibers.Joinable

join(long, TimeUnit) - Method in interface co.paralleluniverse.fibers.Joinable

join() - Method in class co.paralleluniverse.strands.Strand

Awaits the termination of this strand.

join(long, TimeUnit) - Method in class co.paralleluniverse.strands.Strand

Awaits the termination of this strand, at most for the timeout duration specified.

join(Object) - Static method in class co.paralleluniverse.strands.Strand

Awaits the termination of a given strand.

join(Object, long, TimeUnit) - Static method in class co.paralleluniverse.strands.Strand

Awaits the termination of a given strand, at most for the timeout duration specified.

Joinable<V> - Interface in co.paralleluniverse.fibers

joinNoSuspend() - Method in class co.paralleluniverse.fibers.Fiber

joinNoSuspend(long, TimeUnit) - Method in class co.paralleluniverse.fibers.Fiber

K

kryo - Variable in class co.paralleluniverse.io.serialization.kryo.KryoSerializer

KryoSerializer - Class in co.paralleluniverse.io.serialization.kryo

This class is not thread-safe.

KryoSerializer() - Constructor for class co.paralleluniverse.io.serialization.kryo.KryoSerializer

KryoUtil - Class in co.paralleluniverse.io.serialization.kryo

L

last() - Method in class co.paralleluniverse.concurrent.util.ConcurrentSkipListSet

lastIndexOf(Object) - Method in class co.paralleluniverse.common.util.Tuple

lastIndexRead() - Method in class co.paralleluniverse.strands.queues.CircularBuffer.Consumer

LatencyStatsReservoir - Class in co.paralleluniverse.common.monitoring

LatencyStatsReservoir(LatencyStats) - Constructor for class co.paralleluniverse.common.monitoring.LatencyStatsReservoir

lease() - Method in class co.paralleluniverse.strands.channels.SelectActionImpl

LEASED - Static variable in class co.paralleluniverse.concurrent.forkjoin.ParkableForkJoinTask

length() - Method in class co.paralleluniverse.common.util.Substring

listIterator() - Method in class co.paralleluniverse.common.util.Tuple

listIterator(int) - Method in class co.paralleluniverse.common.util.Tuple

loadSingletonService(Class<T>) - Static method in class co.paralleluniverse.common.util.ServiceUtil

Loads a service of the given type and ensures it has exactly one implementation.

loadSingletonServiceOrNull(Class<T>) - Static method in class co.paralleluniverse.common.util.ServiceUtil

Loads a service of the given type and ensures it has either one implementation or none.

lock(long, long, boolean) - Method in class co.paralleluniverse.fibers.io.FiberFileChannel

lock() - Method in class co.paralleluniverse.strands.concurrent.ReentrantLock

Acquires the lock.

lock() - Method in class co.paralleluniverse.strands.concurrent.ReentrantReadWriteLock.ReadLock

Acquires the read lock.

lock() - Method in class co.paralleluniverse.strands.concurrent.ReentrantReadWriteLock.WriteLock

Acquires the write lock.

lockInterruptibly() - Method in class co.paralleluniverse.strands.concurrent.ReentrantLock

Acquires the lock unless the current strand is interrupted.

lockInterruptibly() - Method in class co.paralleluniverse.strands.concurrent.ReentrantReadWriteLock.ReadLock

Acquires the read lock unless the current strand is interrupted.

lockInterruptibly() - Method in class co.paralleluniverse.strands.concurrent.ReentrantReadWriteLock.WriteLock

Acquires the write lock unless the current strand is interrupted.

Log - Interface in co.paralleluniverse.fibers.instrument

log(LogLevel, String, Object...) - Method in interface co.paralleluniverse.fibers.instrument.Log

log(LogLevel, String, Object...) - Method in class co.paralleluniverse.fibers.instrument.MethodDatabase

log(LogLevel, String, Object...) - Method in class co.paralleluniverse.fibers.instrument.QuasarInstrumentor

LoggingUtils - Class in co.paralleluniverse.common.logging

LogLevel - Enum in co.paralleluniverse.fibers.instrument

LongChannel - Interface in co.paralleluniverse.strands.channels

A channel for primitive double messages.

LongConsumer() - Constructor for class co.paralleluniverse.strands.queues.CircularLongBuffer.LongConsumer

longNext() - Method in interface co.paralleluniverse.strands.queues.LongQueueIterator

LongQueueIterator - Interface in co.paralleluniverse.strands.queues

LongReceivePort - Interface in co.paralleluniverse.strands.channels

A primitive long channel's consumer-side interface.

LongSendPort - Interface in co.paralleluniverse.strands.channels

A primitive long channel's producer-side interface.

longValue() - Method in interface co.paralleluniverse.strands.queues.LongQueueIterator

lookupMethod(ExtendedStackTraceElement) - Static method in class co.paralleluniverse.fibers.instrument.SuspendableHelper

lower(E) - Method in class co.paralleluniverse.concurrent.util.ConcurrentSkipListSet

lowestEquivalentValue(long) - Method in class co.paralleluniverse.common.benchmark.StripedHistogram

Get the lowest value that is equivalent to the given value within the histogram's resolution.

M

main(String[]) - Static method in class co.paralleluniverse.fibers.instrument.InstrumentationTKB

make(ConcurrentMap<E, Object>) - Static method in class co.paralleluniverse.common.util.ConcurrentSet

makeFlightRecorderMessage(String, String, String, Object[]) - Method in interface co.paralleluniverse.common.monitoring.FlightRecorderMessageFactory

map(FileChannel.MapMode, long, long) - Method in class co.paralleluniverse.fibers.io.FiberFileChannel

map(ReceivePort<S>, Function<S, T>) - Static method in class co.paralleluniverse.strands.channels.Channels

Returns a ReceivePort that receives messages that are transformed by a given mapping function from a given channel.

map(S) - Method in class co.paralleluniverse.strands.channels.FlatMappingReceivePort

map(Function<T, U>) - Method in class co.paralleluniverse.strands.channels.TransformingReceivePort

Returns a TransformingReceivePort that receives messages that are transformed by a given mapping function from this channel.

map(Function<S, T>) - Method in class co.paralleluniverse.strands.channels.TransformingSendPort

Returns a TransformingSendPort that transforms messages by applying a given mapping function before sending this channel.

mapErrors(ReceivePort<T>, Function<Exception, T>) - Static method in class co.paralleluniverse.strands.channels.Channels

Returns a ReceivePort that maps exceptions thrown by the underlying channel (by channel transformations, or as a result of SendPort.close(Throwable) ) into messages.

mapSend(SendPort<T>, Function<S, T>) - Static method in class co.paralleluniverse.strands.channels.Channels

Returns a SendPort that transforms messages by applying a given mapping function before sending them to a given channel.

MapUtil - Class in co.paralleluniverse.concurrent.util

MAX_ENTRY - Static variable in class co.paralleluniverse.fibers.Stack

MAX_PRIORITY - Static variable in class co.paralleluniverse.strands.Strand

The maximum priority that a strand can have.

MAX_SLOTS - Static variable in class co.paralleluniverse.fibers.Stack

maybeSetCurrentStrandAsOwner() - Method in class co.paralleluniverse.strands.channels.QueuePrimitiveChannel

maybeSetCurrentStrandAsOwner() - Method in class co.paralleluniverse.strands.channels.SingleConsumerQueueChannel

medianEquivalentValue(long) - Method in class co.paralleluniverse.common.benchmark.StripedHistogram

Get a value that lies in the middle (rounded up) of the range of values equivalent the given value.

message() - Method in class co.paralleluniverse.strands.channels.SelectAction

Returns the message to send if this is a send operation, or the message that has been received if this is a receive operation and has been successfully completed by the selector.

meter(String) - Static method in class co.paralleluniverse.common.monitoring.Metrics

MethodDatabase - Class in co.paralleluniverse.fibers.instrument

Collects information about classes and their suspendable methods.

MethodDatabase(QuasarInstrumentor, ClassLoader, SuspendableClassifier) - Constructor for class co.paralleluniverse.fibers.instrument.MethodDatabase

MethodDatabase.ClassEntry - Class in co.paralleluniverse.fibers.instrument

MethodDatabase.ExtractSuperClass - Class in co.paralleluniverse.fibers.instrument

MethodDatabase.SuspendableType - Enum in co.paralleluniverse.fibers.instrument

metric(String, String) - Method in class co.paralleluniverse.common.monitoring.MetricsForkJoinPoolMonitor

Metrics - Class in co.paralleluniverse.common.monitoring

Metrics() - Constructor for class co.paralleluniverse.common.monitoring.Metrics

MetricsForkJoinPoolMonitor - Class in co.paralleluniverse.common.monitoring

MetricsForkJoinPoolMonitor(String, ForkJoinPool) - Constructor for class co.paralleluniverse.common.monitoring.MetricsForkJoinPoolMonitor

MIN_PRIORITY - Static variable in class co.paralleluniverse.strands.Strand

The minimum priority that a strand can have.

mix(ReceivePort<? extends M>...) - Static method in class co.paralleluniverse.strands.channels.Channels

Returns a Mix that receives messages from a set of channels.

mix(Collection<? extends ReceivePort<? extends M>>) - Static method in class co.paralleluniverse.strands.channels.Channels

Returns a Mix that receives messages from a set of channels.

Mix<M> - Interface in co.paralleluniverse.strands.channels

ReceivePort with Mix operations.

Mix.Mode - Enum in co.paralleluniverse.strands.channels

Mix.SoloEffect - Enum in co.paralleluniverse.strands.channels

Mix.State - Class in co.paralleluniverse.strands.channels

mode - Variable in class co.paralleluniverse.strands.channels.Mix.State

MonitoredForkJoinPool - Class in co.paralleluniverse.concurrent.forkjoin

MonitoredForkJoinPool(String) - Constructor for class co.paralleluniverse.concurrent.forkjoin.MonitoredForkJoinPool

MonitoredForkJoinPool(String, int) - Constructor for class co.paralleluniverse.concurrent.forkjoin.MonitoredForkJoinPool

MonitoredForkJoinPool(String, int, ForkJoinPool.ForkJoinWorkerThreadFactory, Thread.UncaughtExceptionHandler, boolean) - Constructor for class co.paralleluniverse.concurrent.forkjoin.MonitoredForkJoinPool

MonitoredForkJoinPool() - Constructor for class co.paralleluniverse.concurrent.forkjoin.MonitoredForkJoinPool

MonitoredForkJoinPool(int) - Constructor for class co.paralleluniverse.concurrent.forkjoin.MonitoredForkJoinPool

MonitoredForkJoinPool(int, ForkJoinPool.ForkJoinWorkerThreadFactory, Thread.UncaughtExceptionHandler, boolean) - Constructor for class co.paralleluniverse.concurrent.forkjoin.MonitoredForkJoinPool

MonitoringServices - Class in co.paralleluniverse.common.monitoring

MonitoringServicesMXBean - Interface in co.paralleluniverse.common.monitoring

MonitorType - Enum in co.paralleluniverse.common.monitoring

N

name - Variable in class co.paralleluniverse.common.monitoring.SimpleMBean

name - Variable in class co.paralleluniverse.fibers.instrument.InstrumentationTask.WorkListEntry

nanosLeft() - Method in class co.paralleluniverse.strands.Timeout

Returns how many nanoseconds are left before the timeout expires, or a negative number indicating how many nanoseconds have elapsed since the timeout expired.

needsInstrumentation() - Method in class co.paralleluniverse.fibers.instrument.CheckInstrumentationVisitor

newChannel(int, Channels.OverflowPolicy, boolean, boolean) - Static method in class co.paralleluniverse.strands.channels.Channels

Creates a new channel with the given properties.

newChannel(int, Channels.OverflowPolicy) - Static method in class co.paralleluniverse.strands.channels.Channels

Creates a new channel with the given mailbox size and Channels.OverflowPolicy, with other properties set to their default values.

newChannel(int) - Static method in class co.paralleluniverse.strands.channels.Channels

Creates a new channel with the given mailbox size with other properties set to their default values.

newConcurrentHashMap() - Static method in class co.paralleluniverse.concurrent.util.MapUtil

newCondition() - Method in class co.paralleluniverse.strands.concurrent.ReentrantLock

Returns a Condition instance for use with this Lock instance.

newCondition() - Method in class co.paralleluniverse.strands.concurrent.ReentrantReadWriteLock.ReadLock

Throws UnsupportedOperationException because ReadLocks do not support conditions.

newCondition() - Method in class co.paralleluniverse.strands.concurrent.ReentrantReadWriteLock.WriteLock

Returns a Condition instance for use with this Lock instance.

newConsumer() - Method in class co.paralleluniverse.strands.queues.CircularBuffer

newConsumer() - Method in class co.paralleluniverse.strands.queues.CircularDoubleBuffer

newConsumer() - Method in class co.paralleluniverse.strands.queues.CircularFloatBuffer

newConsumer() - Method in class co.paralleluniverse.strands.queues.CircularIntBuffer

newConsumer() - Method in class co.paralleluniverse.strands.queues.CircularLongBuffer

newConsumer() - Method in class co.paralleluniverse.strands.queues.CircularObjectBuffer

newDefaultSerializer(Class) - Method in class co.paralleluniverse.io.serialization.kryo.ReplaceableObjectKryo

newDoubleChannel(int, Channels.OverflowPolicy, boolean, boolean) - Static method in class co.paralleluniverse.strands.channels.Channels

Creates a new primitive double channel with the given properties.

newDoubleChannel(int, Channels.OverflowPolicy) - Static method in class co.paralleluniverse.strands.channels.Channels

Creates a new primitive double channel with the given mailbox size and Channels.OverflowPolicy, with other properties set to their default values.

newDoubleChannel(int) - Static method in class co.paralleluniverse.strands.channels.Channels

Creates a new primitive double channel with the given mailbox size with other properties set to their default values.

newFiber(SuspendableCallable<T>) - Method in interface co.paralleluniverse.fibers.FiberFactory

newFiber(SuspendableCallable<T>) - Method in class co.paralleluniverse.fibers.FiberScheduler

newFloatChannel(int, Channels.OverflowPolicy, boolean, boolean) - Static method in class co.paralleluniverse.strands.channels.Channels

Creates a new primitive float channel with the given properties.

newFloatChannel(int, Channels.OverflowPolicy) - Static method in class co.paralleluniverse.strands.channels.Channels

Creates a new primitive float channel with the given mailbox size and Channels.OverflowPolicy, with other properties set to their default values.

newFloatChannel(int) - Static method in class co.paralleluniverse.strands.channels.Channels

Creates a new primitive float channel with the given mailbox size with other properties set to their default values.

newInstance() - Static method in class co.paralleluniverse.io.serialization.Serialization

newIntChannel(int, Channels.OverflowPolicy, boolean, boolean) - Static method in class co.paralleluniverse.strands.channels.Channels

Creates a new primitive int channel with the given properties.

newIntChannel(int, Channels.OverflowPolicy) - Static method in class co.paralleluniverse.strands.channels.Channels

Creates a new primitive int channel with the given mailbox size and Channels.OverflowPolicy, with other properties set to their default values.

newIntChannel(int) - Static method in class co.paralleluniverse.strands.channels.Channels

Creates a new primitive int channel with the given mailbox size with other properties set to their default values.

newKryo() - Static method in class co.paralleluniverse.io.serialization.kryo.KryoUtil

newLongChannel(int, Channels.OverflowPolicy, boolean, boolean) - Static method in class co.paralleluniverse.strands.channels.Channels

Creates a new primitive long channel with the given properties.

newLongChannel(int, Channels.OverflowPolicy) - Static method in class co.paralleluniverse.strands.channels.Channels

Creates a new primitive long channel with the given mailbox size and Channels.OverflowPolicy, with other properties set to their default values.

newLongChannel(int) - Static method in class co.paralleluniverse.strands.channels.Channels

Creates a new primitive long channel with the given mailbox size with other properties set to their default values.

newResource() - Method in class co.paralleluniverse.common.benchmark.Striped

newStrand(SuspendableCallable<?>) - Method in class co.paralleluniverse.fibers.FiberScheduler

newStrand(SuspendableCallable<?>) - Method in interface co.paralleluniverse.strands.StrandFactory

newTaskFor(Runnable, T) - Method in class co.paralleluniverse.concurrent.util.AbstractCompletableExecutorService

newTaskFor(Callable<T>) - Method in class co.paralleluniverse.concurrent.util.AbstractCompletableExecutorService

newThread(ForkJoinPool) - Method in class co.paralleluniverse.concurrent.forkjoin.ExtendedForkJoinWorkerFactory

newTickerConsumerFor(Channel<Message>) - Static method in class co.paralleluniverse.strands.channels.Channels

Creates a ReceivePort that can be used to receive messages from a a ticker channel: a channel of bounded capacity and the DISPLACE overflow policy.

newTickerConsumerFor(IntChannel) - Static method in class co.paralleluniverse.strands.channels.Channels

Creates an IntReceivePort that can be used to receive messages from a a ticker channel: a channel of bounded capacity and the DISPLACE overflow policy.

newTickerConsumerFor(LongChannel) - Static method in class co.paralleluniverse.strands.channels.Channels

Creates a LongReceivePort that can be used to receive messages from a a ticker channel: a channel of bounded capacity and the DISPLACE overflow policy.

newTickerConsumerFor(FloatChannel) - Static method in class co.paralleluniverse.strands.channels.Channels

Creates a FloatReceivePort that can be used to receive messages from a a ticker channel: a channel of bounded capacity and the DISPLACE overflow policy.

newTickerConsumerFor(DoubleChannel) - Static method in class co.paralleluniverse.strands.channels.Channels

Creates a DoubleReceivePort that can be used to receive messages from a a ticker channel: a channel of bounded capacity and the DISPLACE overflow policy.

next(int) - Method in class co.paralleluniverse.strands.StrandLocalRandom

nextDouble(double) - Method in class co.paralleluniverse.strands.StrandLocalRandom

Returns a pseudorandom, uniformly distributed double value between 0 (inclusive) and the specified value (exclusive).

nextDouble(double, double) - Method in class co.paralleluniverse.strands.StrandLocalRandom

Returns a pseudorandom, uniformly distributed value between the given least value (inclusive) and bound (exclusive).

nextInt(int, int) - Method in class co.paralleluniverse.strands.StrandLocalRandom

Returns a pseudorandom, uniformly distributed value between the given least value (inclusive) and bound (exclusive).

nextLong(long) - Method in class co.paralleluniverse.strands.StrandLocalRandom

Returns a pseudorandom, uniformly distributed value between 0 (inclusive) and the specified value (exclusive).

nextLong(long, long) - Method in class co.paralleluniverse.strands.StrandLocalRandom

Returns a pseudorandom, uniformly distributed value between the given least value (inclusive) and bound (exclusive).

nextMethodEntry() - Method in class co.paralleluniverse.fibers.Stack

called at the beginning of a method

nextNonEquivalentValue(long) - Method in class co.paralleluniverse.common.benchmark.StripedHistogram

Get the next value that is not equivalent to the given value within the histogram's resolution.

nonAntExecute(String[]) - Method in class co.paralleluniverse.fibers.instrument.OldSuspendablesScanner

NoopFibersMonitor - Class in co.paralleluniverse.fibers

NoopFibersMonitor() - Constructor for class co.paralleluniverse.fibers.NoopFibersMonitor

NORM_PRIORITY - Static variable in class co.paralleluniverse.strands.Strand

The default priority that is assigned to a strand.

numOfElements() - Method in class co.paralleluniverse.common.benchmark.StripedLongTimeSeries.ThreadRecorder

numOfElements() - Method in class co.paralleluniverse.common.benchmark.StripedTimeSeries.ThreadRecorder

numOfElements() - Method in class co.paralleluniverse.common.monitoring.FlightRecorder.ThreadRecorder

O

Objects - Class in co.paralleluniverse.common.util

of(Throwable) - Static method in class co.paralleluniverse.common.util.ExtendedStackTrace

of(SuspendExecution) - Static method in exception co.paralleluniverse.fibers.RuntimeSuspendExecution

of(Object) - Static method in class co.paralleluniverse.strands.Strand

of(Thread) - Static method in class co.paralleluniverse.strands.Strand

Returns a strand representing the given thread.

of(Fiber) - Static method in class co.paralleluniverse.strands.Strand

Returns a strand representing the given fiber.

offer(E) - Method in class co.paralleluniverse.concurrent.util.ConcurrentSkipListPriorityQueue

offer(E) - Method in class co.paralleluniverse.concurrent.util.DelayQueue

Inserts the specified element into this delay queue.

offer(E, long, TimeUnit) - Method in class co.paralleluniverse.concurrent.util.DelayQueue

Inserts the specified element into this delay queue.

offer(E) - Method in class co.paralleluniverse.concurrent.util.SingleConsumerNonblockingProducerQueue

offer(E, long, TimeUnit) - Method in class co.paralleluniverse.concurrent.util.SingleConsumerNonblockingProducerQueue

offer(E) - Method in class co.paralleluniverse.strands.queues.SingleConsumerQueue

OldSuspendablesScanner - Class in co.paralleluniverse.fibers.instrument

OldSuspendablesScanner() - Constructor for class co.paralleluniverse.fibers.instrument.OldSuspendablesScanner

onAdvance(int, int) - Method in class co.paralleluniverse.strands.concurrent.Phaser

Overridable method to perform an action upon impending phase advance, and to control termination.

onCompletion(boolean) - Method in class co.paralleluniverse.concurrent.forkjoin.ParkableForkJoinTask

onCompletion() - Method in class co.paralleluniverse.fibers.Fiber

onException(Throwable) - Method in class co.paralleluniverse.concurrent.forkjoin.ParkableForkJoinTask

onException(Throwable) - Method in class co.paralleluniverse.fibers.Fiber

onExec() - Method in class co.paralleluniverse.concurrent.forkjoin.ParkableForkJoinTask

onIdle() - Method in class co.paralleluniverse.fibers.FiberForkJoinScheduler

onParked(boolean) - Method in class co.paralleluniverse.concurrent.forkjoin.ParkableForkJoinTask

onParked() - Method in class co.paralleluniverse.fibers.Fiber

onReceive(Message) - Method in interface co.paralleluniverse.strands.channels.SelectReceiveListener

onResume() - Method in class co.paralleluniverse.fibers.Fiber

onSend() - Method in interface co.paralleluniverse.strands.channels.SelectSendListener

open(ExecutorService, Path, Set<? extends OpenOption>, FileAttribute<?>...) - Static method in class co.paralleluniverse.fibers.io.FiberFileChannel

Opens or creates a file for reading and/or writing, returning a file channel to access the file.

open(Path, OpenOption...) - Static method in class co.paralleluniverse.fibers.io.FiberFileChannel

Opens or creates a file for reading and/or writing, returning a file channel to access the file.

open(ChannelGroup) - Static method in class co.paralleluniverse.fibers.io.FiberServerSocketChannel

Opens an server-socket channel.

open() - Static method in class co.paralleluniverse.fibers.io.FiberServerSocketChannel

Opens a server-socket channel.

open(ChannelGroup) - Static method in class co.paralleluniverse.fibers.io.FiberSocketChannel

Opens a socket channel.

open() - Static method in class co.paralleluniverse.fibers.io.FiberSocketChannel

Opens a socket channel.

open(SocketAddress) - Static method in class co.paralleluniverse.fibers.io.FiberSocketChannel

Opens a socket channel and connects it to a remote address.

open(ChannelGroup, SocketAddress) - Static method in class co.paralleluniverse.fibers.io.FiberSocketChannel

Opens a socket channel and connects it to a remote address.

OwnedSynchronizer - Class in co.paralleluniverse.strands

OwnedSynchronizer(Object) - Constructor for class co.paralleluniverse.strands.OwnedSynchronizer

owns(AbstractQueuedLongSynchronizer.ConditionObject) - Method in class co.paralleluniverse.strands.concurrent.AbstractQueuedLongSynchronizer

Queries whether the given ConditionObject uses this synchronizer as its lock.

owns(AbstractQueuedSynchronizer.ConditionObject) - Method in class co.paralleluniverse.strands.concurrent.AbstractQueuedSynchronizer

Queries whether the given ConditionObject uses this synchronizer as its lock.

P

Pair<First,Second> - Class in co.paralleluniverse.common.util

Pair(First, Second) - Constructor for class co.paralleluniverse.common.util.Pair

PARK - Static variable in class co.paralleluniverse.concurrent.forkjoin.ParkableForkJoinTask

park(Object) - Method in class co.paralleluniverse.concurrent.forkjoin.ParkableForkJoinTask

park(Object, boolean) - Method in class co.paralleluniverse.concurrent.forkjoin.ParkableForkJoinTask

park(Object, long, TimeUnit) - Static method in class co.paralleluniverse.fibers.Fiber

park(Object) - Static method in class co.paralleluniverse.fibers.Fiber

park(long, TimeUnit) - Static method in class co.paralleluniverse.fibers.Fiber

park() - Static method in class co.paralleluniverse.fibers.Fiber

park() - Static method in class co.paralleluniverse.strands.Strand

Disables the current strand for scheduling purposes unless the permit is available.

park(Object) - Static method in class co.paralleluniverse.strands.Strand

Disables the current strand for scheduling purposes unless the permit is available.

ParkableForkJoinTask<V> - Class in co.paralleluniverse.concurrent.forkjoin

ParkableForkJoinTask() - Constructor for class co.paralleluniverse.concurrent.forkjoin.ParkableForkJoinTask

ParkableForkJoinTask.Park - Error in co.paralleluniverse.concurrent.forkjoin

parkAndSerialize(FiberWriter) - Static method in class co.paralleluniverse.fibers.Fiber

Parks the fiber and allows the given callback to serialize it.

parkAndUnpark(Fiber) - Static method in class co.paralleluniverse.fibers.Fiber

parkAndUnpark(Fiber, Object) - Static method in class co.paralleluniverse.fibers.Fiber

parkAndUnpark(Strand, Object) - Static method in class co.paralleluniverse.strands.Strand

parkAndUnpark(Strand) - Static method in class co.paralleluniverse.strands.Strand

PARKED - Static variable in class co.paralleluniverse.concurrent.forkjoin.ParkableForkJoinTask

PARKING - Static variable in class co.paralleluniverse.concurrent.forkjoin.ParkableForkJoinTask

parking(boolean) - Method in class co.paralleluniverse.concurrent.forkjoin.ParkableForkJoinTask

parkNanos(long) - Static method in class co.paralleluniverse.strands.Strand

Disables the current strand for thread scheduling purposes, for up to the specified waiting time, unless the permit is available.

parkNanos(Object, long) - Static method in class co.paralleluniverse.strands.Strand

Disables the current strand for thread scheduling purposes, for up to the specified waiting time, unless the permit is available.

parkUntil(Object, long) - Static method in class co.paralleluniverse.strands.Strand

Disables the current strand for scheduling purposes, until the specified deadline, unless the permit is available.

payload - Variable in class co.paralleluniverse.common.monitoring.FlightRecorder.Record

peek() - Method in class co.paralleluniverse.concurrent.util.ConcurrentSkipListPriorityQueue

peek() - Method in class co.paralleluniverse.concurrent.util.DelayQueue

Retrieves, but does not remove, the head of this queue, or returns null if this queue is empty.

peek() - Method in class co.paralleluniverse.concurrent.util.SingleConsumerNonblockingProducerQueue

peek() - Method in class co.paralleluniverse.strands.queues.SingleConsumerQueue

peekFirst() - Method in class co.paralleluniverse.concurrent.util.ConcurrentSkipListSet

peekLast() - Method in class co.paralleluniverse.concurrent.util.ConcurrentSkipListPriorityQueue

peekLast() - Method in class co.paralleluniverse.concurrent.util.ConcurrentSkipListSet

Phaser - Class in co.paralleluniverse.strands.concurrent

A reusable synchronization barrier, similar in functionality to CyclicBarrier and CountDownLatch but supporting more flexible usage.

Phaser() - Constructor for class co.paralleluniverse.strands.concurrent.Phaser

Creates a new phaser with no initially registered parties, no parent, and initial phase number 0.

Phaser(int) - Constructor for class co.paralleluniverse.strands.concurrent.Phaser

Creates a new phaser with the given number of registered unarrived parties, no parent, and initial phase number 0.

Phaser(Phaser) - Constructor for class co.paralleluniverse.strands.concurrent.Phaser

Equivalent to Phaser(parent, 0).

Phaser(Phaser, int) - Constructor for class co.paralleluniverse.strands.concurrent.Phaser

Creates a new phaser with the given parent and number of registered unarrived parties.

Pipeline<S,T> - Class in co.paralleluniverse.strands.channels.transfer

Pipeline(ReceivePort<? extends S>, SendPort<? super T>, SuspendableAction2<S, Channel<T>>, int, boolean, SuspendableCallable<Channel<T>>, StrandFactory) - Constructor for class co.paralleluniverse.strands.channels.transfer.Pipeline

Pipeline(ReceivePort<? extends S>, SendPort<? super T>, SuspendableAction2<S, Channel<T>>, int, boolean, SuspendableCallable<Channel<T>>) - Constructor for class co.paralleluniverse.strands.channels.transfer.Pipeline

Pipeline(ReceivePort<? extends S>, SendPort<? super T>, SuspendableAction2<S, Channel<T>>, int, boolean) - Constructor for class co.paralleluniverse.strands.channels.transfer.Pipeline

Pipeline(ReceivePort<? extends S>, SendPort<? super T>, SuspendableAction2<S, Channel<T>>, int) - Constructor for class co.paralleluniverse.strands.channels.transfer.Pipeline

Pipeline(ReceivePort<? extends S>, SendPort<? super T>, SuspendableAction2<S, Channel<T>>) - Constructor for class co.paralleluniverse.strands.channels.transfer.Pipeline

poll() - Method in class co.paralleluniverse.concurrent.util.ConcurrentSkipListPriorityQueue

poll() - Method in class co.paralleluniverse.concurrent.util.DelayQueue

Retrieves and removes the head of this queue, or returns null if this queue has no elements with an expired delay.

poll(long, TimeUnit) - Method in class co.paralleluniverse.concurrent.util.DelayQueue

Retrieves and removes the head of this queue, waiting if necessary until an element with an expired delay is available on this queue, or the specified wait time expires.

poll() - Method in class co.paralleluniverse.concurrent.util.SingleConsumerNonblockingProducerDelayQueue

poll(long, TimeUnit) - Method in class co.paralleluniverse.concurrent.util.SingleConsumerNonblockingProducerDelayQueue

poll(long, TimeUnit) - Method in class co.paralleluniverse.concurrent.util.SingleConsumerNonblockingProducerQueue

poll() - Method in class co.paralleluniverse.concurrent.util.SingleConsumerNonblockingProducerQueue

poll() - Method in class co.paralleluniverse.strands.queues.ArrayQueue

poll() - Method in interface co.paralleluniverse.strands.queues.BasicQueue

poll() - Method in class co.paralleluniverse.strands.queues.BoxQueue

poll() - Method in class co.paralleluniverse.strands.queues.CircularBuffer.Consumer

poll() - Method in class co.paralleluniverse.strands.queues.CircularBuffer

poll() - Method in class co.paralleluniverse.strands.queues.SingleConsumerQueue

poll0() - Method in class co.paralleluniverse.strands.queues.CircularBuffer.Consumer

pollDouble() - Method in interface co.paralleluniverse.strands.queues.BasicSingleConsumerDoubleQueue

pollDouble() - Method in class co.paralleluniverse.strands.queues.CircularDoubleBuffer.DoubleConsumer

pollDouble() - Method in class co.paralleluniverse.strands.queues.CircularDoubleBuffer

pollDouble() - Method in class co.paralleluniverse.strands.queues.SingleConsumerArrayDoubleQueue

pollDouble() - Method in class co.paralleluniverse.strands.queues.SingleConsumerLinkedArrayDoubleQueue

pollDouble() - Method in class co.paralleluniverse.strands.queues.SingleConsumerLinkedDoubleQueue

pollFirst() - Method in class co.paralleluniverse.concurrent.util.ConcurrentSkipListSet

pollFloat() - Method in interface co.paralleluniverse.strands.queues.BasicSingleConsumerFloatQueue

pollFloat() - Method in class co.paralleluniverse.strands.queues.CircularFloatBuffer.FloatConsumer

pollFloat() - Method in class co.paralleluniverse.strands.queues.CircularFloatBuffer

pollFloat() - Method in class co.paralleluniverse.strands.queues.SingleConsumerArrayFloatQueue

pollFloat() - Method in class co.paralleluniverse.strands.queues.SingleConsumerLinkedArrayFloatQueue

pollFloat() - Method in class co.paralleluniverse.strands.queues.SingleConsumerLinkedFloatQueue

pollInt() - Method in interface co.paralleluniverse.strands.queues.BasicSingleConsumerIntQueue

pollInt() - Method in class co.paralleluniverse.strands.queues.CircularIntBuffer.IntConsumer

pollInt() - Method in class co.paralleluniverse.strands.queues.CircularIntBuffer

pollInt() - Method in class co.paralleluniverse.strands.queues.SingleConsumerArrayIntQueue

pollInt() - Method in class co.paralleluniverse.strands.queues.SingleConsumerLinkedArrayIntQueue

pollInt() - Method in class co.paralleluniverse.strands.queues.SingleConsumerLinkedIntQueue

pollLast() - Method in class co.paralleluniverse.concurrent.util.ConcurrentSkipListSet

pollLong() - Method in interface co.paralleluniverse.strands.queues.BasicSingleConsumerLongQueue

pollLong() - Method in class co.paralleluniverse.strands.queues.CircularLongBuffer.LongConsumer

pollLong() - Method in class co.paralleluniverse.strands.queues.CircularLongBuffer

pollLong() - Method in class co.paralleluniverse.strands.queues.SingleConsumerArrayLongQueue

pollLong() - Method in class co.paralleluniverse.strands.queues.SingleConsumerLinkedArrayLongQueue

pollLong() - Method in class co.paralleluniverse.strands.queues.SingleConsumerLinkedLongQueue

popMethod(int) - Method in class co.paralleluniverse.fibers.Stack

Port<Message> - Interface in co.paralleluniverse.strands.channels

An empty super-interface of SendPort and ReceivePort extend.

port() - Method in class co.paralleluniverse.strands.channels.SelectAction

Returns the channel for this operation.

PortAutoCloseable - Interface in co.paralleluniverse.strands.channels

position() - Method in class co.paralleluniverse.fibers.io.FiberFileChannel

position(long) - Method in class co.paralleluniverse.fibers.io.FiberFileChannel

postRestore() - Method in class co.paralleluniverse.fibers.Stack

preemptionPoint(int) - Method in class co.paralleluniverse.fibers.Stack

PREFIX - Static variable in class co.paralleluniverse.fibers.instrument.SimpleSuspendableClassifier

premain(String, Instrumentation) - Static method in class co.paralleluniverse.fibers.instrument.JavaAgent

prepark() - Method in class co.paralleluniverse.fibers.FiberAsync

Called by the fiber if this `FiberAsync` is in immediate-exec mode, immediately before attempting to block while running in the callback's thread.

primitiveToWrapper(Class<?>) - Static method in class co.paralleluniverse.common.reflection.ReflectionUtil

PRINT_WARNINGS_ON_UNSERIALIZABLE_THREAD_LOCAL - Static variable in class co.paralleluniverse.fibers.ThreadLocalSerializer

printStackTrace(int, PrintStream) - Static method in class co.paralleluniverse.common.util.Debug

printStackTrace(int, PrintWriter) - Static method in class co.paralleluniverse.common.util.Debug

printStackTrace(StackTraceElement[], PrintStream) - Static method in class co.paralleluniverse.strands.Strand

This utility method prints a stack-trace into a PrintStream

printStackTrace(StackTraceElement[], PrintWriter) - Static method in class co.paralleluniverse.strands.Strand

This utility method prints a stack-trace into a PrintWriter

ProcessUtil - Class in co.paralleluniverse.common.util

ProcessUtil() - Constructor for class co.paralleluniverse.common.util.ProcessUtil

ProducerException - Exception in co.paralleluniverse.strands.channels

This exception is thrown by a ReceivePort's receive or tryReceive methods if the channel has been closed with an exception.

ProducerException(Throwable) - Constructor for exception co.paralleluniverse.strands.channels.ProducerException

Profile - Annotation Type in co.paralleluniverse.common.monitoring

provider() - Method in class co.paralleluniverse.fibers.io.FiberServerSocketChannel

Returns the IO provider that created this channel.

provider() - Method in class co.paralleluniverse.fibers.io.FiberSocketChannel

Returns the IO provider that created this channel.

push(int, Stack, int) - Static method in class co.paralleluniverse.fibers.Stack

push(float, Stack, int) - Static method in class co.paralleluniverse.fibers.Stack

push(long, Stack, int) - Static method in class co.paralleluniverse.fibers.Stack

push(double, Stack, int) - Static method in class co.paralleluniverse.fibers.Stack

push(Object, Stack, int) - Static method in class co.paralleluniverse.fibers.Stack

pushMethod(int, int) - Method in class co.paralleluniverse.fibers.Stack

Called before a method is called.

put(E) - Method in class co.paralleluniverse.concurrent.util.DelayQueue

Inserts the specified element into this delay queue.

put(E) - Method in class co.paralleluniverse.concurrent.util.SingleConsumerNonblockingProducerQueue

putSuspendablesAndSupers(Collection<String>, Collection<String>) - Method in class co.paralleluniverse.fibers.instrument.SuspendablesScanner

Q

QuasarInstrumentor - Class in co.paralleluniverse.fibers.instrument

QuasarInstrumentor() - Constructor for class co.paralleluniverse.fibers.instrument.QuasarInstrumentor

QuasarInstrumentor(boolean) - Constructor for class co.paralleluniverse.fibers.instrument.QuasarInstrumentor

QuasarURLClassLoader - Class in co.paralleluniverse.fibers.instrument

QuasarURLClassLoader(URL[], ClassLoader) - Constructor for class co.paralleluniverse.fibers.instrument.QuasarURLClassLoader

QuasarURLClassLoader(URL[]) - Constructor for class co.paralleluniverse.fibers.instrument.QuasarURLClassLoader

QuasarURLClassLoader(URL[], ClassLoader, URLStreamHandlerFactory) - Constructor for class co.paralleluniverse.fibers.instrument.QuasarURLClassLoader

QuasarURLClassLoaderHelper - Class in co.paralleluniverse.fibers.instrument

QuasarURLClassLoaderHelper(URLClassLoader) - Constructor for class co.paralleluniverse.fibers.instrument.QuasarURLClassLoaderHelper

queue() - Method in class co.paralleluniverse.strands.channels.QueueDoubleChannel

queue() - Method in class co.paralleluniverse.strands.channels.QueueFloatChannel

queue() - Method in class co.paralleluniverse.strands.channels.QueueIntChannel

queue() - Method in class co.paralleluniverse.strands.channels.QueueLongChannel

queue() - Method in class co.paralleluniverse.strands.channels.QueuePrimitiveChannel

queue() - Method in class co.paralleluniverse.strands.channels.SingleConsumerQueueChannel

QueueCapacityExceededException - Exception in co.paralleluniverse.strands.queues

QueueCapacityExceededException() - Constructor for exception co.paralleluniverse.strands.queues.QueueCapacityExceededException

QueueChannel<Message> - Class in co.paralleluniverse.strands.channels

QueueChannel(BasicQueue<Message>, Channels.OverflowPolicy, boolean) - Constructor for class co.paralleluniverse.strands.channels.QueueChannel

QueueChannel(BasicQueue<Message>, Channels.OverflowPolicy, boolean, boolean) - Constructor for class co.paralleluniverse.strands.channels.QueueChannel

QueueDoubleChannel - Class in co.paralleluniverse.strands.channels

QueueDoubleChannel(BasicSingleConsumerDoubleQueue, Channels.OverflowPolicy) - Constructor for class co.paralleluniverse.strands.channels.QueueDoubleChannel

QueueFloatChannel - Class in co.paralleluniverse.strands.channels

QueueFloatChannel(BasicSingleConsumerFloatQueue, Channels.OverflowPolicy) - Constructor for class co.paralleluniverse.strands.channels.QueueFloatChannel

QueueIntChannel - Class in co.paralleluniverse.strands.channels

QueueIntChannel(BasicSingleConsumerIntQueue, Channels.OverflowPolicy) - Constructor for class co.paralleluniverse.strands.channels.QueueIntChannel

QueueIterator<E> - Interface in co.paralleluniverse.strands.queues

QueueLongChannel - Class in co.paralleluniverse.strands.channels

QueueLongChannel(BasicSingleConsumerLongQueue, Channels.OverflowPolicy) - Constructor for class co.paralleluniverse.strands.channels.QueueLongChannel

QueueObjectChannel<Message> - Class in co.paralleluniverse.strands.channels

QueueObjectChannel(BasicQueue<Message>, Channels.OverflowPolicy, boolean, boolean) - Constructor for class co.paralleluniverse.strands.channels.QueueObjectChannel

QueuePrimitiveChannel<Message> - Class in co.paralleluniverse.strands.channels

Single consumer!

QueuePrimitiveChannel(BasicSingleConsumerQueue<Message>, Channels.OverflowPolicy) - Constructor for class co.paralleluniverse.strands.channels.QueuePrimitiveChannel

R

read(ByteBuffer, long) - Method in class co.paralleluniverse.fibers.io.FiberFileChannel

Reads a sequence of bytes from this channel into the given buffer, starting at the given file position.

read(ByteBuffer) - Method in class co.paralleluniverse.fibers.io.FiberFileChannel

read(ByteBuffer[]) - Method in class co.paralleluniverse.fibers.io.FiberFileChannel

Reads a sequence of bytes from this channel into the given buffers.

read(ByteBuffer[], int, int) - Method in class co.paralleluniverse.fibers.io.FiberFileChannel

read(ByteBuffer[], int, int, long, TimeUnit) - Method in class co.paralleluniverse.fibers.io.FiberSocketChannel

Reads a sequence of bytes from this channel into a subsequence of the given buffers.

read(ByteBuffer, long, TimeUnit) - Method in class co.paralleluniverse.fibers.io.FiberSocketChannel

Reads a sequence of bytes from this channel into the given buffer.

read(ByteBuffer[], int, int) - Method in class co.paralleluniverse.fibers.io.FiberSocketChannel

read(ByteBuffer[]) - Method in class co.paralleluniverse.fibers.io.FiberSocketChannel

read(ByteBuffer) - Method in class co.paralleluniverse.fibers.io.FiberSocketChannel

read(Kryo, Input, Class<ThreadLocal<?>>) - Method in class co.paralleluniverse.fibers.ThreadLocalSerializer

read(byte[]) - Method in interface co.paralleluniverse.io.serialization.ByteArraySerializer

read(byte[], int) - Method in interface co.paralleluniverse.io.serialization.ByteArraySerializer

read(InputStream) - Method in interface co.paralleluniverse.io.serialization.IOStreamSerializer

read(byte[]) - Method in class co.paralleluniverse.io.serialization.JDKSerializer

read(byte[], int) - Method in class co.paralleluniverse.io.serialization.JDKSerializer

read(InputStream) - Method in class co.paralleluniverse.io.serialization.JDKSerializer

read(Kryo, Input, Class<T>) - Method in class co.paralleluniverse.io.serialization.kryo.ExternalizableKryoSerializer

read(byte[]) - Method in class co.paralleluniverse.io.serialization.kryo.KryoSerializer

read(byte[], int) - Method in class co.paralleluniverse.io.serialization.kryo.KryoSerializer

read(byte[], Class<T>) - Method in class co.paralleluniverse.io.serialization.kryo.KryoSerializer

read(byte[], int, Class<T>) - Method in class co.paralleluniverse.io.serialization.kryo.KryoSerializer

read(InputStream) - Method in class co.paralleluniverse.io.serialization.kryo.KryoSerializer

read(InputStream, Class<T>) - Method in class co.paralleluniverse.io.serialization.kryo.KryoSerializer

read(byte[]) - Method in class co.paralleluniverse.io.serialization.Serialization

read(byte[], int) - Method in class co.paralleluniverse.io.serialization.Serialization

read(InputStream) - Method in class co.paralleluniverse.io.serialization.Serialization

readClassAndObject(Input) - Method in class co.paralleluniverse.io.serialization.kryo.ReplaceableObjectKryo

readLock() - Method in class co.paralleluniverse.strands.concurrent.ReentrantReadWriteLock

ReadLock(ReentrantReadWriteLock) - Constructor for class co.paralleluniverse.strands.concurrent.ReentrantReadWriteLock.ReadLock

Constructor for use by subclasses

readLock() - Method in class co.paralleluniverse.strands.concurrent.StampedLock

Non-exclusively acquires the lock, blocking if necessary until available.

readLockInterruptibly() - Method in class co.paralleluniverse.strands.concurrent.StampedLock

Non-exclusively acquires the lock, blocking if necessary until available or the current strand is interrupted.

readObject(Input, Class<T>, Serializer) - Method in class co.paralleluniverse.io.serialization.kryo.ReplaceableObjectKryo

readObject(Input, Class<T>) - Method in class co.paralleluniverse.io.serialization.kryo.ReplaceableObjectKryo

readObjectOrNull(Input, Class<T>) - Method in class co.paralleluniverse.io.serialization.kryo.ReplaceableObjectKryo

readObjectOrNull(Input, Class<T>, Serializer) - Method in class co.paralleluniverse.io.serialization.kryo.ReplaceableObjectKryo

readSuspandables() - Method in class co.paralleluniverse.fibers.instrument.OldSuspendablesScanner

receive() - Method in class co.paralleluniverse.strands.channels.DelegatingReceivePort

receive(long, TimeUnit) - Method in class co.paralleluniverse.strands.channels.DelegatingReceivePort

receive(Timeout) - Method in class co.paralleluniverse.strands.channels.DelegatingReceivePort

receive() - Method in class co.paralleluniverse.strands.channels.FlatMappingReceivePort

receive(long, TimeUnit) - Method in class co.paralleluniverse.strands.channels.FlatMappingReceivePort

receive(Timeout) - Method in class co.paralleluniverse.strands.channels.FlatMappingReceivePort

receive() - Method in class co.paralleluniverse.strands.channels.QueueChannel

receive(long, TimeUnit) - Method in class co.paralleluniverse.strands.channels.QueueChannel

receive(Timeout) - Method in class co.paralleluniverse.strands.channels.QueueChannel

receive() - Method in interface co.paralleluniverse.strands.channels.ReceivePort

Retrieves a message from the channels, possibly blocking until one becomes available.

receive(long, TimeUnit) - Method in interface co.paralleluniverse.strands.channels.ReceivePort

Retrieves a message from the channels, possibly blocking until one becomes available, but no longer than the specified timeout.

receive(Timeout) - Method in interface co.paralleluniverse.strands.channels.ReceivePort

Retrieves a message from the channels, possibly blocking until one becomes available, but no longer than the specified timeout.

receive() - Method in class co.paralleluniverse.strands.channels.ReceivePortGroup

receive(Timeout) - Method in class co.paralleluniverse.strands.channels.ReceivePortGroup

receive(long, TimeUnit) - Method in class co.paralleluniverse.strands.channels.ReceivePortGroup

receive(ReceivePort<? extends Message>) - Static method in class co.paralleluniverse.strands.channels.Selector

Creates a SelectAction for a receive operation

receive(ReceivePort<? extends Message>, SelectReceiveListener<Message>) - Static method in class co.paralleluniverse.strands.channels.Selector

Creates a SelectAction for a receive operation

receive() - Method in class co.paralleluniverse.strands.channels.SingleConsumerQueueChannel

receive(long, TimeUnit) - Method in class co.paralleluniverse.strands.channels.SingleConsumerQueueChannel

receive() - Method in class co.paralleluniverse.strands.channels.ThreadReceivePort

Retrieves a message from the channels, possibly blocking until one becomes available.

receive(long, TimeUnit) - Method in class co.paralleluniverse.strands.channels.ThreadReceivePort

Retrieves a message from the channels, possibly blocking until one becomes available, but no longer than the specified timeout.

receive() - Method in class co.paralleluniverse.strands.channels.TickerChannelConsumer

receive(long, TimeUnit) - Method in class co.paralleluniverse.strands.channels.TickerChannelConsumer

receive(Timeout) - Method in class co.paralleluniverse.strands.channels.TickerChannelConsumer

receive() - Method in class co.paralleluniverse.strands.channels.TransferChannel

receive(long, TimeUnit) - Method in class co.paralleluniverse.strands.channels.TransferChannel

receive(Timeout) - Method in class co.paralleluniverse.strands.channels.TransferChannel

receive() - Method in class co.paralleluniverse.strands.channels.ZippingReceivePort

receive(long, TimeUnit) - Method in class co.paralleluniverse.strands.channels.ZippingReceivePort

receive(Timeout) - Method in class co.paralleluniverse.strands.channels.ZippingReceivePort

receive() - Method in class co.paralleluniverse.strands.dataflow.ValChannel

receive(long, TimeUnit) - Method in class co.paralleluniverse.strands.dataflow.ValChannel

receive(Timeout) - Method in class co.paralleluniverse.strands.dataflow.ValChannel

receiveDouble() - Method in interface co.paralleluniverse.strands.channels.DoubleReceivePort

Retrieves a message from the channels, possibly blocking until one becomes available.

receiveDouble(long, TimeUnit) - Method in interface co.paralleluniverse.strands.channels.DoubleReceivePort

Retrieves a message from the channels, possibly blocking until one becomes available, but no longer than the specified timeout.

receiveDouble(Timeout) - Method in interface co.paralleluniverse.strands.channels.DoubleReceivePort

Retrieves a message from the channels, possibly blocking until one becomes available, but no longer than the specified timeout.

receiveDouble() - Method in class co.paralleluniverse.strands.channels.QueueDoubleChannel

receiveDouble(long, TimeUnit) - Method in class co.paralleluniverse.strands.channels.QueueDoubleChannel

receiveDouble(Timeout) - Method in class co.paralleluniverse.strands.channels.QueueDoubleChannel

receiveFloat() - Method in interface co.paralleluniverse.strands.channels.FloatReceivePort

Retrieves a message from the channels, possibly blocking until one becomes available.

receiveFloat(long, TimeUnit) - Method in interface co.paralleluniverse.strands.channels.FloatReceivePort

Retrieves a message from the channels, possibly blocking until one becomes available, but no longer than the specified timeout.

receiveFloat(Timeout) - Method in interface co.paralleluniverse.strands.channels.FloatReceivePort

Retrieves a message from the channels, possibly blocking until one becomes available, but no longer than the specified timeout.

receiveFloat() - Method in class co.paralleluniverse.strands.channels.QueueFloatChannel

receiveFloat(long, TimeUnit) - Method in class co.paralleluniverse.strands.channels.QueueFloatChannel

receiveFloat(Timeout) - Method in class co.paralleluniverse.strands.channels.QueueFloatChannel

receiveFloat() - Method in class co.paralleluniverse.strands.channels.TickerChannelConsumer.TickerChannelFloatConsumer

receiveFloat(long, TimeUnit) - Method in class co.paralleluniverse.strands.channels.TickerChannelConsumer.TickerChannelFloatConsumer

receiveFloat(Timeout) - Method in class co.paralleluniverse.strands.channels.TickerChannelConsumer.TickerChannelFloatConsumer

receiveFromThread() - Method in class co.paralleluniverse.strands.channels.QueueChannel

receiveFromThread(long, TimeUnit) - Method in class co.paralleluniverse.strands.channels.QueueChannel

receiveInt() - Method in interface co.paralleluniverse.strands.channels.IntReceivePort

Retrieves a message from the channels, possibly blocking until one becomes available.

receiveInt(long, TimeUnit) - Method in interface co.paralleluniverse.strands.channels.IntReceivePort

Retrieves a message from the channels, possibly blocking until one becomes available, but no longer than the specified timeout.

receiveInt(Timeout) - Method in interface co.paralleluniverse.strands.channels.IntReceivePort

Retrieves a message from the channels, possibly blocking until one becomes available, but no longer than the specified timeout.

receiveInt() - Method in class co.paralleluniverse.strands.channels.QueueIntChannel

receiveInt(long, TimeUnit) - Method in class co.paralleluniverse.strands.channels.QueueIntChannel

receiveInt(Timeout) - Method in class co.paralleluniverse.strands.channels.QueueIntChannel

receiveInternal(long, TimeUnit) - Method in class co.paralleluniverse.strands.channels.TransferChannel

receiveLong() - Method in interface co.paralleluniverse.strands.channels.LongReceivePort

Retrieves a message from the channels, possibly blocking until one becomes available.

receiveLong(long, TimeUnit) - Method in interface co.paralleluniverse.strands.channels.LongReceivePort

Retrieves a message from the channels, possibly blocking until one becomes available, but no longer than the specified timeout.

receiveLong(Timeout) - Method in interface co.paralleluniverse.strands.channels.LongReceivePort

Retrieves a message from the channels, possibly blocking until one becomes available, but no longer than the specified timeout.

receiveLong() - Method in class co.paralleluniverse.strands.channels.QueueLongChannel

receiveLong(long, TimeUnit) - Method in class co.paralleluniverse.strands.channels.QueueLongChannel

receiveLong(Timeout) - Method in class co.paralleluniverse.strands.channels.QueueLongChannel

ReceivePort<Message> - Interface in co.paralleluniverse.strands.channels

A channel's consumer-side functional interface.

ReceivePort.EOFException - Exception in co.paralleluniverse.strands.channels

ReceivePortGroup<M> - Class in co.paralleluniverse.strands.channels

ReceivePortGroup(Collection<? extends ReceivePort<? extends M>>, boolean) - Constructor for class co.paralleluniverse.strands.channels.ReceivePortGroup

ReceivePortGroup(Collection<? extends ReceivePort<? extends M>>) - Constructor for class co.paralleluniverse.strands.channels.ReceivePortGroup

ReceivePortGroup(ReceivePort<? extends M>...) - Constructor for class co.paralleluniverse.strands.channels.ReceivePortGroup

ReceivePortGroup(boolean) - Constructor for class co.paralleluniverse.strands.channels.ReceivePortGroup

ReceivePortGroup() - Constructor for class co.paralleluniverse.strands.channels.ReceivePortGroup

record(long) - Method in class co.paralleluniverse.common.benchmark.StripedLongTimeSeries

record(long, long) - Method in class co.paralleluniverse.common.benchmark.StripedLongTimeSeries

record(long, long) - Method in class co.paralleluniverse.common.benchmark.StripedLongTimeSeries.ThreadRecorder

record(V) - Method in class co.paralleluniverse.common.benchmark.StripedTimeSeries

record(long, V) - Method in class co.paralleluniverse.common.benchmark.StripedTimeSeries

record(long, V) - Method in class co.paralleluniverse.common.benchmark.StripedTimeSeries.ThreadRecorder

record(int, Object) - Method in class co.paralleluniverse.common.monitoring.FlightRecorder

record(int, Object...) - Method in class co.paralleluniverse.common.monitoring.FlightRecorder

record(int, Object) - Method in class co.paralleluniverse.common.monitoring.FlightRecorder.ThreadRecorder

record(int, Object...) - Method in class co.paralleluniverse.common.monitoring.FlightRecorder.ThreadRecorder

record(int, Object) - Static method in class co.paralleluniverse.common.util.Debug

record(int, Object...) - Static method in class co.paralleluniverse.common.util.Debug

record(String, String) - Static method in class co.paralleluniverse.concurrent.forkjoin.ParkableForkJoinTask

record(String, String, Object) - Static method in class co.paralleluniverse.concurrent.forkjoin.ParkableForkJoinTask

record(String, String, Object, Object) - Static method in class co.paralleluniverse.concurrent.forkjoin.ParkableForkJoinTask

record(String, String, Object, Object, Object) - Static method in class co.paralleluniverse.concurrent.forkjoin.ParkableForkJoinTask

record(String, String, Object, Object, Object, Object) - Static method in class co.paralleluniverse.concurrent.forkjoin.ParkableForkJoinTask

record(String, String, Object, Object, Object, Object, Object) - Static method in class co.paralleluniverse.concurrent.forkjoin.ParkableForkJoinTask

record(int, String, String, String) - Method in class co.paralleluniverse.fibers.Fiber

record(int, String, String, String, Object) - Method in class co.paralleluniverse.fibers.Fiber

record(int, String, String, String, Object, Object) - Method in class co.paralleluniverse.fibers.Fiber

record(int, String, String, String, Object, Object, Object) - Method in class co.paralleluniverse.fibers.Fiber

record(int, String, String, String, Object, Object, Object, Object) - Method in class co.paralleluniverse.fibers.Fiber

record(int, String, String, String, Object, Object, Object, Object, Object) - Method in class co.paralleluniverse.fibers.Fiber

record(int, String, String, String, Object, Object, Object, Object, Object, Object) - Method in class co.paralleluniverse.fibers.Fiber

record(int, String, String, String, Object, Object, Object, Object, Object, Object, Object) - Method in class co.paralleluniverse.fibers.Fiber

record(int, String, String, String, Object...) - Method in class co.paralleluniverse.fibers.Fiber

RECORDER - Static variable in class co.paralleluniverse.concurrent.forkjoin.ParkableForkJoinTask

RECORDER - Static variable in class co.paralleluniverse.strands.channels.QueueChannel

RECORDER - Static variable in class co.paralleluniverse.strands.ConditionSynchronizer

RECORDER - Static variable in class co.paralleluniverse.strands.dataflow.Var

recordingDouble(Object) - Method in class co.paralleluniverse.common.monitoring.FlightRecorderMessage

RecordingDouble - Interface in co.paralleluniverse.common.monitoring

recordsLevel(int) - Method in class co.paralleluniverse.common.monitoring.FlightRecorder.ThreadRecorder

recordValue(long) - Method in class co.paralleluniverse.common.benchmark.StripedHistogram

Record a value in the histogram

recordValue(long, long) - Method in class co.paralleluniverse.common.benchmark.StripedHistogram

Deprecated.

Record a value in the histogram. This deprecated method has identical behavior to recordValueWithExpectedInterval(). It was renamed to avoid ambiguity.

recordValueWithCount(long, long) - Method in class co.paralleluniverse.common.benchmark.StripedHistogram

Record a value in the histogram (adding to the value's current count)

recordValueWithExpectedInterval(long, long) - Method in class co.paralleluniverse.common.benchmark.StripedHistogram

Record a value in the histogram.

redefine(Collection<ClassDefinition>) - Static method in class co.paralleluniverse.fibers.instrument.Retransform

reduce(ReceivePort<S>, Function2<T, S, T>, T) - Static method in class co.paralleluniverse.strands.channels.Channels

Returns a ReceivePort providing messages that are transformed from a given channel by a given reduction function.

reduce(Function2<U, T, U>, U) - Method in class co.paralleluniverse.strands.channels.TransformingReceivePort

Returns a TransformingReceivePort from which receiving messages that are transformed from a given channel by a given reduction function.

reduce(Function2<T, S, T>, T) - Method in class co.paralleluniverse.strands.channels.TransformingSendPort

Returns a TransformingSendPort to which sending messages that are transformed towards a channel by a reduction function.

reducePermits(int) - Method in class co.paralleluniverse.strands.concurrent.Semaphore

Shrinks the number of available permits by the indicated reduction.

reduceSend(SendPort<T>, Function2<T, S, T>, T) - Static method in class co.paralleluniverse.strands.channels.Channels

Returns a SendPort accepting messages that are transformed by a reduction function.

ReentrantLock - Class in co.paralleluniverse.strands.concurrent

A reentrant mutual exclusion Lock with the same basic behavior and semantics as the implicit monitor lock accessed using synchronized methods and statements, but with extended capabilities.

ReentrantLock() - Constructor for class co.paralleluniverse.strands.concurrent.ReentrantLock

Creates an instance of ReentrantLock.

ReentrantLock(boolean) - Constructor for class co.paralleluniverse.strands.concurrent.ReentrantLock

Creates an instance of ReentrantLock with the given fairness policy.

ReentrantReadWriteLock - Class in co.paralleluniverse.strands.concurrent

An implementation of ReadWriteLock supporting similar semantics to ReentrantLock.

ReentrantReadWriteLock() - Constructor for class co.paralleluniverse.strands.concurrent.ReentrantReadWriteLock

Creates a new ReentrantReadWriteLock with default (nonfair) ordering properties.

ReentrantReadWriteLock(boolean) - Constructor for class co.paralleluniverse.strands.concurrent.ReentrantReadWriteLock

Creates a new ReentrantReadWriteLock with the given fairness policy.

ReentrantReadWriteLock.ReadLock - Class in co.paralleluniverse.strands.concurrent

The lock returned by method ReentrantReadWriteLock.readLock().

ReentrantReadWriteLock.WriteLock - Class in co.paralleluniverse.strands.concurrent

The lock returned by method ReentrantReadWriteLock.writeLock().

ReflectionUtil - Class in co.paralleluniverse.common.reflection

refresh() - Method in interface co.paralleluniverse.fibers.FibersMXBean

register(String, T) - Static method in class co.paralleluniverse.common.monitoring.Metrics

register(Class) - Static method in class co.paralleluniverse.io.serialization.kryo.KryoSerializer

register(Class, int) - Static method in class co.paralleluniverse.io.serialization.kryo.KryoSerializer

register(Class, Serializer) - Static method in class co.paralleluniverse.io.serialization.kryo.KryoSerializer

register(Class, Serializer, int) - Static method in class co.paralleluniverse.io.serialization.kryo.KryoSerializer

register(SelectAction<Message>) - Method in class co.paralleluniverse.strands.channels.QueueChannel

register() - Method in class co.paralleluniverse.strands.channels.QueueChannel

register(SelectAction<Message>) - Method in interface co.paralleluniverse.strands.channels.Selectable

register() - Method in class co.paralleluniverse.strands.channels.Selector

register(SelectAction<Message>) - Method in class co.paralleluniverse.strands.channels.TickerChannelConsumer

register() - Method in class co.paralleluniverse.strands.channels.TransferChannel

register(SelectAction<Message>) - Method in class co.paralleluniverse.strands.channels.TransferChannel

register() - Method in class co.paralleluniverse.strands.concurrent.Phaser

Adds a new unarrived party to this phaser.

register() - Method in interface co.paralleluniverse.strands.Condition

register() - Method in class co.paralleluniverse.strands.ConditionSelector

register(SelectAction<V>) - Method in class co.paralleluniverse.strands.dataflow.ValChannel

register() - Method in class co.paralleluniverse.strands.DoneSynchronizer

register() - Method in class co.paralleluniverse.strands.OwnedSynchronizer

register() - Method in class co.paralleluniverse.strands.SimpleConditionSynchronizer

register() - Method in interface co.paralleluniverse.strands.Synchronization

registerAll(MetricSet) - Static method in class co.paralleluniverse.common.monitoring.Metrics

registerCommonClasses(Kryo) - Static method in class co.paralleluniverse.io.serialization.kryo.KryoUtil

registerMBean() - Method in class co.paralleluniverse.common.monitoring.JMXForkJoinPoolMonitor

registerMBean() - Method in class co.paralleluniverse.common.monitoring.SimpleMBean

registerWriteReplace(Class<?>, WriteReplace) - Method in class co.paralleluniverse.io.serialization.JDKSerializer

registry() - Static method in class co.paralleluniverse.common.monitoring.Metrics

reject(Runnable) - Method in class co.paralleluniverse.concurrent.util.ScheduledSingleThreadExecutor

reject(Object) - Method in class co.paralleluniverse.fibers.FiberTimedScheduler

release(long) - Method in class co.paralleluniverse.strands.concurrent.AbstractQueuedLongSynchronizer

Releases in exclusive mode.

release(int) - Method in class co.paralleluniverse.strands.concurrent.AbstractQueuedSynchronizer

Releases in exclusive mode.

release() - Method in class co.paralleluniverse.strands.concurrent.Semaphore

Releases a permit, returning it to the semaphore.

release(int) - Method in class co.paralleluniverse.strands.concurrent.Semaphore

Releases the given number of permits, returning them to the semaphore.

releaseShared(long) - Method in class co.paralleluniverse.strands.concurrent.AbstractQueuedLongSynchronizer

Releases in shared mode.

releaseShared(int) - Method in class co.paralleluniverse.strands.concurrent.AbstractQueuedSynchronizer

Releases in shared mode.

remainingCapacity() - Method in class co.paralleluniverse.concurrent.util.DelayQueue

Always returns Integer.MAX_VALUE because a DelayQueue is not capacity constrained.

remainingCapacity() - Method in class co.paralleluniverse.concurrent.util.SingleConsumerNonblockingProducerQueue

RemoteChannelProxyFactory - Interface in co.paralleluniverse.remote

RemoteChannelProxyFactoryService - Class in co.paralleluniverse.remote

RemoteException - Exception in co.paralleluniverse.remote

RemoteException() - Constructor for exception co.paralleluniverse.remote.RemoteException

RemoteException(String) - Constructor for exception co.paralleluniverse.remote.RemoteException

RemoteException(String, Throwable) - Constructor for exception co.paralleluniverse.remote.RemoteException

RemoteException(Throwable) - Constructor for exception co.paralleluniverse.remote.RemoteException

remove(String) - Static method in class co.paralleluniverse.common.monitoring.Metrics

remove(Object) - Method in class co.paralleluniverse.common.util.ConcurrentSet

remove(int) - Method in class co.paralleluniverse.common.util.Tuple

remove(Object) - Method in class co.paralleluniverse.concurrent.util.ConcurrentSkipListPriorityQueue

remove(Object) - Method in class co.paralleluniverse.concurrent.util.ConcurrentSkipListSet

Removes the specified element from this set if it is present.

remove(Object) - Method in class co.paralleluniverse.concurrent.util.DelayQueue

Removes a single instance of the specified element from this queue, if it is present, whether or not it has expired.

remove(Object) - Method in class co.paralleluniverse.concurrent.util.SingleConsumerNonblockingProducerQueue

remove() - Method in class co.paralleluniverse.fibers.SchedulerLocal

Removes the association between the scheduler-local value and the current scheduler.

remove(T...) - Method in interface co.paralleluniverse.strands.channels.Mix

remove(T...) - Method in class co.paralleluniverse.strands.channels.ReceivePortGroup

remove() - Method in class co.paralleluniverse.strands.queues.SingleConsumerQueue

removeAll(Collection<?>) - Method in class co.paralleluniverse.concurrent.util.ConcurrentSkipListSet

Removes from this set all of its elements that are contained in the specified collection.

removeAll(Collection<?>) - Method in class co.paralleluniverse.concurrent.util.SingleConsumerNonblockingProducerQueue

removeAll(Collection<?>) - Method in class co.paralleluniverse.strands.queues.SingleConsumerQueue

removePerfNotificationListener(NotificationListener) - Method in class co.paralleluniverse.common.monitoring.MonitoringServices

removeStructuralNotificationListener(NotificationListener) - Method in class co.paralleluniverse.common.monitoring.MonitoringServices

ReplaceableObjectKryo - Class in co.paralleluniverse.io.serialization.kryo

A subclass of Kryo that respects java.io.Serializable's writeReplace and readResolve.

ReplaceableObjectKryo() - Constructor for class co.paralleluniverse.io.serialization.kryo.ReplaceableObjectKryo

requestAsync() - Method in class co.paralleluniverse.fibers.FiberAsync

A user of this class must override this method to start the asynchronous operation and register the callback.

requestAsync() - Method in class co.paralleluniverse.fibers.futures.AsyncCompletionStage

requestAsync() - Method in class co.paralleluniverse.fibers.futures.AsyncListenableFuture

requestSync() - Method in class co.paralleluniverse.fibers.FiberAsync

Called if FiberAsync.run() is not being executed in a fiber.

requestSync(long, TimeUnit) - Method in class co.paralleluniverse.fibers.FiberAsync

Called if FiberAsync.run(long, TimeUnit) is not being executed in a fiber.

requestSync() - Method in class co.paralleluniverse.fibers.futures.AsyncCompletionStage

requestSync() - Method in class co.paralleluniverse.fibers.futures.AsyncListenableFuture

requiresInstrumentation() - Method in class co.paralleluniverse.fibers.instrument.MethodDatabase.ClassEntry

reset() - Method in class co.paralleluniverse.common.benchmark.StripedHistogram

Reset the contents and stats of this histogram

reset() - Method in class co.paralleluniverse.common.monitoring.Counter

reset() - Method in class co.paralleluniverse.strands.concurrent.CyclicBarrier

Resets the barrier to its initial state.

reset() - Method in interface co.paralleluniverse.strands.queues.QueueIterator

resourceToClass(String) - Static method in class co.paralleluniverse.common.reflection.ClassLoaderUtil

resourceToSlashed(String) - Static method in class co.paralleluniverse.common.reflection.ClassLoaderUtil

retainAll(Collection<?>) - Method in class co.paralleluniverse.concurrent.util.SingleConsumerNonblockingProducerQueue

retainAll(Collection<?>) - Method in class co.paralleluniverse.strands.queues.SingleConsumerQueue

rethrow(Throwable) - Static method in class co.paralleluniverse.common.util.Exceptions

rethrowUnwrap(Throwable) - Static method in class co.paralleluniverse.common.util.Exceptions

rethrowUnwrap(Throwable, Class<X>) - Static method in class co.paralleluniverse.common.util.Exceptions

rethrowUnwrap(Throwable, Class<X1>, Class<X2>) - Static method in class co.paralleluniverse.common.util.Exceptions

Retransform - Class in co.paralleluniverse.fibers.instrument

Retransform() - Constructor for class co.paralleluniverse.fibers.instrument.Retransform

retransform(Class<?>) - Static method in class co.paralleluniverse.fibers.instrument.Retransform

Retransform.ClassLoadListener - Interface in co.paralleluniverse.fibers.instrument

run() - Method in class co.paralleluniverse.concurrent.util.CompletableFutureTask

run() - Method in class co.paralleluniverse.fibers.Fiber

run() - Method in class co.paralleluniverse.fibers.FiberAsync

Runs the asynchronous operation, blocks until it completes and returns its result.

run(long, TimeUnit) - Method in class co.paralleluniverse.fibers.FiberAsync

Runs the asynchronous operation, blocks until it completes (but only up to the given timeout duration) and returns its result.

run(Timeout) - Method in class co.paralleluniverse.fibers.FiberAsync

Runs the asynchronous operation, blocks until it completes (but only up to the given timeout duration) and returns its result.

run(String[]) - Method in class co.paralleluniverse.fibers.instrument.OldSuspendablesScanner

run() - Method in class co.paralleluniverse.fibers.instrument.SuspendablesScanner

run() - Method in class co.paralleluniverse.strands.channels.transfer.Pipeline

run() - Method in interface co.paralleluniverse.strands.SuspendableCallable

run() - Method in interface co.paralleluniverse.strands.SuspendableRunnable

run() - Method in class co.paralleluniverse.strands.SuspendableUtils.VoidSuspendableCallable

runBlocking(ExecutorService, CheckedCallable<V, E>) - Static method in class co.paralleluniverse.fibers.FiberAsync

Runs a thread-blocking operation on a given thread pool, blocks (the fiber) until the operation completes and returns its result.

runBlocking(ExecutorService, long, TimeUnit, CheckedCallable<V, E>) - Static method in class co.paralleluniverse.fibers.FiberAsync

Runs a thread-blocking operation on a given thread pool, blocks (the fiber) until the operation completes (but no longer than the specified timeout) and returns its result.

runBlocking(ExecutorService, Timeout, CheckedCallable<V, E>) - Static method in class co.paralleluniverse.fibers.FiberAsync

Runs a thread-blocking operation on a given thread pool, blocks (the fiber) until the operation completes (but no longer than the specified timeout) and returns its result.

runInFiber(SuspendableCallable<V>) - Static method in class co.paralleluniverse.fibers.FiberUtil

Runs an action in a new fiber, awaits the fiber's termination, and returns its result.

runInFiber(FiberScheduler, SuspendableCallable<V>) - Static method in class co.paralleluniverse.fibers.FiberUtil

Runs an action in a new fiber, awaits the fiber's termination, and returns its result.

runInFiber(SuspendableRunnable) - Static method in class co.paralleluniverse.fibers.FiberUtil

Runs an action in a new fiber and awaits the fiber's termination.

runInFiber(FiberScheduler, SuspendableRunnable) - Static method in class co.paralleluniverse.fibers.FiberUtil

Runs an action in a new fiber and awaits the fiber's termination.

runInFiberChecked(SuspendableCallable<V>, Class<X>) - Static method in class co.paralleluniverse.fibers.FiberUtil

Runs an action in a new fiber, awaits the fiber's termination, and returns its result.

runInFiberChecked(FiberScheduler, SuspendableCallable<V>, Class<X>) - Static method in class co.paralleluniverse.fibers.FiberUtil

Runs an action in a new fiber, awaits the fiber's termination, and returns its result.

runInFiberChecked(SuspendableRunnable, Class<X>) - Static method in class co.paralleluniverse.fibers.FiberUtil

Runs an action in a new fiber and awaits the fiber's termination.

runInFiberChecked(FiberScheduler, SuspendableRunnable, Class<X>) - Static method in class co.paralleluniverse.fibers.FiberUtil

Runs an action in a new fiber and awaits the fiber's termination.

runInFiberRuntime(SuspendableCallable<V>) - Static method in class co.paralleluniverse.fibers.FiberUtil

Runs an action in a new fiber, awaits the fiber's termination, and returns its result.

runInFiberRuntime(FiberScheduler, SuspendableCallable<V>) - Static method in class co.paralleluniverse.fibers.FiberUtil

Runs an action in a new fiber, awaits the fiber's termination, and returns its result.

runInFiberRuntime(SuspendableRunnable) - Static method in class co.paralleluniverse.fibers.FiberUtil

Runs an action in a new fiber and awaits the fiber's termination.

runInFiberRuntime(FiberScheduler, SuspendableRunnable) - Static method in class co.paralleluniverse.fibers.FiberUtil

Runs an action in a new fiber and awaits the fiber's termination.

RUNNABLE - Static variable in class co.paralleluniverse.concurrent.forkjoin.ParkableForkJoinTask

runnableToCallable(SuspendableRunnable) - Static method in class co.paralleluniverse.strands.SuspendableUtils

RuntimeExecutionException - Exception in co.paralleluniverse.fibers

Similar to ExecutionException only as an unchecked, rather than a checked, exception.

RuntimeExecutionException(Throwable) - Constructor for exception co.paralleluniverse.fibers.RuntimeExecutionException

RuntimeSuspendExecution - Exception in co.paralleluniverse.fibers

S

sameAsLast - Variable in class co.paralleluniverse.common.monitoring.FlightRecorder.Record

SameThreadExecutor - Class in co.paralleluniverse.common.util

SameThreadExecutorService - Class in co.paralleluniverse.common.util

scanClass(ClassNode) - Method in class co.paralleluniverse.fibers.instrument.OldSuspendablesScanner

schedule(Runnable, long, TimeUnit) - Method in class co.paralleluniverse.concurrent.util.ScheduledSingleThreadExecutor

schedule(Callable<V>, long, TimeUnit) - Method in class co.paralleluniverse.concurrent.util.ScheduledSingleThreadExecutor

schedule(Fiber<?>, Object, long, TimeUnit) - Method in class co.paralleluniverse.fibers.FiberTimedScheduler

scheduleAtFixedRate(Runnable, long, long, TimeUnit) - Method in class co.paralleluniverse.concurrent.util.ScheduledSingleThreadExecutor

ScheduledSingleThreadExecutor - Class in co.paralleluniverse.concurrent.util

This is a replacement for ScheduledThreadPoolExecutor, with the following characteristics:

1.

ScheduledSingleThreadExecutor(ThreadFactory) - Constructor for class co.paralleluniverse.concurrent.util.ScheduledSingleThreadExecutor

ScheduledSingleThreadExecutor() - Constructor for class co.paralleluniverse.concurrent.util.ScheduledSingleThreadExecutor

SchedulerLocal<T> - Class in co.paralleluniverse.fibers

Associates a value with the current FiberScheduler

SchedulerLocal() - Constructor for class co.paralleluniverse.fibers.SchedulerLocal

scheduleWithFixedDelay(Runnable, long, long, TimeUnit) - Method in class co.paralleluniverse.concurrent.util.ScheduledSingleThreadExecutor

select(boolean, SelectAction<Message>...) - Static method in class co.paralleluniverse.strands.channels.Selector

Performs exactly one channel operation of a given set, blocking until any of the actions completes.

select(boolean, long, TimeUnit, SelectAction<Message>...) - Static method in class co.paralleluniverse.strands.channels.Selector

Performs exactly one channel operation of a given set, blocking until any of the actions completes, but no longer than the given timeout.

select(boolean, Timeout, SelectAction<Message>...) - Static method in class co.paralleluniverse.strands.channels.Selector

Performs exactly one channel operation of a given set, blocking until any of the actions completes, but no longer than the given timeout.

select(boolean, List<? extends SelectAction<Message>>) - Static method in class co.paralleluniverse.strands.channels.Selector

Performs exactly one channel operation of a given set, blocking until any of the actions completes.

select(boolean, long, TimeUnit, List<? extends SelectAction<Message>>) - Static method in class co.paralleluniverse.strands.channels.Selector

Performs exactly one channel operation of a given set, blocking until any of the actions completes, but no longer than the specified timeout.

select(boolean, Timeout, List<? extends SelectAction<Message>>) - Static method in class co.paralleluniverse.strands.channels.Selector

Performs exactly one channel operation of a given set, blocking until any of the actions completes, but no longer than the specified timeout.

select(SelectAction<Message>...) - Static method in class co.paralleluniverse.strands.channels.Selector

Performs exactly one channel operation of a given set, blocking until any of the actions completes.

select(long, TimeUnit, SelectAction<Message>...) - Static method in class co.paralleluniverse.strands.channels.Selector

Performs exactly one channel operation of a given set, blocking until any of the actions completes, but no longer than the given timeout.

select(Timeout, SelectAction<Message>...) - Static method in class co.paralleluniverse.strands.channels.Selector

Performs exactly one channel operation of a given set, blocking until any of the actions completes, but no longer than the given timeout.

select(List<? extends SelectAction<Message>>) - Static method in class co.paralleluniverse.strands.channels.Selector

Performs exactly one channel operation of a given set, blocking until any of the actions completes.

select(long, TimeUnit, List<? extends SelectAction<Message>>) - Static method in class co.paralleluniverse.strands.channels.Selector

Performs exactly one channel operation of a given set, blocking until any of the actions completes, but no longer than the given timeout.

select(Timeout, List<? extends SelectAction<Message>>) - Static method in class co.paralleluniverse.strands.channels.Selector

Performs exactly one channel operation of a given set, blocking until any of the actions completes, but no longer than the given timeout.

select(Message) - Method in class co.paralleluniverse.strands.channels.SplitSendPort

Subclasses will implement this method to select the target SendPort.

Selectable<Message> - Interface in co.paralleluniverse.strands.channels

A channel port that can be used by a Selector.

SelectAction<Message> - Class in co.paralleluniverse.strands.channels

A channel operation that is selected by a Selector.

SelectActionImpl<Message> - Class in co.paralleluniverse.strands.channels

Selector<Message> - Class in co.paralleluniverse.strands.channels

Attempts to perform at most one channel operation (send or receive) of a given set.

SelectReceiveListener<Message> - Interface in co.paralleluniverse.strands.channels

A listener associated with a receive SelectAction, which is called if an only if the associated action has succeeded.

SelectSendListener<Message> - Interface in co.paralleluniverse.strands.channels

A listener associated with a send SelectAction, which is called if an only if the associated action has succeeded.

Semaphore - Class in co.paralleluniverse.strands.concurrent

A counting semaphore.

Semaphore(int) - Constructor for class co.paralleluniverse.strands.concurrent.Semaphore

Creates a Semaphore with the given number of permits and nonfair fairness setting.

Semaphore(int, boolean) - Constructor for class co.paralleluniverse.strands.concurrent.Semaphore

Creates a Semaphore with the given number of permits and the given fairness setting.

send(T) - Method in class co.paralleluniverse.strands.channels.DelegatingSendPort

send(T, long, TimeUnit) - Method in class co.paralleluniverse.strands.channels.DelegatingSendPort

send(T, Timeout) - Method in class co.paralleluniverse.strands.channels.DelegatingSendPort

send(double) - Method in interface co.paralleluniverse.strands.channels.DoubleSendPort

Sends a message to the channel, possibly blocking until there's room available in the channel.

send(double, long, TimeUnit) - Method in interface co.paralleluniverse.strands.channels.DoubleSendPort

Sends a message to the channel, possibly blocking until there's room available in the channel, but never longer than the specified timeout.

send(double, Timeout) - Method in interface co.paralleluniverse.strands.channels.DoubleSendPort

Sends a message to the channel, possibly blocking until there's room available in the channel, but never longer than the specified timeout.

send(float) - Method in interface co.paralleluniverse.strands.channels.FloatSendPort

Sends a message to the channel, possibly blocking until there's room available in the channel.

send(float, long, TimeUnit) - Method in interface co.paralleluniverse.strands.channels.FloatSendPort

Sends a message to the channel, possibly blocking until there's room available in the channel, but never longer than the specified timeout.

send(float, Timeout) - Method in interface co.paralleluniverse.strands.channels.FloatSendPort

Sends a message to the channel, possibly blocking until there's room available in the channel, but never longer than the specified timeout.

send(int) - Method in interface co.paralleluniverse.strands.channels.IntSendPort

Sends a message to the channel, possibly blocking until there's room available in the channel.

send(int, long, TimeUnit) - Method in interface co.paralleluniverse.strands.channels.IntSendPort

Sends a message to the channel, possibly blocking until there's room available in the channel, but never longer than the specified timeout.

send(int, Timeout) - Method in interface co.paralleluniverse.strands.channels.IntSendPort

Sends a message to the channel, possibly blocking until there's room available in the channel, but never longer than the specified timeout.

send(long) - Method in interface co.paralleluniverse.strands.channels.LongSendPort

Sends a message to the channel, possibly blocking until there's room available in the channel.

send(long, long, TimeUnit) - Method in interface co.paralleluniverse.strands.channels.LongSendPort

Sends a message to the channel, possibly blocking until there's room available in the channel, but never longer than the specified timeout.

send(long, Timeout) - Method in interface co.paralleluniverse.strands.channels.LongSendPort

Sends a message to the channel, possibly blocking until there's room available in the channel, but never longer than the specified timeout.

send(Message) - Method in class co.paralleluniverse.strands.channels.QueueChannel

send(Message, long, TimeUnit) - Method in class co.paralleluniverse.strands.channels.QueueChannel

send(Message, Timeout) - Method in class co.paralleluniverse.strands.channels.QueueChannel

send(double) - Method in class co.paralleluniverse.strands.channels.QueueDoubleChannel

send(double, long, TimeUnit) - Method in class co.paralleluniverse.strands.channels.QueueDoubleChannel

send(double, Timeout) - Method in class co.paralleluniverse.strands.channels.QueueDoubleChannel

send(float) - Method in class co.paralleluniverse.strands.channels.QueueFloatChannel

send(float, long, TimeUnit) - Method in class co.paralleluniverse.strands.channels.QueueFloatChannel

send(float, Timeout) - Method in class co.paralleluniverse.strands.channels.QueueFloatChannel

send(int) - Method in class co.paralleluniverse.strands.channels.QueueIntChannel

send(int, long, TimeUnit) - Method in class co.paralleluniverse.strands.channels.QueueIntChannel

send(int, Timeout) - Method in class co.paralleluniverse.strands.channels.QueueIntChannel

send(long) - Method in class co.paralleluniverse.strands.channels.QueueLongChannel

send(long, long, TimeUnit) - Method in class co.paralleluniverse.strands.channels.QueueLongChannel

send(long, Timeout) - Method in class co.paralleluniverse.strands.channels.QueueLongChannel

send(SendPort<? super Message>, Message) - Static method in class co.paralleluniverse.strands.channels.Selector

Creates a SelectAction for a send operation

send(SendPort<? super Message>, Message, SelectSendListener<Message>) - Static method in class co.paralleluniverse.strands.channels.Selector

Creates a SelectAction for a send operation

send(Message) - Method in interface co.paralleluniverse.strands.channels.SendPort

Sends a message to the channel, possibly blocking until there's room available in the channel.

send(Message, long, TimeUnit) - Method in interface co.paralleluniverse.strands.channels.SendPort

Sends a message to the channel, possibly blocking until there's room available in the channel, but never longer than the specified timeout.

send(Message, Timeout) - Method in interface co.paralleluniverse.strands.channels.SendPort

Sends a message to the channel, possibly blocking until there's room available in the channel, but never longer than the specified timeout.

send(Message) - Method in class co.paralleluniverse.strands.channels.SplitSendPort

send(Message, Timeout) - Method in class co.paralleluniverse.strands.channels.SplitSendPort

send(Message, long, TimeUnit) - Method in class co.paralleluniverse.strands.channels.SplitSendPort

send(Message) - Method in class co.paralleluniverse.strands.channels.ThreadSendPort

Sends a message to the channel, possibly blocking until there's room available in the channel.

send(Message, long, TimeUnit) - Method in class co.paralleluniverse.strands.channels.ThreadSendPort

Sends a message to the channel, possibly blocking until there's room available in the channel, but never longer than the specified timeout.

send(Message) - Method in class co.paralleluniverse.strands.channels.Topic

send(Message, long, TimeUnit) - Method in class co.paralleluniverse.strands.channels.Topic

send(Message, Timeout) - Method in class co.paralleluniverse.strands.channels.Topic

send(Message) - Method in class co.paralleluniverse.strands.channels.TransferChannel

send(Message, long, TimeUnit) - Method in class co.paralleluniverse.strands.channels.TransferChannel

send(Message, Timeout) - Method in class co.paralleluniverse.strands.channels.TransferChannel

send0(Message, boolean, boolean, long) - Method in class co.paralleluniverse.strands.channels.QueueChannel

sendClosed - Variable in class co.paralleluniverse.strands.channels.Topic

sendNonSuspendable(Message) - Method in class co.paralleluniverse.strands.channels.QueueChannel

SendPort<Message> - Interface in co.paralleluniverse.strands.channels

A channel's producer-side functional interface.

sendSync(Message) - Method in class co.paralleluniverse.strands.channels.QueueChannel

Serialization - Class in co.paralleluniverse.io.serialization

ServiceUtil - Class in co.paralleluniverse.common.util

A utility class for loading services with ServiceLoader.

set(int, E) - Method in class co.paralleluniverse.common.util.Tuple

set(String, String, MethodDatabase.SuspendableType) - Method in class co.paralleluniverse.fibers.instrument.MethodDatabase.ClassEntry

set(T) - Method in class co.paralleluniverse.fibers.SchedulerLocal

Sets the scheduler-local value of this SchedulerLocal.

set(T) - Method in class co.paralleluniverse.fibers.TrueThreadLocal

set(V) - Method in class co.paralleluniverse.strands.AbstractFuture

set(V) - Method in class co.paralleluniverse.strands.dataflow.Val

Sets the value.

set(T) - Method in class co.paralleluniverse.strands.dataflow.Var

Sets a new value for this Var.

set(V) - Method in class co.paralleluniverse.strands.SettableFuture

setAll(MethodDatabase.SuspendableType) - Method in class co.paralleluniverse.fibers.instrument.MethodDatabase.ClassEntry

setAllowBlocking(boolean) - Method in class co.paralleluniverse.fibers.instrument.InstrumentationTask

setAllowBlocking(boolean) - Method in class co.paralleluniverse.fibers.instrument.QuasarInstrumentor

setAllowMonitors(boolean) - Method in class co.paralleluniverse.fibers.instrument.InstrumentationTask

setAllowMonitors(boolean) - Method in class co.paralleluniverse.fibers.instrument.QuasarInstrumentor

setAppend(boolean) - Method in class co.paralleluniverse.fibers.instrument.OldSuspendablesScanner

setAppend(boolean) - Method in class co.paralleluniverse.fibers.instrument.SuspendablesScanner

Whether the found methods should be appended to the output files(s) or replace them.

setAuto(boolean) - Method in class co.paralleluniverse.fibers.instrument.SuspendablesScanner

Whether suspendables should be found based on the method call-graph.

setAux(Object) - Method in class co.paralleluniverse.common.monitoring.FlightRecorder

setAux(Object) - Method in class co.paralleluniverse.common.monitoring.FlightRecorder.ThreadRecorder

setCheck(boolean) - Method in class co.paralleluniverse.fibers.instrument.InstrumentationTask

setCheck(boolean) - Method in class co.paralleluniverse.fibers.instrument.QuasarInstrumentor

setContextClassLoader(Thread, ClassLoader) - Static method in class co.paralleluniverse.concurrent.util.ThreadAccess

setContinueExistingPeriodicTasksAfterShutdownPolicy(boolean) - Method in class co.paralleluniverse.concurrent.util.ScheduledSingleThreadExecutor

Sets the policy on whether to continue executing existing periodic tasks even when this executor has been shutdown.

setDebug(boolean) - Method in class co.paralleluniverse.fibers.instrument.InstrumentationTask

setDebug(boolean) - Method in class co.paralleluniverse.fibers.instrument.QuasarInstrumentor

setDefaultUncaughtExceptionHandler(Strand.UncaughtExceptionHandler) - Static method in class co.paralleluniverse.fibers.Fiber

Set the default handler invoked when a fiber abruptly terminates due to an uncaught exception, and no other handler has been defined for that fiber.

setException(Throwable) - Method in class co.paralleluniverse.strands.AbstractFuture

setException(Throwable) - Method in class co.paralleluniverse.strands.dataflow.Val

Sets an exception that will be thrown by get, wrapped by RuntimeExecutionException.

setException(Throwable) - Method in class co.paralleluniverse.strands.SettableFuture

setExclusiveOwnerStrand(Strand) - Method in class co.paralleluniverse.strands.concurrent.AbstractOwnableSynchronizer

Sets the strand that currently owns exclusive access.

setExecuteExistingDelayedTasksAfterShutdownPolicy(boolean) - Method in class co.paralleluniverse.concurrent.util.ScheduledSingleThreadExecutor

Sets the policy on whether to execute existing delayed tasks even when this executor has been shutdown.

setFiber(FiberScheduler) - Method in class co.paralleluniverse.strands.StrandFactoryBuilder

Makes the resulting StrandFactory produce fibers.

setInheritableThreadLocals(Thread, Object) - Static method in class co.paralleluniverse.concurrent.util.ThreadAccess

setInheritedAccessControlContext(Thread, AccessControlContext) - Static method in class co.paralleluniverse.concurrent.util.ThreadAccess

setInstrumented(boolean) - Method in class co.paralleluniverse.fibers.instrument.MethodDatabase.ClassEntry

setInterfaces(String[]) - Method in class co.paralleluniverse.fibers.instrument.MethodDatabase.ClassEntry

setIsInterface(boolean) - Method in class co.paralleluniverse.fibers.instrument.MethodDatabase.ClassEntry

setItem(Message) - Method in class co.paralleluniverse.strands.channels.SelectActionImpl

setLog(Log) - Method in class co.paralleluniverse.fibers.instrument.QuasarInstrumentor

setLog(boolean, boolean) - Method in class co.paralleluniverse.fibers.instrument.QuasarURLClassLoaderHelper

setMonitor(ForkJoinPoolMonitor) - Method in class co.paralleluniverse.concurrent.forkjoin.MonitoredForkJoinPool

setName(String) - Method in class co.paralleluniverse.fibers.Fiber

setName(String) - Method in class co.paralleluniverse.strands.Strand

Sets this strand's name.

setNameFormat(String) - Method in class co.paralleluniverse.strands.StrandFactoryBuilder

Sets the naming format to use when naming strands (Strand.setName(java.lang.String)) which are created with this StrandFactory.

setNoLocals(boolean) - Method in class co.paralleluniverse.fibers.Fiber

Deprecated.

setOption(SocketOption<T>, T) - Method in class co.paralleluniverse.fibers.io.FiberServerSocketChannel

setOption(SocketOption<T>, T) - Method in class co.paralleluniverse.fibers.io.FiberSocketChannel

setOutputFile(String) - Method in class co.paralleluniverse.fibers.instrument.OldSuspendablesScanner

setPerformanceTimerPeriod(int) - Method in class co.paralleluniverse.common.monitoring.MonitoringServices

setPerformanceTimerPeriod(int) - Method in interface co.paralleluniverse.common.monitoring.MonitoringServicesMXBean

setPerformanceUpdates(boolean) - Method in class co.paralleluniverse.common.monitoring.MonitoringServices

setPerformanceUpdates(boolean) - Method in interface co.paralleluniverse.common.monitoring.MonitoringServicesMXBean

setPriority(int) - Method in class co.paralleluniverse.fibers.Fiber

Sets the priority of this fiber.

setPriority(int) - Method in class co.paralleluniverse.strands.Strand

Attempts to change the priority of this strand.

setPriority(int) - Method in class co.paralleluniverse.strands.StrandFactoryBuilder

Sets the priority for strands created by the StrandFactory.

setRecordStackTraces(boolean) - Static method in class co.paralleluniverse.common.util.Debug

setRemoveOnCancelPolicy(boolean) - Method in class co.paralleluniverse.concurrent.util.ScheduledSingleThreadExecutor

Sets the policy on whether cancelled tasks should be immediately removed from the work queue at time of cancellation.

setRequiresInstrumentation(boolean) - Method in class co.paralleluniverse.fibers.instrument.MethodDatabase.ClassEntry

setRunawayFibers(Collection<Fiber>) - Method in interface co.paralleluniverse.fibers.FibersMonitor

setRunawayFibers(Collection<Fiber>) - Method in class co.paralleluniverse.fibers.NoopFibersMonitor

setSeed(long) - Method in class co.paralleluniverse.strands.StrandLocalRandom

Throws UnsupportedOperationException.

setSoloEffect(Mix.SoloEffect) - Method in interface co.paralleluniverse.strands.channels.Mix

setSoloEffect(Mix.SoloEffect) - Method in class co.paralleluniverse.strands.channels.ReceivePortGroup

setSourceDebugInfo(String) - Method in class co.paralleluniverse.fibers.instrument.MethodDatabase.ClassEntry

setSourceName(String) - Method in class co.paralleluniverse.fibers.instrument.MethodDatabase.ClassEntry

setStackSize(int) - Method in class co.paralleluniverse.strands.StrandFactoryBuilder

Suggests a stack size of strands created by the resulting StrandFactory.

setState(int) - Method in class co.paralleluniverse.concurrent.forkjoin.ParkableForkJoinTask

setState(Mix.State, T...) - Method in interface co.paralleluniverse.strands.channels.Mix

setState(Map<T, Mix.State>) - Method in interface co.paralleluniverse.strands.channels.Mix

setState(Mix.State, T...) - Method in class co.paralleluniverse.strands.channels.ReceivePortGroup

setState(Map<T, Mix.State>) - Method in class co.paralleluniverse.strands.channels.ReceivePortGroup

setState(long) - Method in class co.paralleluniverse.strands.concurrent.AbstractQueuedLongSynchronizer

Sets the value of synchronization state.

setState(int) - Method in class co.paralleluniverse.strands.concurrent.AbstractQueuedSynchronizer

Sets the value of synchronization state.

setStrand(Strand) - Method in class co.paralleluniverse.strands.channels.QueuePrimitiveChannel

setStrand(Strand) - Method in class co.paralleluniverse.strands.channels.SingleConsumerQueueChannel

setStrand(Strand) - Method in interface co.paralleluniverse.strands.Stranded

setStructuraltimerPeriod(int) - Method in class co.paralleluniverse.common.monitoring.MonitoringServices

setStructuraltimerPeriod(int) - Method in interface co.paralleluniverse.common.monitoring.MonitoringServicesMXBean

setStructuralUpdates(boolean) - Method in class co.paralleluniverse.common.monitoring.MonitoringServices

setStructuralUpdates(boolean) - Method in interface co.paralleluniverse.common.monitoring.MonitoringServicesMXBean

setSupersFile(String) - Method in class co.paralleluniverse.fibers.instrument.SuspendablesScanner

setSuspendablesFile(String) - Method in class co.paralleluniverse.fibers.instrument.OldSuspendablesScanner

setSuspendablesFile(String) - Method in class co.paralleluniverse.fibers.instrument.SuspendablesScanner

SettableFuture<V> - Class in co.paralleluniverse.strands

SettableFuture() - Constructor for class co.paralleluniverse.strands.SettableFuture

setTarget(Thread, Object) - Static method in class co.paralleluniverse.concurrent.forkjoin.ParkableForkJoinTask

setTarget(Thread, Runnable) - Static method in class co.paralleluniverse.concurrent.util.ThreadAccess

setThread(boolean) - Method in class co.paralleluniverse.strands.StrandFactoryBuilder

Makes the resulting StrandFactory produce threads.

setThreadLocals(Thread, Object) - Static method in class co.paralleluniverse.concurrent.util.ThreadAccess

setUncaughtExceptionHandler(Strand.UncaughtExceptionHandler) - Method in class co.paralleluniverse.fibers.Fiber

Set the handler invoked when this fiber abruptly terminates due to an uncaught exception.

setUncaughtExceptionHandler(Strand.UncaughtExceptionHandler) - Method in class co.paralleluniverse.strands.Strand

Set the handler invoked when this strand abruptly terminates due to an uncaught exception.

setUncaughtExceptionHandler(Strand.UncaughtExceptionHandler) - Method in class co.paralleluniverse.strands.StrandFactoryBuilder

Sets the UncaughtExceptionHandler for new threads created with this ThreadFactory.

setVerbose(boolean) - Method in class co.paralleluniverse.fibers.instrument.InstrumentationTask

setVerbose(boolean) - Method in class co.paralleluniverse.fibers.instrument.QuasarInstrumentor

setWriteClasses(boolean) - Method in class co.paralleluniverse.fibers.instrument.InstrumentationTask

shouldInstrument(String) - Method in class co.paralleluniverse.fibers.instrument.QuasarInstrumentor

shouldPreempt(int) - Method in class co.paralleluniverse.fibers.Fiber

shutdown() - Method in interface co.paralleluniverse.common.monitoring.ForkJoinPoolMXBean

shutdown() - Method in class co.paralleluniverse.common.monitoring.JMXForkJoinPoolMonitor

shutdown() - Method in class co.paralleluniverse.common.util.SameThreadExecutorService

shutdown() - Method in class co.paralleluniverse.concurrent.util.ScheduledSingleThreadExecutor

Initiates an orderly shutdown in which previously submitted tasks are executed, but no new tasks will be accepted.

shutdown() - Method in class co.paralleluniverse.fibers.FiberExecutorScheduler

shutdown() - Method in class co.paralleluniverse.fibers.FiberForkJoinScheduler

shutdown() - Method in class co.paralleluniverse.fibers.FiberScheduler

shutdown() - Method in class co.paralleluniverse.fibers.FiberTimedScheduler

Initiates an orderly shutdown in which previously submitted tasks are executed, but no new tasks will be accepted.

shutdown() - Method in class co.paralleluniverse.fibers.io.ChannelGroup

Shutdown the channel group.

shutdownInput() - Method in class co.paralleluniverse.fibers.io.FiberSocketChannel

Shutdown the connection for reading without closing the channel.

shutdownNow() - Method in interface co.paralleluniverse.common.monitoring.ForkJoinPoolMXBean

shutdownNow() - Method in class co.paralleluniverse.common.monitoring.JMXForkJoinPoolMonitor

shutdownNow() - Method in class co.paralleluniverse.common.util.SameThreadExecutorService

shutdownNow() - Method in class co.paralleluniverse.concurrent.util.ScheduledSingleThreadExecutor

Attempts to stop all actively executing tasks, halts the processing of waiting tasks, and returns a list of the tasks that were awaiting execution.

shutdownNow() - Method in class co.paralleluniverse.fibers.FiberTimedScheduler

Attempts to stop all actively executing tasks, halts the processing of waiting tasks, and returns a list of the tasks that were awaiting execution.

shutdownOutput() - Method in class co.paralleluniverse.fibers.io.FiberSocketChannel

Shutdown the connection for writing without closing the channel.

signal() - Method in class co.paralleluniverse.strands.concurrent.AbstractQueuedLongSynchronizer.ConditionObject

Moves the longest-waiting strand, if one exists, from the wait queue for this condition to the wait queue for the owning lock.

signal() - Method in class co.paralleluniverse.strands.concurrent.AbstractQueuedSynchronizer.ConditionObject

Moves the longest-waiting strand, if one exists, from the wait queue for this condition to the wait queue for the owning lock.

signal() - Method in interface co.paralleluniverse.strands.Condition

signal() - Method in class co.paralleluniverse.strands.ConditionSelector

signal() - Method in class co.paralleluniverse.strands.DoneSynchronizer

signal() - Method in class co.paralleluniverse.strands.OwnedSynchronizer

signal() - Method in class co.paralleluniverse.strands.SimpleConditionSynchronizer

signalAll() - Method in class co.paralleluniverse.strands.concurrent.AbstractQueuedLongSynchronizer.ConditionObject

Moves all strands from the wait queue for this condition to the wait queue for the owning lock.

signalAll() - Method in class co.paralleluniverse.strands.concurrent.AbstractQueuedSynchronizer.ConditionObject

Moves all strands from the wait queue for this condition to the wait queue for the owning lock.

signalAll() - Method in interface co.paralleluniverse.strands.Condition

signalAll() - Method in class co.paralleluniverse.strands.ConditionSelector

signalAll() - Method in class co.paralleluniverse.strands.DoneSynchronizer

signalAll() - Method in class co.paralleluniverse.strands.OwnedSynchronizer

signalAll() - Method in class co.paralleluniverse.strands.SimpleConditionSynchronizer

signalAndWait() - Method in class co.paralleluniverse.strands.channels.QueueChannel

signalAndWait() - Method in class co.paralleluniverse.strands.OwnedSynchronizer

signalReceivers() - Method in class co.paralleluniverse.strands.channels.QueueChannel

SimpleConditionSynchronizer - Class in co.paralleluniverse.strands

SimpleConditionSynchronizer(Object) - Constructor for class co.paralleluniverse.strands.SimpleConditionSynchronizer

SimpleFormatter - Class in co.paralleluniverse.common.logging

Exactly the same as java.util.logging.SimpleFormatter, except passes thread ID as the last (#7) parameter to String.format.

SimpleFormatter() - Constructor for class co.paralleluniverse.common.logging.SimpleFormatter

SimpleMBean - Class in co.paralleluniverse.common.monitoring

SimpleMBean(String, String, String, String) - Constructor for class co.paralleluniverse.common.monitoring.SimpleMBean

SimpleReservoir - Class in co.paralleluniverse.common.monitoring

This is a false reservoir that merely records the precise max and min, as well as an approximate mean.

SimpleReservoir() - Constructor for class co.paralleluniverse.common.monitoring.SimpleReservoir

SimpleSuspendableClassifier - Class in co.paralleluniverse.fibers.instrument

SimpleSuspendableClassifier(ClassLoader) - Constructor for class co.paralleluniverse.fibers.instrument.SimpleSuspendableClassifier

SimpleSuspendableClassifier(ClassLoader, String[], String[]) - Constructor for class co.paralleluniverse.fibers.instrument.SimpleSuspendableClassifier

SingleConsumerArrayDoubleQueue - Class in co.paralleluniverse.strands.queues

SingleConsumerArrayDoubleQueue(int) - Constructor for class co.paralleluniverse.strands.queues.SingleConsumerArrayDoubleQueue

SingleConsumerArrayFloatQueue - Class in co.paralleluniverse.strands.queues

SingleConsumerArrayFloatQueue(int) - Constructor for class co.paralleluniverse.strands.queues.SingleConsumerArrayFloatQueue

SingleConsumerArrayIntQueue - Class in co.paralleluniverse.strands.queues

SingleConsumerArrayIntQueue(int) - Constructor for class co.paralleluniverse.strands.queues.SingleConsumerArrayIntQueue

SingleConsumerArrayLongQueue - Class in co.paralleluniverse.strands.queues

SingleConsumerArrayLongQueue(int) - Constructor for class co.paralleluniverse.strands.queues.SingleConsumerArrayLongQueue

SingleConsumerArrayObjectQueue<E> - Class in co.paralleluniverse.strands.queues

SingleConsumerArrayObjectQueue(int) - Constructor for class co.paralleluniverse.strands.queues.SingleConsumerArrayObjectQueue

SingleConsumerLinkedArrayDoubleQueue - Class in co.paralleluniverse.strands.queues

SingleConsumerLinkedArrayDoubleQueue() - Constructor for class co.paralleluniverse.strands.queues.SingleConsumerLinkedArrayDoubleQueue

SingleConsumerLinkedArrayFloatQueue - Class in co.paralleluniverse.strands.queues

SingleConsumerLinkedArrayFloatQueue() - Constructor for class co.paralleluniverse.strands.queues.SingleConsumerLinkedArrayFloatQueue

SingleConsumerLinkedArrayIntQueue - Class in co.paralleluniverse.strands.queues

SingleConsumerLinkedArrayIntQueue() - Constructor for class co.paralleluniverse.strands.queues.SingleConsumerLinkedArrayIntQueue

SingleConsumerLinkedArrayLongQueue - Class in co.paralleluniverse.strands.queues

SingleConsumerLinkedArrayLongQueue() - Constructor for class co.paralleluniverse.strands.queues.SingleConsumerLinkedArrayLongQueue

SingleConsumerLinkedArrayObjectQueue<E> - Class in co.paralleluniverse.strands.queues

SingleConsumerLinkedArrayObjectQueue() - Constructor for class co.paralleluniverse.strands.queues.SingleConsumerLinkedArrayObjectQueue

SingleConsumerLinkedArrayPrimitiveQueue<E> - Class in co.paralleluniverse.strands.queues

SingleConsumerLinkedArrayPrimitiveQueue() - Constructor for class co.paralleluniverse.strands.queues.SingleConsumerLinkedArrayPrimitiveQueue

SingleConsumerLinkedDoubleQueue - Class in co.paralleluniverse.strands.queues

SingleConsumerLinkedDoubleQueue() - Constructor for class co.paralleluniverse.strands.queues.SingleConsumerLinkedDoubleQueue

SingleConsumerLinkedFloatQueue - Class in co.paralleluniverse.strands.queues

SingleConsumerLinkedFloatQueue() - Constructor for class co.paralleluniverse.strands.queues.SingleConsumerLinkedFloatQueue

SingleConsumerLinkedIntQueue - Class in co.paralleluniverse.strands.queues

SingleConsumerLinkedIntQueue() - Constructor for class co.paralleluniverse.strands.queues.SingleConsumerLinkedIntQueue

SingleConsumerLinkedLongQueue - Class in co.paralleluniverse.strands.queues

SingleConsumerLinkedLongQueue() - Constructor for class co.paralleluniverse.strands.queues.SingleConsumerLinkedLongQueue

SingleConsumerLinkedObjectQueue<E> - Class in co.paralleluniverse.strands.queues

SingleConsumerLinkedObjectQueue() - Constructor for class co.paralleluniverse.strands.queues.SingleConsumerLinkedObjectQueue

SingleConsumerNonblockingProducerDelayQueue<E extends java.util.concurrent.Delayed> - Class in co.paralleluniverse.concurrent.util

SingleConsumerNonblockingProducerDelayQueue() - Constructor for class co.paralleluniverse.concurrent.util.SingleConsumerNonblockingProducerDelayQueue

SingleConsumerNonblockingProducerQueue<E> - Class in co.paralleluniverse.concurrent.util

SingleConsumerNonblockingProducerQueue(Queue<E>) - Constructor for class co.paralleluniverse.concurrent.util.SingleConsumerNonblockingProducerQueue

SingleConsumerQueue<E> - Class in co.paralleluniverse.strands.queues

SingleConsumerQueue() - Constructor for class co.paralleluniverse.strands.queues.SingleConsumerQueue

SingleConsumerQueueChannel<Message> - Class in co.paralleluniverse.strands.channels

SingleConsumerQueueChannel(SingleConsumerQueue<Message>, Channels.OverflowPolicy) - Constructor for class co.paralleluniverse.strands.channels.SingleConsumerQueueChannel

singletonReceivePort(T) - Static method in class co.paralleluniverse.strands.channels.Channels

Returns a newly created ReceivePort that receives a single message: the object given to the function.

size() - Method in class co.paralleluniverse.common.benchmark.Striped

size() - Method in class co.paralleluniverse.common.monitoring.LatencyStatsReservoir

size() - Method in class co.paralleluniverse.common.monitoring.SimpleReservoir

size() - Method in class co.paralleluniverse.common.util.ConcurrentSet

size() - Method in class co.paralleluniverse.common.util.Pair

size() - Method in class co.paralleluniverse.common.util.Tuple

size() - Method in class co.paralleluniverse.concurrent.util.ConcurrentSkipListPriorityQueue

Returns the number of key-value mappings in this map.

size() - Method in class co.paralleluniverse.concurrent.util.ConcurrentSkipListSet

Returns the number of elements in this set.

size() - Method in class co.paralleluniverse.concurrent.util.DelayQueue

size() - Method in class co.paralleluniverse.concurrent.util.SingleConsumerNonblockingProducerQueue

size() - Method in class co.paralleluniverse.fibers.io.FiberFileChannel

size() - Method in class co.paralleluniverse.strands.queues.ArrayQueue

size() - Method in interface co.paralleluniverse.strands.queues.BasicQueue

size() - Method in class co.paralleluniverse.strands.queues.BoxQueue

size() - Method in class co.paralleluniverse.strands.queues.CircularBuffer.Consumer

size() - Method in class co.paralleluniverse.strands.queues.CircularBuffer

size() - Method in class co.paralleluniverse.strands.queues.SingleConsumerQueue

sizeOfEquivalentValueRange(long) - Method in class co.paralleluniverse.common.benchmark.StripedHistogram

Get the size (in value units) of the range of values that are equivalent to the given value within the histogram's resolution.

sleep(long) - Static method in class co.paralleluniverse.fibers.Fiber

sleep(long, int) - Static method in class co.paralleluniverse.fibers.Fiber

sleep(long, TimeUnit) - Static method in class co.paralleluniverse.fibers.Fiber

sleep(long) - Static method in class co.paralleluniverse.strands.Strand

Causes the currently executing strand to sleep (temporarily cease execution) for the specified number of milliseconds, subject to the precision and accuracy of system timers and schedulers.

sleep(long, int) - Static method in class co.paralleluniverse.strands.Strand

Causes the currently executing strand to sleep (temporarily cease execution) for the specified number of milliseconds plus the specified number of nanoseconds, subject to the precision and accuracy of system timers and schedulers.

sleep(long, TimeUnit) - Static method in class co.paralleluniverse.strands.Strand

Causes the currently executing strand to sleep (temporarily cease execution) for the specified duration, subject to the precision and accuracy of system timers and schedulers.

snapshot() - Method in class co.paralleluniverse.strands.queues.SingleConsumerQueue

sneakyThrow(Throwable) - Static method in class co.paralleluniverse.common.util.Exceptions

solo - Variable in class co.paralleluniverse.strands.channels.Mix.State

SplitSendPort<Message> - Class in co.paralleluniverse.strands.channels

SendPort that will send messages it receives to a target SendPort.

SplitSendPort() - Constructor for class co.paralleluniverse.strands.channels.SplitSendPort

spuriousWakeup() - Method in interface co.paralleluniverse.fibers.FibersMonitor

spuriousWakeup() - Method in class co.paralleluniverse.fibers.NoopFibersMonitor

Stack - Class in co.paralleluniverse.fibers

Internal Class - DO NOT USE! (Public so that instrumented code can access it) ANY CHANGE IN THIS CLASS NEEDS TO BE SYNCHRONIZED WITH InstrumentMethod

StampedLock - Class in co.paralleluniverse.strands.concurrent

A capability-based lock with three modes for controlling read/write access.

StampedLock() - Constructor for class co.paralleluniverse.strands.concurrent.StampedLock

Creates a new lock, initially in unlocked state.

StandardChannel<Message> - Interface in co.paralleluniverse.strands.channels

A common interface for standard channel implementations

start() - Method in class co.paralleluniverse.fibers.Fiber

start() - Method in class co.paralleluniverse.strands.Strand

Starts the strand.

startPerformanceUpdates() - Method in class co.paralleluniverse.common.monitoring.MonitoringServices

startPerformanceUpdates() - Method in interface co.paralleluniverse.common.monitoring.MonitoringServicesMXBean

startStructuralUpdates() - Method in class co.paralleluniverse.common.monitoring.MonitoringServices

startStructuralUpdates() - Method in interface co.paralleluniverse.common.monitoring.MonitoringServicesMXBean

State(Mix.Mode, Boolean) - Constructor for class co.paralleluniverse.strands.channels.Mix.State

State(Mix.Mode) - Constructor for class co.paralleluniverse.strands.channels.Mix.State

State(boolean) - Constructor for class co.paralleluniverse.strands.channels.Mix.State

stop() - Method in class co.paralleluniverse.common.monitoring.FlightRecorder

stopPerformanceUpdates() - Method in class co.paralleluniverse.common.monitoring.MonitoringServices

stopPerformanceUpdates() - Method in interface co.paralleluniverse.common.monitoring.MonitoringServicesMXBean

stopStructuralUpdates() - Method in class co.paralleluniverse.common.monitoring.MonitoringServices

stopStructuralUpdates() - Method in interface co.paralleluniverse.common.monitoring.MonitoringServicesMXBean

Strand - Class in co.paralleluniverse.strands

A Strand is either a Thread or a Fiber

Strand() - Constructor for class co.paralleluniverse.strands.Strand

Strand.State - Enum in co.paralleluniverse.strands

A strand's running state

Strand.UncaughtExceptionHandler - Interface in co.paralleluniverse.strands

Interface for handlers invoked when a Strand abruptly terminates due to an uncaught exception.

Stranded - Interface in co.paralleluniverse.strands

StrandFactory - Interface in co.paralleluniverse.strands

Creates new strands on demand.

StrandFactoryBuilder - Class in co.paralleluniverse.strands

Easily creates StrandFactorys.

StrandFactoryBuilder() - Constructor for class co.paralleluniverse.strands.StrandFactoryBuilder

StrandLocalRandom - Class in co.paralleluniverse.strands

A random number generator isolated to the current thread.

Strings - Class in co.paralleluniverse.common.util

Striped<T> - Class in co.paralleluniverse.common.benchmark

Striped() - Constructor for class co.paralleluniverse.common.benchmark.Striped

StripedHistogram - Class in co.paralleluniverse.common.benchmark

StripedHistogram(long, int) - Constructor for class co.paralleluniverse.common.benchmark.StripedHistogram

Construct a Histogram given the Highest value to be tracked and a number of significant decimal digits

StripedLongTimeSeries - Class in co.paralleluniverse.common.benchmark

StripedLongTimeSeries(int, boolean) - Constructor for class co.paralleluniverse.common.benchmark.StripedLongTimeSeries

StripedLongTimeSeries.Record - Class in co.paralleluniverse.common.benchmark

StripedLongTimeSeries.ThreadRecorder - Class in co.paralleluniverse.common.benchmark

StripedTimeSeries<V> - Class in co.paralleluniverse.common.benchmark

StripedTimeSeries(int, boolean) - Constructor for class co.paralleluniverse.common.benchmark.StripedTimeSeries

StripedTimeSeries.Record<V> - Class in co.paralleluniverse.common.benchmark

StripedTimeSeries.ThreadRecorder<V> - Class in co.paralleluniverse.common.benchmark

subList(int, int) - Method in class co.paralleluniverse.common.util.Tuple

submit() - Method in class co.paralleluniverse.concurrent.forkjoin.ParkableForkJoinTask

submit(Runnable) - Method in class co.paralleluniverse.concurrent.util.AbstractCompletableExecutorService

submit(Runnable, T) - Method in class co.paralleluniverse.concurrent.util.AbstractCompletableExecutorService

submit(Callable<T>) - Method in class co.paralleluniverse.concurrent.util.AbstractCompletableExecutorService

submit(Callable<T>) - Method in interface co.paralleluniverse.concurrent.util.CompletableExecutorService

submit(Runnable) - Method in interface co.paralleluniverse.concurrent.util.CompletableExecutorService

submit(Runnable, T) - Method in interface co.paralleluniverse.concurrent.util.CompletableExecutorService

submit(Runnable) - Method in class co.paralleluniverse.concurrent.util.ScheduledSingleThreadExecutor

submit(Runnable, T) - Method in class co.paralleluniverse.concurrent.util.ScheduledSingleThreadExecutor

submit(Callable<T>) - Method in class co.paralleluniverse.concurrent.util.ScheduledSingleThreadExecutor

subscribe(T) - Method in class co.paralleluniverse.strands.channels.Topic

subSequence(int, int) - Method in class co.paralleluniverse.common.util.Substring

subSet(E, boolean, E, boolean) - Method in class co.paralleluniverse.concurrent.util.ConcurrentSkipListSet

subSet(E, E) - Method in class co.paralleluniverse.concurrent.util.ConcurrentSkipListSet

Substring - Class in co.paralleluniverse.common.util

An O(1) substring, necessitated by the JDK's new String representation.

Substring(String, int, int) - Constructor for class co.paralleluniverse.common.util.Substring

Substring(String, int) - Constructor for class co.paralleluniverse.common.util.Substring

supportedOptions() - Method in class co.paralleluniverse.fibers.io.FiberServerSocketChannel

supportedOptions() - Method in class co.paralleluniverse.fibers.io.FiberSocketChannel

Suspendable - Annotation Type in co.paralleluniverse.fibers

Marks a method as suspendable.

SUSPENDABLE_SUPERS_FILE - Static variable in class co.paralleluniverse.fibers.instrument.SimpleSuspendableClassifier

SuspendableAction1<S> - Interface in co.paralleluniverse.strands

SuspendableAction2<S1,S2> - Interface in co.paralleluniverse.strands

SuspendableCallable<V> - Interface in co.paralleluniverse.strands

This interface can represent any operation that may suspend the currently executing Strand (i.e.

SuspendableClassifier - Interface in co.paralleluniverse.fibers.instrument

SuspendableHelper - Class in co.paralleluniverse.fibers.instrument

SuspendableRunnable - Interface in co.paralleluniverse.strands

This interface can represent any operation that may suspend the currently executing Strand (i.e.

SUSPENDABLES_FILE - Static variable in class co.paralleluniverse.fibers.instrument.SimpleSuspendableClassifier

SuspendablesScanner - Class in co.paralleluniverse.fibers.instrument

SuspendablesScanner() - Constructor for class co.paralleluniverse.fibers.instrument.SuspendablesScanner

SuspendablesScanner(Path) - Constructor for class co.paralleluniverse.fibers.instrument.SuspendablesScanner

SuspendableUtils - Class in co.paralleluniverse.strands

SuspendableUtils() - Constructor for class co.paralleluniverse.strands.SuspendableUtils

SuspendableUtils.VoidSuspendableCallable - Class in co.paralleluniverse.strands

SuspendExecution - Exception in co.paralleluniverse.fibers

An exception used to initiate the control transfer.

SuspendExecution() - Constructor for exception co.paralleluniverse.fibers.SuspendExecution

swap(Function<V, V>) - Method in class co.paralleluniverse.concurrent.util.EnhancedAtomicReference

sync() - Method in class co.paralleluniverse.strands.channels.QueueChannel

Synchronization - Interface in co.paralleluniverse.strands

systemObjectId(Object) - Static method in class co.paralleluniverse.common.util.Objects

SystemProperties - Class in co.paralleluniverse.common.util

System properties utilities.

systemToString(Object) - Static method in class co.paralleluniverse.common.util.Objects

systemToStringSimpleName(Object) - Static method in class co.paralleluniverse.common.util.Objects

T

t - Variable in class co.paralleluniverse.common.util.ExtendedStackTrace

tailSet(E, boolean) - Method in class co.paralleluniverse.concurrent.util.ConcurrentSkipListSet

tailSet(E) - Method in class co.paralleluniverse.concurrent.util.ConcurrentSkipListSet

take() - Method in class co.paralleluniverse.concurrent.util.DelayQueue

Retrieves and removes the head of this queue, waiting if necessary until an element with an expired delay is available on this queue.

take() - Method in class co.paralleluniverse.concurrent.util.SingleConsumerNonblockingProducerDelayQueue

take() - Method in class co.paralleluniverse.concurrent.util.SingleConsumerNonblockingProducerQueue

take(ReceivePort<T>, long) - Static method in class co.paralleluniverse.strands.channels.Channels

Returns a ReceivePort that can provide at most count messages from channel.

take(long) - Method in class co.paralleluniverse.strands.channels.TransformingReceivePort

Returns a TakeReceivePort that can provide at most count messages from the underlying channel.

target - Variable in class co.paralleluniverse.strands.channels.DelegatingReceivePort

target - Variable in class co.paralleluniverse.strands.channels.DelegatingSendPort

test(ArrayList<String>) - Method in interface co.paralleluniverse.common.test.TestInterface

test(ArrayList<String>, TestInterface) - Method in interface co.paralleluniverse.common.test.TestInterface2

TestInterface - Interface in co.paralleluniverse.common.test

TestInterface2 - Interface in co.paralleluniverse.common.test

TestUtil - Class in co.paralleluniverse.common.test

TestUtil() - Constructor for class co.paralleluniverse.common.test.TestUtil

thread - Variable in class co.paralleluniverse.common.monitoring.FlightRecorder.Record

ThreadAccess - Class in co.paralleluniverse.concurrent.util

ThreadAccess() - Constructor for class co.paralleluniverse.concurrent.util.ThreadAccess

ThreadLocalSerializer - Class in co.paralleluniverse.fibers

ThreadLocalSerializer() - Constructor for class co.paralleluniverse.fibers.ThreadLocalSerializer

ThreadReceivePort<Message> - Class in co.paralleluniverse.strands.channels

This class is a simple convenience wrapper around ReceivePort that can be used by threads (as opposed to fibers).

ThreadReceivePort(ReceivePort<Message>) - Constructor for class co.paralleluniverse.strands.channels.ThreadReceivePort

Creates a new convenience wrapper for using a ReceivePort in a thread.

ThreadSendPort<Message> - Class in co.paralleluniverse.strands.channels

This class is a simple convenience wrapper around SendPort that can be used by threads (as opposed to fibers).

ThreadSendPort(SendPort<Message>) - Constructor for class co.paralleluniverse.strands.channels.ThreadSendPort

Creates a new convenience wrapper for using a SendPort in a thread.

ThreadUtil - Class in co.paralleluniverse.concurrent.util

throwPark(boolean) - Method in class co.paralleluniverse.concurrent.forkjoin.ParkableForkJoinTask

TickerChannelConsumer<Message> - Class in co.paralleluniverse.strands.channels

A ReceivePort which is a view of a ticker channel.

TickerChannelConsumer.TickerChannelFloatConsumer - Class in co.paralleluniverse.strands.channels

TickerChannelFloatConsumer(QueueFloatChannel) - Constructor for class co.paralleluniverse.strands.channels.TickerChannelConsumer.TickerChannelFloatConsumer

timedParkLatency(long) - Method in interface co.paralleluniverse.fibers.FibersMonitor

timedParkLatency(long) - Method in class co.paralleluniverse.fibers.NoopFibersMonitor

timeLeft(TimeUnit) - Method in class co.paralleluniverse.strands.Timeout

Returns how long is left before the timeout expires in the given time unit.

timeout(long, TimeUnit) - Static method in class co.paralleluniverse.strands.channels.TimeoutChannel

Timeout - Class in co.paralleluniverse.strands

Represents a timeout that can span several operations.

Timeout(long, TimeUnit) - Constructor for class co.paralleluniverse.strands.Timeout

Starts a new Timeout that begins now and expires within the given timeout from the instant this constructor has been called.

TimeoutChannel<Message> - Class in co.paralleluniverse.strands.channels

timer(String) - Static method in class co.paralleluniverse.common.monitoring.Metrics

timestamp - Variable in class co.paralleluniverse.common.benchmark.StripedLongTimeSeries.Record

timestamp - Variable in class co.paralleluniverse.common.benchmark.StripedTimeSeries.Record

timestamp - Variable in class co.paralleluniverse.common.monitoring.FlightRecorder.Record

toArray() - Method in class co.paralleluniverse.concurrent.util.ConcurrentSkipListPriorityQueue

toArray(T[]) - Method in class co.paralleluniverse.concurrent.util.ConcurrentSkipListPriorityQueue

toArray() - Method in class co.paralleluniverse.concurrent.util.DelayQueue

Returns an array containing all of the elements in this queue.

toArray(T[]) - Method in class co.paralleluniverse.concurrent.util.DelayQueue

Returns an array containing all of the elements in this queue; the runtime type of the returned array is that of the specified array.

toArray(T[]) - Method in class co.paralleluniverse.concurrent.util.SingleConsumerNonblockingProducerQueue

toArray() - Method in class co.paralleluniverse.concurrent.util.SingleConsumerNonblockingProducerQueue

toDataInput(InputStream) - Static method in class co.paralleluniverse.io.serialization.JDKSerializer

toDataOutput(OutputStream) - Static method in class co.paralleluniverse.io.serialization.JDKSerializer

toFuture(Fiber<V>) - Static method in class co.paralleluniverse.fibers.FiberUtil

Turns a fiber into a Future.

toMap(Object) - Static method in class co.paralleluniverse.concurrent.util.ThreadAccess

toObjectInput(InputStream) - Static method in class co.paralleluniverse.io.serialization.JDKSerializer

toObjectOutput(OutputStream) - Static method in class co.paralleluniverse.io.serialization.JDKSerializer

Topic<Message> - Class in co.paralleluniverse.strands.channels

A channel that forwards all messages to subscriber channels.

Topic() - Constructor for class co.paralleluniverse.strands.channels.Topic

toReceivePort(Iterator<T>) - Static method in class co.paralleluniverse.strands.channels.Channels

Returns a newly created ReceivePort that receives all the elements iterated by the iterator.

toReceivePort(Iterable<T>) - Static method in class co.paralleluniverse.strands.channels.Channels

Returns a newly created ReceivePort that receives all the elements iterated by the iterable.

toRunnable(SuspendableRunnable) - Static method in class co.paralleluniverse.strands.Strand

A utility method that converts a SuspendableRunnable to a Runnable so that it could run as the target of a thread.

toRunnable(SuspendableCallable<?>) - Static method in class co.paralleluniverse.strands.Strand

A utility method that converts a SuspendableCallable to a Runnable so that it could run as the target of a thread.

toString() - Method in class co.paralleluniverse.common.monitoring.FlightRecorder.Record

toString() - Method in class co.paralleluniverse.common.monitoring.FlightRecorderMessage

toString() - Method in class co.paralleluniverse.common.monitoring.GenericRecordingDouble

toString(Object) - Static method in class co.paralleluniverse.common.util.Debug

toString() - Method in class co.paralleluniverse.common.util.ExtendedStackTraceElement

toString(Member) - Method in class co.paralleluniverse.common.util.ExtendedStackTraceElement

toString() - Method in class co.paralleluniverse.common.util.Pair

toString() - Method in class co.paralleluniverse.common.util.Substring

toString() - Method in class co.paralleluniverse.concurrent.forkjoin.ParkableForkJoinTask

toString() - Method in class co.paralleluniverse.concurrent.util.SingleConsumerNonblockingProducerQueue

toString() - Method in class co.paralleluniverse.fibers.Fiber

toString() - Method in class co.paralleluniverse.strands.channels.DelegatingReceivePort

toString() - Method in class co.paralleluniverse.strands.channels.DelegatingSendPort

toString() - Method in class co.paralleluniverse.strands.channels.Mix.State

toString() - Method in class co.paralleluniverse.strands.channels.QueueChannel

toString() - Method in class co.paralleluniverse.strands.channels.SelectActionImpl

toString() - Method in class co.paralleluniverse.strands.channels.Selector

toString() - Method in class co.paralleluniverse.strands.channels.SingleConsumerQueueChannel

toString() - Method in class co.paralleluniverse.strands.channels.ThreadReceivePort

toString() - Method in class co.paralleluniverse.strands.channels.ThreadSendPort

toString() - Method in class co.paralleluniverse.strands.concurrent.AbstractQueuedLongSynchronizer

Returns a string identifying this synchronizer, as well as its state.

toString() - Method in class co.paralleluniverse.strands.concurrent.AbstractQueuedSynchronizer

Returns a string identifying this synchronizer, as well as its state.

toString() - Method in class co.paralleluniverse.strands.concurrent.CountDownLatch

Returns a string identifying this latch, as well as its state.

toString() - Method in class co.paralleluniverse.strands.concurrent.Phaser

Returns a string identifying this phaser, as well as its state.

toString() - Method in class co.paralleluniverse.strands.concurrent.ReentrantLock

Returns a string identifying this lock, as well as its lock state.

toString() - Method in class co.paralleluniverse.strands.concurrent.ReentrantReadWriteLock.ReadLock

Returns a string identifying this lock, as well as its lock state.

toString() - Method in class co.paralleluniverse.strands.concurrent.ReentrantReadWriteLock

Returns a string identifying this lock, as well as its lock state.

toString() - Method in class co.paralleluniverse.strands.concurrent.ReentrantReadWriteLock.WriteLock

Returns a string identifying this lock, as well as its lock state.

toString() - Method in class co.paralleluniverse.strands.concurrent.Semaphore

Returns a string identifying this semaphore, as well as its state.

toString() - Method in class co.paralleluniverse.strands.queues.SingleConsumerQueue

toString(StackTraceElement[]) - Static method in class co.paralleluniverse.strands.Strand

This utility method turns a stack-trace into a human readable, multi-line string.

TransferChannel<Message> - Class in co.paralleluniverse.strands.channels

TransferChannel() - Constructor for class co.paralleluniverse.strands.channels.TransferChannel

transferFrom(ReadableByteChannel, long, long) - Method in class co.paralleluniverse.fibers.io.FiberFileChannel

transferTo(long, long, WritableByteChannel) - Method in class co.paralleluniverse.fibers.io.FiberFileChannel

transform(ReceivePort<M>) - Static method in class co.paralleluniverse.strands.channels.Channels

Returns a TransformingReceivePort wrapping the given channel, which may be used for functional transformations.

transform(Object[]) - Method in class co.paralleluniverse.strands.channels.ZippingReceivePort

TransformingReceivePort<T> - Class in co.paralleluniverse.strands.channels

A ReceivePort with additional functional-transform operations, usually wrapping a plain ReceivePort.

TransformingSendPort<T> - Class in co.paralleluniverse.strands.channels

A SendPort with additional functional-transform operations, usually wrapping a plain SendPort.

transformSend(SendPort<M>) - Static method in class co.paralleluniverse.strands.channels.Channels

Returns a TransformingSendPort wrapping the given channel, which may be used for functional transformations.

TrueThreadLocal<T> - Class in co.paralleluniverse.fibers

A ThreadLocal that is local to the current thread, rather than Strand.

TrueThreadLocal() - Constructor for class co.paralleluniverse.fibers.TrueThreadLocal

truncate(long) - Method in class co.paralleluniverse.fibers.io.FiberFileChannel

tryAcquire(long) - Method in class co.paralleluniverse.strands.concurrent.AbstractQueuedLongSynchronizer

Attempts to acquire in exclusive mode.

tryAcquire(int) - Method in class co.paralleluniverse.strands.concurrent.AbstractQueuedSynchronizer

Attempts to acquire in exclusive mode.

tryAcquire() - Method in class co.paralleluniverse.strands.concurrent.Semaphore

Acquires a permit from this semaphore, only if one is available at the time of invocation.

tryAcquire(long, TimeUnit) - Method in class co.paralleluniverse.strands.concurrent.Semaphore

Acquires a permit from this semaphore, if one becomes available within the given waiting time and the current thread has not been interrupted.

tryAcquire(int) - Method in class co.paralleluniverse.strands.concurrent.Semaphore

Acquires the given number of permits from this semaphore, only if all are available at the time of invocation.

tryAcquire(int, long, TimeUnit) - Method in class co.paralleluniverse.strands.concurrent.Semaphore

Acquires the given number of permits from this semaphore, if all become available within the given waiting time and the current thread has not been interrupted.

tryAcquireNanos(long, long) - Method in class co.paralleluniverse.strands.concurrent.AbstractQueuedLongSynchronizer

Attempts to acquire in exclusive mode, aborting if interrupted, and failing if the given timeout elapses.

tryAcquireNanos(int, long) - Method in class co.paralleluniverse.strands.concurrent.AbstractQueuedSynchronizer

Attempts to acquire in exclusive mode, aborting if interrupted, and failing if the given timeout elapses.

tryAcquireShared(long) - Method in class co.paralleluniverse.strands.concurrent.AbstractQueuedLongSynchronizer

Attempts to acquire in shared mode.

tryAcquireShared(int) - Method in class co.paralleluniverse.strands.concurrent.AbstractQueuedSynchronizer

Attempts to acquire in shared mode.

tryAcquireSharedNanos(long, long) - Method in class co.paralleluniverse.strands.concurrent.AbstractQueuedLongSynchronizer

Attempts to acquire in shared mode, aborting if interrupted, and failing if the given timeout elapses.

tryAcquireSharedNanos(int, long) - Method in class co.paralleluniverse.strands.concurrent.AbstractQueuedSynchronizer

Attempts to acquire in shared mode, aborting if interrupted, and failing if the given timeout elapses.

tryConvertToOptimisticRead(long) - Method in class co.paralleluniverse.strands.concurrent.StampedLock

If the lock state matches the given stamp then, if the stamp represents holding a lock, releases it and returns an observation stamp.

tryConvertToReadLock(long) - Method in class co.paralleluniverse.strands.concurrent.StampedLock

If the lock state matches the given stamp, performs one of the following actions.

tryConvertToWriteLock(long) - Method in class co.paralleluniverse.strands.concurrent.StampedLock

If the lock state matches the given stamp, performs one of the following actions.

tryLock(long, long, boolean) - Method in class co.paralleluniverse.fibers.io.FiberFileChannel

tryLock() - Method in class co.paralleluniverse.strands.concurrent.ReentrantLock

Acquires the lock only if it is not held by another strand at the time of invocation.

tryLock(long, TimeUnit) - Method in class co.paralleluniverse.strands.concurrent.ReentrantLock

Acquires the lock if it is not held by another strand within the given waiting time and the current strand has not been interrupted.

tryLock() - Method in class co.paralleluniverse.strands.concurrent.ReentrantReadWriteLock.ReadLock

Acquires the read lock only if the write lock is not held by another strand at the time of invocation.

tryLock(long, TimeUnit) - Method in class co.paralleluniverse.strands.concurrent.ReentrantReadWriteLock.ReadLock

Acquires the read lock if the write lock is not held by another strand within the given waiting time and the current strand has not been interrupted.

tryLock() - Method in class co.paralleluniverse.strands.concurrent.ReentrantReadWriteLock.WriteLock

Acquires the write lock only if it is not held by another strand at the time of invocation.

tryLock(long, TimeUnit) - Method in class co.paralleluniverse.strands.concurrent.ReentrantReadWriteLock.WriteLock

Acquires the write lock if it is not held by another strand within the given waiting time and the current strand has not been interrupted.

tryNow(Object) - Method in class co.paralleluniverse.strands.channels.QueueChannel

tryNow(Object) - Method in interface co.paralleluniverse.strands.channels.Selectable

tryNow(Object) - Method in class co.paralleluniverse.strands.channels.TickerChannelConsumer

tryNow(Object) - Method in class co.paralleluniverse.strands.channels.TransferChannel

tryNow(Object) - Method in class co.paralleluniverse.strands.dataflow.ValChannel

tryOptimisticRead() - Method in class co.paralleluniverse.strands.concurrent.StampedLock

Returns a stamp that can later be validated, or zero if exclusively locked.

tryReadLock() - Method in class co.paralleluniverse.strands.concurrent.StampedLock

Non-exclusively acquires the lock if it is immediately available.

tryReadLock(long, TimeUnit) - Method in class co.paralleluniverse.strands.concurrent.StampedLock

Non-exclusively acquires the lock if it is available within the given time and the current strand has not been interrupted.

tryReceive() - Method in class co.paralleluniverse.strands.channels.DelegatingReceivePort

tryReceive() - Method in class co.paralleluniverse.strands.channels.FlatMappingReceivePort

tryReceive() - Method in class co.paralleluniverse.strands.channels.QueueChannel

tryReceive() - Method in interface co.paralleluniverse.strands.channels.ReceivePort

Retrieves a message from the channel if one is available.

tryReceive() - Method in class co.paralleluniverse.strands.channels.ReceivePortGroup

tryReceive() - Method in class co.paralleluniverse.strands.channels.SingleConsumerQueueChannel

tryReceive() - Method in class co.paralleluniverse.strands.channels.ThreadReceivePort

Retrieves a message from the channel if one is available.

tryReceive() - Method in class co.paralleluniverse.strands.channels.TickerChannelConsumer

tryReceive() - Method in class co.paralleluniverse.strands.channels.TransferChannel

tryReceive() - Method in class co.paralleluniverse.strands.channels.ZippingReceivePort

tryReceive() - Method in class co.paralleluniverse.strands.dataflow.ValChannel

tryRelease(long) - Method in class co.paralleluniverse.strands.concurrent.AbstractQueuedLongSynchronizer

Attempts to set the state to reflect a release in exclusive mode.

tryRelease(int) - Method in class co.paralleluniverse.strands.concurrent.AbstractQueuedSynchronizer

Attempts to set the state to reflect a release in exclusive mode.

tryReleaseShared(long) - Method in class co.paralleluniverse.strands.concurrent.AbstractQueuedLongSynchronizer

Attempts to set the state to reflect a release in shared mode.

tryReleaseShared(int) - Method in class co.paralleluniverse.strands.concurrent.AbstractQueuedSynchronizer

Attempts to set the state to reflect a release in shared mode.

trySelect(boolean, SelectAction<Message>...) - Static method in class co.paralleluniverse.strands.channels.Selector

Attempts to performs exactly one channel operation of a given set if one can be completed without blocking.

trySelect(boolean, List<? extends SelectAction<Message>>) - Static method in class co.paralleluniverse.strands.channels.Selector

Attempts to performs exactly one channel operation of a given set if one can be completed without blocking.

trySelect(SelectAction<Message>...) - Static method in class co.paralleluniverse.strands.channels.Selector

Attempts to performs exactly one channel operation of a given set if one can be completed without blocking.

trySelect(List<? extends SelectAction<Message>>) - Static method in class co.paralleluniverse.strands.channels.Selector

Attempts to performs exactly one channel operation of a given set if one can be completed without blocking.

trySelect() - Method in class co.paralleluniverse.strands.channels.Selector

trySend(T) - Method in class co.paralleluniverse.strands.channels.DelegatingSendPort

trySend(double) - Method in interface co.paralleluniverse.strands.channels.DoubleSendPort

Sends a message to the channel if the channel has room available.

trySend(float) - Method in interface co.paralleluniverse.strands.channels.FloatSendPort

Sends a message to the channel if the channel has room available.

trySend(int) - Method in interface co.paralleluniverse.strands.channels.IntSendPort

Sends a message to the channel if the channel has room available.

trySend(long) - Method in interface co.paralleluniverse.strands.channels.LongSendPort

Sends a message to the channel if the channel has room available.

trySend(Message) - Method in class co.paralleluniverse.strands.channels.QueueChannel

trySend(double) - Method in class co.paralleluniverse.strands.channels.QueueDoubleChannel

trySend(float) - Method in class co.paralleluniverse.strands.channels.QueueFloatChannel

trySend(int) - Method in class co.paralleluniverse.strands.channels.QueueIntChannel

trySend(long) - Method in class co.paralleluniverse.strands.channels.QueueLongChannel

trySend(Message) - Method in interface co.paralleluniverse.strands.channels.SendPort

Sends a message to the channel if the channel has room available.

trySend(Message) - Method in class co.paralleluniverse.strands.channels.SplitSendPort

trySend(Message) - Method in class co.paralleluniverse.strands.channels.ThreadSendPort

Sends a message to the channel if the channel has room available.

trySend(Message) - Method in class co.paralleluniverse.strands.channels.Topic

trySend(Message) - Method in class co.paralleluniverse.strands.channels.TransferChannel

tryUnlockRead() - Method in class co.paralleluniverse.strands.concurrent.StampedLock

Releases one hold of the read lock if it is held, without requiring a stamp value.

tryUnlockWrite() - Method in class co.paralleluniverse.strands.concurrent.StampedLock

Releases the write lock if it is held, without requiring a stamp value.

tryUnpark(Object) - Method in class co.paralleluniverse.concurrent.forkjoin.ParkableForkJoinTask

tryWriteLock() - Method in class co.paralleluniverse.strands.concurrent.StampedLock

Exclusively acquires the lock if it is immediately available.

tryWriteLock(long, TimeUnit) - Method in class co.paralleluniverse.strands.concurrent.StampedLock

Exclusively acquires the lock if it is available within the given time and the current strand has not been interrupted.

Tuple<E> - Class in co.paralleluniverse.common.util

Tuple() - Constructor for class co.paralleluniverse.common.util.Tuple

U

UnableToInstrumentException - Exception in co.paralleluniverse.fibers.instrument

This exception is thrown when an unsupported construct was found in a class that must be instrumented for suspension.

UnableToInstrumentException(String, String, String, String) - Constructor for exception co.paralleluniverse.fibers.instrument.UnableToInstrumentException

uncaughtException(Strand, Throwable) - Method in interface co.paralleluniverse.strands.Strand.UncaughtExceptionHandler

Method invoked when the given fiber terminates due to the given uncaught exception.

unlock() - Method in class co.paralleluniverse.strands.concurrent.ReentrantLock

Attempts to release this lock.

unlock() - Method in class co.paralleluniverse.strands.concurrent.ReentrantReadWriteLock.ReadLock

Attempts to release this lock.

unlock() - Method in class co.paralleluniverse.strands.concurrent.ReentrantReadWriteLock.WriteLock

Attempts to release this lock.

unlock(long) - Method in class co.paralleluniverse.strands.concurrent.StampedLock

If the lock state matches the given stamp, releases the corresponding mode of the lock.

unlockRead(long) - Method in class co.paralleluniverse.strands.concurrent.StampedLock

If the lock state matches the given stamp, releases the non-exclusive lock.

unlockWrite(long) - Method in class co.paralleluniverse.strands.concurrent.StampedLock

If the lock state matches the given stamp, releases the exclusive lock.

unpark() - Method in class co.paralleluniverse.concurrent.forkjoin.ParkableForkJoinTask

unpark(Object) - Method in class co.paralleluniverse.concurrent.forkjoin.ParkableForkJoinTask

unpark(ForkJoinPool, Object) - Method in class co.paralleluniverse.concurrent.forkjoin.ParkableForkJoinTask

unpark() - Method in class co.paralleluniverse.fibers.Fiber

Makes available the permit for this fiber, if it was not already available.

unpark(Object) - Method in class co.paralleluniverse.fibers.Fiber

unpark(Fiber, Object) - Static method in class co.paralleluniverse.fibers.FiberControl

unpark() - Method in class co.paralleluniverse.strands.Strand

Makes available the permit for this strand, if it was not already available.

unpark(Object) - Method in class co.paralleluniverse.strands.Strand

Makes available the permit for this strand, if it was not already available.

unpark(Strand) - Static method in class co.paralleluniverse.strands.Strand

Makes available the permit for the given strand, if it was not already available.

unpark(Strand, Object) - Static method in class co.paralleluniverse.strands.Strand

Makes available the permit for the given strand, if it was not already available.

unpark(Thread) - Static method in class co.paralleluniverse.strands.Strand

Makes available the permit for the given strand, if it was not already available.

unparkDeserialized(Fiber<V>, FiberScheduler) - Static method in class co.paralleluniverse.fibers.Fiber

Unparks a fiber that's been deserialized (with the help of Fiber.getFiberSerializer()

unparkSerialized(byte[], FiberScheduler) - Static method in class co.paralleluniverse.fibers.Fiber

Deserializes a fiber from the given byte array and unparks it.

unregister() - Method in class co.paralleluniverse.common.monitoring.ForkJoinPoolMonitor

unregister() - Method in class co.paralleluniverse.common.monitoring.JMXForkJoinPoolMonitor

unregister() - Method in interface co.paralleluniverse.fibers.FibersMonitor

unregister() - Method in class co.paralleluniverse.fibers.NoopFibersMonitor

unregister(Object) - Method in class co.paralleluniverse.strands.channels.QueueChannel

unregister(Object) - Method in interface co.paralleluniverse.strands.channels.Selectable

unregister(Object) - Method in class co.paralleluniverse.strands.channels.Selector

unregister(Object) - Method in class co.paralleluniverse.strands.channels.TickerChannelConsumer

unregister(Object) - Method in class co.paralleluniverse.strands.channels.TransferChannel

unregister(Object) - Method in interface co.paralleluniverse.strands.Condition

unregister(Object) - Method in class co.paralleluniverse.strands.ConditionSelector

unregister(Object) - Method in class co.paralleluniverse.strands.dataflow.ValChannel

unregister(Object) - Method in class co.paralleluniverse.strands.DoneSynchronizer

unregister(Object) - Method in class co.paralleluniverse.strands.OwnedSynchronizer

unregister(Object) - Method in class co.paralleluniverse.strands.SimpleConditionSynchronizer

unregister(Object) - Method in interface co.paralleluniverse.strands.Synchronization

unregisterMBean() - Method in class co.paralleluniverse.common.monitoring.SimpleMBean

unsubscribe(SendPort<? super Message>) - Method in class co.paralleluniverse.strands.channels.Topic

unsubscribeAll() - Method in class co.paralleluniverse.strands.channels.Topic

unwrap(Throwable) - Static method in class co.paralleluniverse.common.util.Exceptions

Unwraps several common wrapper exceptions and returns the underlying cause.

unwrapSuspendable(Runnable) - Static method in class co.paralleluniverse.strands.Strand

Returns the SuspendableCallable or SuspendableRunnable, wrapped by the given Runnable by toRunnable.

update(long) - Method in class co.paralleluniverse.common.monitoring.LatencyStatsReservoir

update(long) - Method in class co.paralleluniverse.common.monitoring.SimpleReservoir

UtilUnsafe - Class in co.paralleluniverse.common.util

Simple class to obtain access to the Unsafe object.

V

Val<V> - Class in co.paralleluniverse.strands.dataflow

A dataflow constant.

Val(SuspendableCallable<V>) - Constructor for class co.paralleluniverse.strands.dataflow.Val

Creates a Val whose value will be the one returned by the given SuspendableCallable, which will be spawned into a new fiber.

Val(FiberScheduler, SuspendableCallable<V>) - Constructor for class co.paralleluniverse.strands.dataflow.Val

Creates a Val whose value will be the one returned by the given SuspendableCallable, which will be spawned into a new fiber, scheduled by the given FiberScheduler.

Val() - Constructor for class co.paralleluniverse.strands.dataflow.Val

ValChannel<V> - Class in co.paralleluniverse.strands.dataflow

An adapter that turns a DelayedVal into a ReceivePort that receives the DelayedVal's value and then closes.

ValChannel(Val<V>) - Constructor for class co.paralleluniverse.strands.dataflow.ValChannel

validate(long) - Method in class co.paralleluniverse.strands.concurrent.StampedLock

Returns true if the lock has not been exclusively acquired since issuance of the given stamp.

value - Variable in class co.paralleluniverse.common.benchmark.StripedLongTimeSeries.Record

value - Variable in class co.paralleluniverse.common.benchmark.StripedTimeSeries.Record

value() - Method in interface co.paralleluniverse.strands.queues.QueueIterator

value(int) - Method in class co.paralleluniverse.strands.queues.SingleConsumerArrayObjectQueue

valueOf(String) - Static method in enum co.paralleluniverse.common.monitoring.ForkJoinPoolMonitor.Status

Returns the enum constant of this type with the specified name.

valueOf(String) - Static method in enum co.paralleluniverse.common.monitoring.MonitorType

Returns the enum constant of this type with the specified name.

valueOf(String) - Static method in enum co.paralleluniverse.fibers.instrument.LogLevel

Returns the enum constant of this type with the specified name.

valueOf(String) - Static method in enum co.paralleluniverse.fibers.instrument.MethodDatabase.SuspendableType

Returns the enum constant of this type with the specified name.

valueOf(String) - Static method in enum co.paralleluniverse.strands.channels.Channels.OverflowPolicy

Returns the enum constant of this type with the specified name.

valueOf(String) - Static method in enum co.paralleluniverse.strands.channels.Mix.Mode

Returns the enum constant of this type with the specified name.

valueOf(String) - Static method in enum co.paralleluniverse.strands.channels.Mix.SoloEffect

Returns the enum constant of this type with the specified name.

valueOf(String) - Static method in enum co.paralleluniverse.strands.Strand.State

Returns the enum constant of this type with the specified name.

values() - Static method in enum co.paralleluniverse.common.monitoring.ForkJoinPoolMonitor.Status

Returns an array containing the constants of this enum type, in the order they are declared.

values() - Static method in enum co.paralleluniverse.common.monitoring.MonitorType

Returns an array containing the constants of this enum type, in the order they are declared.

values() - Static method in enum co.paralleluniverse.fibers.instrument.LogLevel

Returns an array containing the constants of this enum type, in the order they are declared.

values() - Static method in enum co.paralleluniverse.fibers.instrument.MethodDatabase.SuspendableType

Returns an array containing the constants of this enum type, in the order they are declared.

values() - Static method in enum co.paralleluniverse.strands.channels.Channels.OverflowPolicy

Returns an array containing the constants of this enum type, in the order they are declared.

values() - Static method in enum co.paralleluniverse.strands.channels.Mix.Mode

Returns an array containing the constants of this enum type, in the order they are declared.

values() - Static method in enum co.paralleluniverse.strands.channels.Mix.SoloEffect

Returns an array containing the constants of this enum type, in the order they are declared.

values() - Static method in enum co.paralleluniverse.strands.Strand.State

Returns an array containing the constants of this enum type, in the order they are declared.

valuesAreEquivalent(long, long) - Method in class co.paralleluniverse.common.benchmark.StripedHistogram

Determine if two values are equivalent with the histogram's resolution.

Var<T> - Class in co.paralleluniverse.strands.dataflow

A dataflow variable.

Var(int, FiberScheduler, SuspendableCallable<T>) - Constructor for class co.paralleluniverse.strands.dataflow.Var

Creates a new Var, whose value is set to the value returned by the given function f; the function will be re-applied, and the Var's value re-set, whenever any of the Vars referenced by f change value.

Var(int, SuspendableCallable<T>) - Constructor for class co.paralleluniverse.strands.dataflow.Var

Creates a new Var, whose value is set to the value returned by the given function f; the function will be re-applied, and the Var's value re-set, whenever any of the Vars referenced by f change value.

Var(SuspendableCallable<T>) - Constructor for class co.paralleluniverse.strands.dataflow.Var

Creates a new Var with no history, whose value is set to the value returned by the given function f; the function will be re-applied, and the Var's value re-set, whenever any of the Vars referenced by f change value.

Var(FiberScheduler, SuspendableCallable<T>) - Constructor for class co.paralleluniverse.strands.dataflow.Var

Creates a new Var with no history, whose value is set to the value returned by the given function f; the function will be re-applied, and the Var's value re-set, whenever any of the Vars referenced by f change value.

Var(int) - Constructor for class co.paralleluniverse.strands.dataflow.Var

Creates a new Var.

Var() - Constructor for class co.paralleluniverse.strands.dataflow.Var

Creates a new Var with no history.

VerifyInstrumentationException - Exception in co.paralleluniverse.fibers

VerifyInstrumentationException(String) - Constructor for exception co.paralleluniverse.fibers.VerifyInstrumentationException

VisibleForTesting - Annotation Type in co.paralleluniverse.common.util

Indicates that the annotated element's visibility was increased only for testing purposes, but should have been "private".

visit(String, URL, ClassLoader) - Method in interface co.paralleluniverse.common.reflection.ClassLoaderUtil.Visitor

visit(int, int, String, String, String, String[]) - Method in class co.paralleluniverse.fibers.instrument.CheckInstrumentationVisitor

visit(int, int, String, String, String, String[]) - Method in class co.paralleluniverse.fibers.instrument.MethodDatabase.ExtractSuperClass

visitAnnotation(String, boolean) - Method in class co.paralleluniverse.fibers.instrument.CheckInstrumentationVisitor

visitMethod(int, String, String, String, String[]) - Method in class co.paralleluniverse.fibers.instrument.CheckInstrumentationVisitor

visitMethod(int, String, String, String, String[]) - Method in class co.paralleluniverse.fibers.instrument.FindAnnotatedMethods

visitSource(String, String) - Method in class co.paralleluniverse.fibers.instrument.CheckInstrumentationVisitor

VoidSuspendableCallable(SuspendableRunnable) - Constructor for class co.paralleluniverse.strands.SuspendableUtils.VoidSuspendableCallable

W

waitForRegistration() - Method in class co.paralleluniverse.fibers.FiberAsync

Spins until requestAsync returns.

WATCHMAN - Static variable in class co.paralleluniverse.common.test.TestUtil

whereIs(String) - Static method in class co.paralleluniverse.common.util.Debug

whereIs(Class<?>) - Static method in class co.paralleluniverse.common.util.Debug

withFixedThreadPool(int, ThreadFactory) - Static method in class co.paralleluniverse.fibers.io.ChannelGroup

Creates a channel group with a fixed thread pool.

withThreadPool(ExecutorService) - Static method in class co.paralleluniverse.fibers.io.ChannelGroup

Creates a channel group with a given thread pool.

won() - Method in class co.paralleluniverse.strands.channels.SelectActionImpl

WorkListEntry(String, File) - Constructor for class co.paralleluniverse.fibers.instrument.InstrumentationTask.WorkListEntry

wrapException(Throwable) - Method in class co.paralleluniverse.fibers.FiberAsync

Takes the exception generated by the async operation and possibly wraps it in an exception that will be thrown by the run method.

wrapException(Throwable) - Method in class co.paralleluniverse.fibers.futures.AsyncCompletionStage

wrapperToPrimitive(Class<?>) - Static method in class co.paralleluniverse.common.reflection.ReflectionUtil

write(Fiber, ByteArraySerializer) - Method in interface co.paralleluniverse.fibers.FiberWriter

write(ByteBuffer, long) - Method in class co.paralleluniverse.fibers.io.FiberFileChannel

Writes a sequence of bytes to this channel from the given buffer, starting at the given file position.

write(ByteBuffer) - Method in class co.paralleluniverse.fibers.io.FiberFileChannel

write(ByteBuffer[], int, int) - Method in class co.paralleluniverse.fibers.io.FiberFileChannel

write(ByteBuffer[]) - Method in class co.paralleluniverse.fibers.io.FiberFileChannel

write(ByteBuffer[], int, int, long, TimeUnit) - Method in class co.paralleluniverse.fibers.io.FiberSocketChannel

Writes a sequence of bytes to this channel from a subsequence of the given buffers.

write(ByteBuffer, long, TimeUnit) - Method in class co.paralleluniverse.fibers.io.FiberSocketChannel

Writes a sequence of bytes to this channel from the given buffer.

write(ByteBuffer[], int, int) - Method in class co.paralleluniverse.fibers.io.FiberSocketChannel

write(ByteBuffer[]) - Method in class co.paralleluniverse.fibers.io.FiberSocketChannel

write(ByteBuffer) - Method in class co.paralleluniverse.fibers.io.FiberSocketChannel

write(Kryo, Output, ThreadLocal<?>) - Method in class co.paralleluniverse.fibers.ThreadLocalSerializer

write(Object) - Method in interface co.paralleluniverse.io.serialization.ByteArraySerializer

write(OutputStream, Object) - Method in interface co.paralleluniverse.io.serialization.IOStreamSerializer

write(Object) - Method in class co.paralleluniverse.io.serialization.JDKSerializer

write(OutputStream, Object) - Method in class co.paralleluniverse.io.serialization.JDKSerializer

write(Kryo, Output, T) - Method in class co.paralleluniverse.io.serialization.kryo.ExternalizableKryoSerializer

write(Object) - Method in class co.paralleluniverse.io.serialization.kryo.KryoSerializer

write(OutputStream, Object) - Method in class co.paralleluniverse.io.serialization.kryo.KryoSerializer

write(Object) - Method in class co.paralleluniverse.io.serialization.Serialization

write(OutputStream, Object) - Method in class co.paralleluniverse.io.serialization.Serialization

writeClass(Output, Class) - Method in class co.paralleluniverse.io.serialization.kryo.ReplaceableObjectKryo

writeClassAndObject(Output, Object) - Method in class co.paralleluniverse.io.serialization.kryo.ReplaceableObjectKryo

writeLock() - Method in class co.paralleluniverse.strands.concurrent.ReentrantReadWriteLock

WriteLock(ReentrantReadWriteLock) - Constructor for class co.paralleluniverse.strands.concurrent.ReentrantReadWriteLock.WriteLock

Constructor for use by subclasses

writeLock() - Method in class co.paralleluniverse.strands.concurrent.StampedLock

Exclusively acquires the lock, blocking if necessary until available.

writeLockInterruptibly() - Method in class co.paralleluniverse.strands.concurrent.StampedLock

Exclusively acquires the lock, blocking if necessary until available or the current strand is interrupted.

writeObject(Output, Object, Serializer) - Method in class co.paralleluniverse.io.serialization.kryo.ReplaceableObjectKryo

WriteReplace - Interface in co.paralleluniverse.io.serialization

writeReplace(Object) - Method in interface co.paralleluniverse.io.serialization.WriteReplace

writeReplace() - Method in class co.paralleluniverse.strands.channels.QueueChannel

Y

yield() - Method in class co.paralleluniverse.concurrent.forkjoin.ParkableForkJoinTask

yield() - Static method in class co.paralleluniverse.fibers.Fiber

yield() - Static method in class co.paralleluniverse.strands.Strand

A hint to the scheduler that the current strand is willing to yield its current use of a processor.

yieldAndUnpark(Fiber, Object) - Static method in class co.paralleluniverse.fibers.Fiber

yieldAndUnpark(Fiber) - Static method in class co.paralleluniverse.fibers.Fiber

yieldAndUnpark(Strand, Object) - Static method in class co.paralleluniverse.strands.Strand

yieldAndUnpark(Strand) - Static method in class co.paralleluniverse.strands.Strand

Z

zip(List<? extends ReceivePort<?>>, Function<Object[], M>) - Static method in class co.paralleluniverse.strands.channels.Channels

Returns a ReceivePort that combines each vector of messages from a list of channels into a single combined message.

zip(ReceivePort<S1>, ReceivePort<S2>, Function2<S1, S2, M>) - Static method in class co.paralleluniverse.strands.channels.Channels

Returns a ReceivePort that combines each vector of messages from a vector of channels into a single combined message.

zip(ReceivePort<S1>, ReceivePort<S2>, ReceivePort<S3>, Function3<S1, S2, S3, M>) - Static method in class co.paralleluniverse.strands.channels.Channels

Returns a ReceivePort that combines each vector of messages from a vector of channels into a single combined message.

zip(ReceivePort<S1>, ReceivePort<S2>, ReceivePort<S3>, ReceivePort<S4>, Function4<S1, S2, S3, S4, M>) - Static method in class co.paralleluniverse.strands.channels.Channels

Returns a ReceivePort that combines each vector of messages from a vector of channels into a single combined message.

zip(ReceivePort<S1>, ReceivePort<S2>, ReceivePort<S3>, ReceivePort<S4>, ReceivePort<S5>, Function5<S1, S2, S3, S4, S5, M>) - Static method in class co.paralleluniverse.strands.channels.Channels

Returns a ReceivePort that combines each vector of messages from a vector of channels into a single combined message.

ZippingReceivePort<Message> - Class in co.paralleluniverse.strands.channels

Single consumer

ZippingReceivePort(Function<Object[], Message>, ReceivePort<?>...) - Constructor for class co.paralleluniverse.strands.channels.ZippingReceivePort

ZippingReceivePort(Function<Object[], Message>, List<? extends ReceivePort<?>>) - Constructor for class co.paralleluniverse.strands.channels.ZippingReceivePort

ZippingReceivePort(ReceivePort<?>...) - Constructor for class co.paralleluniverse.strands.channels.ZippingReceivePort

ZippingReceivePort(List<? extends ReceivePort<?>>) - Constructor for class co.paralleluniverse.strands.channels.ZippingReceivePort

A B C D E F G H I J K L M N O P Q R S T U V W Y Z