Nested and Inner Type Summary

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

Field Summary

Modifier and Type	Field and Description
private final long	asyncMask
private final Executor	executor
private long	mask
private final Join.Reaction[][]	reactionsPerChannel
public static final Executor	TRIVIAL_EXECUTOR
private final LinkedList<E>[]	writes

Access	Constructor and Description
private	Join(final long asyncMask, final Join.Reaction[][] reactionsPerChannel, Executor executor)

Method Summary

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

Inherited from java.lang.Object:: clone equals finalize getClass hashCode notify notifyAll toString wait wait wait

Field Detail

asyncMask	back to summary
private final long asyncMask

executor	back to summary
private final Executor executor

mask	back to summary
private long mask

reactionsPerChannel	back to summary
private final Join.Reaction[][] reactionsPerChannel

TRIVIAL_EXECUTOR	back to summary
public static final Executor TRIVIAL_EXECUTOR

writes	back to summary
private final LinkedList<E>[] writes

Join	back to summary
private Join(final long asyncMask, final Join.Reaction[][] reactionsPerChannel, Executor executor)

Method Detail

call	back to summary
public Object call(int channel, Object message)

call	back to summary
public Object call(Enum<?> channel, Object message)

isAsync	back to summary
public boolean isAsync(int channel)

send	back to summary
public void send(int channel, Object message)

send	back to summary
public void send(Enum<?> channel, Object message)

sendRaw	back to summary
private void sendRaw(int index, Object message)

org.jruby.util back to summary

private Class Join.AsyncCall

Class Inheritance

extends Call

java.lang.Object
org.jruby.util.Join.Call
org.jruby.util.Join.AsyncCall

Constructor Summary

Access	Constructor and Description
public	AsyncCall(Object message)

Method Summary

Modifier and Type	Method and Description
public void	activate(final Join join, final Join.SyncReaction reaction, final Object[] args) Implements abstract org.jruby.util.Join.Call.activate.

Inherited from org.jruby.util.Join.Call:: getMessage

Constructor Detail

AsyncCall	back to summary
public AsyncCall(Object message)

Method Detail

activate	back to summary
public void activate(final Join join, final Join.SyncReaction reaction, final Object[] args) Implements abstract org.jruby.util.Join.Call.activate.

org.jruby.util back to summary

public abstract Class Join.AsyncReaction

Class Inheritance

extends Reaction

java.lang.Object
org.jruby.util.Join.Reaction
org.jruby.util.Join.AsyncReaction

Constructor Summary

Access	Constructor and Description
public	AsyncReaction(int[] indices)
public	AsyncReaction(Enum<?> head, Enum<?>... channels)

Method Summary

Modifier and Type	Method and Description
pack-priv void	dispatch(final Join join, final Object[] args) Implements abstract org.jruby.util.Join.Reaction.dispatch.
public abstract void	react(Join join, Object[] args)

Constructor Detail

AsyncReaction	back to summary
public AsyncReaction(int[] indices)

AsyncReaction	back to summary
public AsyncReaction(Enum<?> head, Enum<?>... channels)

Method Detail

dispatch	back to summary
pack-priv void dispatch(final Join join, final Object[] args) Implements abstract org.jruby.util.Join.Reaction.dispatch. Annotations @Override

dispatch

back to summary

pack-priv void dispatch(final Join join, final Object[] args)

Implements abstract org.jruby.util.Join.Reaction.dispatch.

Annotations

@Override

react	back to summary
public abstract void react(Join join, Object[] args)

org.jruby.util back to summary

private abstract Class Join.Call

Class Inheritance

extends Object

java.lang.Object
org.jruby.util.Join.Call

Known Direct Subclasses

org.jruby.util.Join.AsyncCall, org.jruby.util.Join.SyncCall

Field Summary

Modifier and Type	Field and Description
private final Object	message

Constructor Summary

Access	Constructor and Description
public	Call(Object message)

Method Summary

