org.jruby.util

Class Join

java.lang.Object

org.jruby.util.Join

public final class Join
extends java.lang.Object

Nested Class Summary

Nested Classes

Modifier and Type	Class and Description
private static class	Join.AsyncCall
static class	Join.AsyncReaction
private static class	Join.Call
static class	Join.FastReaction
static class	Join.Reaction
static class	Join.Spec
private static class	Join.SyncCall
static class	Join.SyncReaction

Field Summary

Fields

Modifier and Type	Field and Description
private long	asyncMask
private java.util.concurrent.Executor	executor
private long	mask
private Join.Reaction[][]	reactionsPerChannel
static java.util.concurrent.Executor	TRIVIAL_EXECUTOR
private java.util.LinkedList[]	writes

Constructor Summary

Constructors

Modifier	Constructor and Description
private	Join(long asyncMask, Join.Reaction[][] reactionsPerChannel, java.util.concurrent.Executor executor)

Method Summary

Modifier and Type	Method and Description
java.lang.Object	call(java.lang.Enum<?> channel, java.lang.Object message)
java.lang.Object	call(int channel, java.lang.Object message)
boolean	isAsync(int channel)
void	send(java.lang.Enum<?> channel, java.lang.Object message)
void	send(int channel, java.lang.Object message)
private void	sendRaw(int index, java.lang.Object message)

Methods inherited from class java.lang.Object

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

Field Detail

TRIVIAL_EXECUTOR

public static final java.util.concurrent.Executor TRIVIAL_EXECUTOR

executor

private final java.util.concurrent.Executor executor

writes

private final java.util.LinkedList[] writes

asyncMask

private final long asyncMask

mask

private long mask

reactionsPerChannel

private final Join.Reaction[][] reactionsPerChannel

Constructor Detail

Join

private Join(long asyncMask,
             Join.Reaction[][] reactionsPerChannel,
             java.util.concurrent.Executor executor)

Method Detail

sendRaw

private void sendRaw(int index,
                     java.lang.Object message)

isAsync

public boolean isAsync(int channel)

send

public void send(int channel,
                 java.lang.Object message)

send

public void send(java.lang.Enum<?> channel,
                 java.lang.Object message)

call

public java.lang.Object call(int channel,
                             java.lang.Object message)

call

public java.lang.Object call(java.lang.Enum<?> channel,
                             java.lang.Object message)