org.wandora.utils

Class ParallelListenerList<T>

java.lang.Object

org.wandora.utils.ParallelListenerList<T>

public class ParallelListenerList<T>
extends java.lang.Object

This is like ListenerList but several events can be firing simultaneously in several threads. ListenerList synchronizes on the list itself meaning that another event will not start processing until the previous one is done, this class avoids that problem by using a different locking mechanism. This somewhat obfuscates the behaviour of modifying the list while events are firing. Changes are still gathered into a separate changes list but those changes are not processed until all currently firing events have finished. If the changes list is not empty, processing of new events will wait until the changes list has been cleared.

Author:

olli

Nested Class Summary

Nested Classes

Modifier and Type	Class and Description
static interface	ParallelListenerList.EachDelegate<T>
static interface	ParallelListenerList.ListenerFilter<T>

Field Summary

Fields

Modifier and Type	Field and Description
protected java.util.ArrayList<Tuples.T2<T,java.lang.Boolean>>	changes
protected java.lang.Class<T>	cls
protected int	iterating
protected java.util.ArrayList<T>	listeners
protected java.util.HashMap<java.lang.String,java.lang.reflect.Method>	methods
protected boolean	returnValues

Constructor Summary

Constructors

Constructor and Description
ParallelListenerList(java.lang.Class<T> cls)

Method Summary

Modifier and Type	Method and Description
void	addListener(T l)
java.lang.reflect.Method	findMethod(java.lang.String event)
java.lang.Object[]	fireEvent(java.lang.reflect.Method m, java.lang.Object... params)
java.lang.Object[]	fireEvent(java.lang.String event, java.lang.Object... params)
java.lang.Object[]	fireEventFiltered(java.lang.reflect.Method m, ListenerList.ListenerFilter<T> filter, java.lang.Object... params)
java.lang.Object[]	fireEventFiltered(java.lang.String event, ListenerList.ListenerFilter<T> filter, java.lang.Object... params)
void	forEach(ListenerList.EachDelegate delegate, java.lang.Object... params)
boolean	isEmpty()
boolean	isReturnValues()
protected void	processChanges()
void	removeListener(T l)
void	setReturnValues(boolean returnValues)
int	size()

Methods inherited from class java.lang.Object

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

Field Detail

listeners

protected final java.util.ArrayList<T> listeners

changes

protected final java.util.ArrayList<Tuples.T2<T,java.lang.Boolean>> changes

cls

protected java.lang.Class<T> cls

methods

protected final java.util.HashMap<java.lang.String,java.lang.reflect.Method> methods

returnValues

protected boolean returnValues

iterating

protected int iterating

Constructor Detail

ParallelListenerList

public ParallelListenerList(java.lang.Class<T> cls)

Method Detail

size

public int size()

isEmpty

public boolean isEmpty()

isReturnValues

public boolean isReturnValues()

setReturnValues

public void setReturnValues(boolean returnValues)

addListener

public void addListener(T l)

removeListener

public void removeListener(T l)

processChanges

protected void processChanges()

findMethod

public java.lang.reflect.Method findMethod(java.lang.String event)

fireEvent

public java.lang.Object[] fireEvent(java.lang.reflect.Method m,
                                    java.lang.Object... params)

fireEventFiltered

public java.lang.Object[] fireEventFiltered(java.lang.reflect.Method m,
                                            ListenerList.ListenerFilter<T> filter,
                                            java.lang.Object... params)

fireEvent

public java.lang.Object[] fireEvent(java.lang.String event,
                                    java.lang.Object... params)

fireEventFiltered

public java.lang.Object[] fireEventFiltered(java.lang.String event,
                                            ListenerList.ListenerFilter<T> filter,
                                            java.lang.Object... params)

forEach

public void forEach(ListenerList.EachDelegate delegate,
                    java.lang.Object... params)