Class ListenerManager<T>

java.lang.Object

com.biglybt.core.util.ListenerManager<T>

public class ListenerManager<T>
extends Object

Field Summary

Fields

Modifier and Type	Field	Description
private final boolean	async
private AEThread2	async_thread
private List<Object[]>	dispatch_queue
private AESemaphore	dispatch_sem
private CopyOnWriteList<T>	listeners
private int	logged_too_many_count_next
private final String	name
private final ListenerManagerDispatcher<T>	target
private ListenerManagerDispatcherWithException<T>	target_with_exception
private static final boolean	TIME_LISTENERS

Constructor Summary

Constructors

Modifier	Constructor	Description
protected	ListenerManager(String _name, ListenerManagerDispatcher<T> _target, boolean _async)

Method Summary

Modifier and Type	Method	Description
void	addListener(T listener)
void	clear()
static <T> ListenerManager<T>	createAsyncManager(String name, ListenerManagerDispatcher<T> target)
static <T> ListenerManager<T>	createManager(String name, ListenerManagerDispatcher<T> target)
void	dispatch(int type, Object value)
void	dispatch(int type, Object value, boolean blocking)
void	dispatch(T listener, int type, Object value)
void	dispatch(T listener, int type, Object value, boolean blocking)
protected void	dispatchInternal(List<T> listeners_ref, int type, Object value)
protected void	dispatchInternal(T listener, int type, Object value)
void	dispatchLoop()
void	dispatchWithException(int type, Object value)
static <T> void	dispatchWithTimeout(List<T> _listeners, ListenerManagerDispatcher<T> _dispatcher, long _timeout)
protected void	doDispatch(T listener, int type, Object value)
protected void	doDispatchWithException(T listener, int type, Object value)
protected String	getListenerName(T listener)
List<T>	getListenersCopy()
boolean	hasListener(T listener)
void	removeListener(T listener)
long	size()

Methods inherited from class Object

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

Field Details

TIME_LISTENERS

private static final boolean TIME_LISTENERS

See Also:

• Constant Field Values

name

private final String name

target

private final ListenerManagerDispatcher<T> target

target_with_exception

private ListenerManagerDispatcherWithException<T> target_with_exception

async

private final boolean async

async_thread

private AEThread2 async_thread

listeners

private CopyOnWriteList<T> listeners

dispatch_queue

private List<Object[]> dispatch_queue

dispatch_sem

private AESemaphore dispatch_sem

logged_too_many_count_next

private int logged_too_many_count_next

Constructor Details

ListenerManager

protected ListenerManager(String _name,
 ListenerManagerDispatcher<T> _target,
 boolean _async)

Method Details

createManager

public static <T> ListenerManager<T> createManager(String name,
 ListenerManagerDispatcher<T> target)

createAsyncManager

public static <T> ListenerManager<T> createAsyncManager(String name,
 ListenerManagerDispatcher<T> target)

addListener

public void addListener(T listener)

removeListener

public void removeListener(T listener)

hasListener

public boolean hasListener(T listener)

clear

public void clear()

getListenersCopy

public List<T> getListenersCopy()

dispatch

public void dispatch(int type,
 Object value)

dispatch

public void dispatch(int type,
 Object value,
 boolean blocking)

dispatchWithException

public void dispatchWithException(int type,
 Object value)
                           throws Throwable

Throws:

Throwable

dispatch

public void dispatch(T listener,
 int type,
 Object value)

dispatch

public void dispatch(T listener,
 int type,
 Object value,
 boolean blocking)

getListenerName

protected String getListenerName(T listener)

doDispatch

protected void doDispatch(T listener,
 int type,
 Object value)

doDispatchWithException

protected void doDispatchWithException(T listener,
 int type,
 Object value)
                                throws Throwable

Throws:

Throwable

dispatchInternal

protected void dispatchInternal(List<T> listeners_ref,
 int type,
 Object value)
                         throws Throwable

Throws:

Throwable

dispatchInternal

protected void dispatchInternal(T listener,
 int type,
 Object value)
                         throws Throwable

Throws:

Throwable

dispatchLoop

public void dispatchLoop()

dispatchWithTimeout

public static <T> void dispatchWithTimeout(List<T> _listeners,
 ListenerManagerDispatcher<T> _dispatcher,
 long _timeout)

size

public long size()