Modifier and Type	Method and Description
public abstract void	activate(Join join, Join.SyncReaction reaction, Object[] args)
public Object	getMessage()

Inherited from java.lang.Object:: clone equals finalize getClass hashCode notify notifyAll toString wait wait wait

Field Detail

message	back to summary
private final Object message

Constructor Detail

Call	back to summary
public Call(Object message)

Method Detail

activate	back to summary
public abstract void activate(Join join, Join.SyncReaction reaction, Object[] args)

getMessage	back to summary
public Object getMessage()

org.jruby.util back to summary

public abstract Class Join.FastReaction

Class Inheritance

extends Reaction

java.lang.Object
org.jruby.util.Join.Reaction
org.jruby.util.Join.FastReaction

Constructor Summary

Access	Constructor and Description
public	FastReaction(int[] indices)
public	FastReaction(Enum<?> head, Enum<?>... channels)

Method Summary

Modifier and Type	Method and Description
pack-priv void	dispatch(final Join join, final Object[] args) Implements abstract org.jruby.util.Join.Reaction.dispatch.
public abstract void	react(Join join, Object[] args)

Constructor Detail

FastReaction	back to summary
public FastReaction(int[] indices)

FastReaction	back to summary
public FastReaction(Enum<?> head, Enum<?>... channels)

Method Detail

dispatch	back to summary
pack-priv void dispatch(final Join join, final Object[] args) Implements abstract org.jruby.util.Join.Reaction.dispatch. Annotations @Override

dispatch

back to summary

pack-priv void dispatch(final Join join, final Object[] args)

Implements abstract org.jruby.util.Join.Reaction.dispatch.

Annotations

@Override

react	back to summary
public abstract void react(Join join, Object[] args)

org.jruby.util back to summary

public abstract Class Join.Reaction

Class Inheritance

extends Object

java.lang.Object
org.jruby.util.Join.Reaction

Known Direct Subclasses

org.jruby.util.Join.FastReaction, org.jruby.util.Join.AsyncReaction, org.jruby.util.Join.SyncReaction

Field Summary

Modifier and Type	Field and Description
private final long	asyncMask
private final int[]	indices
private final long	mask

Constructor Summary

Access	Constructor and Description
pack-priv	Reaction(Enum<?> head, Enum<?>[] channels, boolean isAsync)
pack-priv	Reaction(int[] indices, boolean isAsync)

Method Summary

Modifier and Type	Method and Description
pack-priv abstract void	dispatch(Join join, Object[] args)
private static int[]	toIndices(Enum<?> head, Enum<?>[] channels)

Inherited from java.lang.Object:: clone equals finalize getClass hashCode notify notifyAll toString wait wait wait

Field Detail

asyncMask	back to summary
private final long asyncMask

indices	back to summary
private final int[] indices

mask	back to summary
private final long mask

Constructor Detail

Reaction	back to summary
pack-priv Reaction(Enum<?> head, Enum<?>[] channels, boolean isAsync)

Reaction	back to summary
pack-priv Reaction(int[] indices, boolean isAsync)

Method Detail

dispatch	back to summary
pack-priv abstract void dispatch(Join join, Object[] args)

toIndices	back to summary
private static int[] toIndices(Enum<?> head, Enum<?>[] channels)

org.jruby.util back to summary

public Class Join.Spec

Class Inheritance

extends Object

java.lang.Object
org.jruby.util.Join.Spec

Field Summary

Modifier and Type	Field and Description
private long	asyncMask
private volatile Join.Reaction[][]	cachedReactionsPerChannel
private static final Join.Reaction[]	EMPTY_REACTIONS
private long	mask
private final ArrayList<ArrayList<Join.Reaction>>	reactionsPerChannel

Constructor Summary

Access	Constructor and Description
public	Spec()

Method Summary

Modifier and Type	Method and Description
public void	addReaction(Join.Reaction reaction)
public Join	createJoin()
public Join	createJoin(final Executor executor)

Inherited from java.lang.Object:: clone equals finalize getClass hashCode notify notifyAll toString wait wait wait

Field Detail

asyncMask	back to summary
private long asyncMask

cachedReactionsPerChannel	back to summary
private volatile Join.Reaction[][] cachedReactionsPerChannel

EMPTY_REACTIONS	back to summary
private static final Join.Reaction[] EMPTY_REACTIONS

mask	back to summary
private long mask

reactionsPerChannel	back to summary
private final ArrayList<ArrayList<Join.Reaction>> reactionsPerChannel

Constructor Detail

Spec	back to summary
public Spec()

Method Detail

addReaction	back to summary
public void addReaction(Join.Reaction reaction)

createJoin	back to summary
public Join createJoin()

createJoin	back to summary
public Join createJoin(final Executor executor)

org.jruby.util back to summary

private Class Join.SyncCall

Class Inheritance

extends Call

java.lang.Object
org.jruby.util.Join.Call
org.jruby.util.Join.SyncCall

Field Summary

Modifier and Type	Field and Description
private Object[]	args
private Join	join
private Join.SyncReaction	reaction

Constructor Summary

Access	Constructor and Description
public	SyncCall(Object message)

Method Summary

Modifier and Type	Method and Description
public synchronized void	activate(Join join, Join.SyncReaction reaction, Object[] args) Implements abstract org.jruby.util.Join.Call.activate.
public synchronized Object	call()

Inherited from org.jruby.util.Join.Call:: getMessage

Field Detail

args	back to summary
private Object[] args

join	back to summary
private Join join

reaction	back to summary
private Join.SyncReaction reaction

Constructor Detail

SyncCall	back to summary
public SyncCall(Object message)

Method Detail

activate	back to summary
public synchronized void activate(Join join, Join.SyncReaction reaction, Object[] args) Implements abstract org.jruby.util.Join.Call.activate.

call	back to summary
public synchronized Object call()

org.jruby.util back to summary

public abstract Class Join.SyncReaction

Class Inheritance

extends Reaction

java.lang.Object
org.jruby.util.Join.Reaction
org.jruby.util.Join.SyncReaction

Constructor Summary

Access	Constructor and Description
public	SyncReaction(int[] indices)
public	SyncReaction(Enum<?> head, Enum<?>... channels)

Method Summary

Modifier and Type	Method and Description
pack-priv void	dispatch(Join join, final Object[] args) Implements abstract org.jruby.util.Join.Reaction.dispatch.
public abstract Object	react(Join join, Object[] args)

Constructor Detail

SyncReaction	back to summary
public SyncReaction(int[] indices)

SyncReaction	back to summary
public SyncReaction(Enum<?> head, Enum<?>... channels)

Method Detail

dispatch

back to summary

pack-priv void dispatch(Join join, final Object[] args)

Implements abstract org.jruby.util.Join.Reaction.dispatch.

Annotations

@Override

react	back to summary
public abstract Object react(Join join, Object[] args)

public final Class Join

Nested and Inner Type Summary

Field Summary

Constructor Summary

Method Summary

Field Detail

Constructor Detail

Method Detail

private Class Join.AsyncCall

Constructor Summary

Method Summary

Constructor Detail

Method Detail

public abstract Class Join.AsyncReaction

Constructor Summary

Method Summary

Constructor Detail

Method Detail

private abstract Class Join.Call

Field Summary

Constructor Summary

Method Summary

Field Detail

Constructor Detail

Method Detail

public abstract Class Join.FastReaction

Constructor Summary

Method Summary

Constructor Detail

Method Detail

public abstract Class Join.Reaction

Field Summary

Constructor Summary

Method Summary

Field Detail

Constructor Detail

Method Detail

public Class Join.Spec

Field Summary

Constructor Summary

Method Summary

Field Detail

Constructor Detail

Method Detail

private Class Join.SyncCall

Field Summary

Constructor Summary

Method Summary

Field Detail

Constructor Detail

Method Detail

public abstract Class Join.SyncReaction

Constructor Summary

Method Summary

Constructor Detail

Method Detail