org.jboss.as.clustering.jgroups

Class TimerSchedulerAdapter

java.lang.Object

org.jboss.as.clustering.jgroups.TimerSchedulerAdapter

All Implemented Interfaces:

org.jgroups.util.TimeScheduler

public class TimerSchedulerAdapter
extends Object
implements org.jgroups.util.TimeScheduler

Adapts a ScheduledExecutorService to a TimeScheduler. Disallow modification of the pool itself - this should be done via the threading subsystem directly.

Author:

Paul Ferraro

Nested Class Summary

Nested classes/interfaces inherited from interface org.jgroups.util.TimeScheduler

org.jgroups.util.TimeScheduler.Task

Constructor Summary

Constructors

Constructor and Description
TimerSchedulerAdapter(ScheduledExecutorService executor)

Method Summary

Modifier and Type	Method and Description
String	dumpTimerTasks()
void	execute(Runnable command)
int	getCurrentThreads()
long	getKeepAliveTime()
int	getMaxThreads()
int	getMinThreads()
boolean	isShutdown()
ScheduledFuture<?>	schedule(Runnable command, long delay, TimeUnit unit)
ScheduledFuture<?>	scheduleAtFixedRate(Runnable command, long initialDelay, long period, TimeUnit unit)
ScheduledFuture<?>	scheduleWithDynamicInterval(org.jgroups.util.TimeScheduler.Task task)
ScheduledFuture<?>	scheduleWithFixedDelay(Runnable command, long initialDelay, long delay, TimeUnit unit)
void	setKeepAliveTime(long time)
void	setMaxThreads(int size)
void	setMinThreads(int size)
void	setThreadFactory(org.jgroups.util.ThreadFactory factory)
int	size()
void	stop()

Methods inherited from class java.lang.Object

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

Constructor Detail

TimerSchedulerAdapter

public TimerSchedulerAdapter(ScheduledExecutorService executor)

Method Detail

execute

public void execute(Runnable command)

Specified by:

execute in interface org.jgroups.util.TimeScheduler

schedule

public ScheduledFuture<?> schedule(Runnable command,
                                   long delay,
                                   TimeUnit unit)

Specified by:

schedule in interface org.jgroups.util.TimeScheduler

scheduleWithFixedDelay

public ScheduledFuture<?> scheduleWithFixedDelay(Runnable command,
                                                 long initialDelay,
                                                 long delay,
                                                 TimeUnit unit)

Specified by:

scheduleWithFixedDelay in interface org.jgroups.util.TimeScheduler

scheduleAtFixedRate

public ScheduledFuture<?> scheduleAtFixedRate(Runnable command,
                                              long initialDelay,
                                              long period,
                                              TimeUnit unit)

Specified by:

scheduleAtFixedRate in interface org.jgroups.util.TimeScheduler

scheduleWithDynamicInterval

public ScheduledFuture<?> scheduleWithDynamicInterval(org.jgroups.util.TimeScheduler.Task task)

Specified by:

scheduleWithDynamicInterval in interface org.jgroups.util.TimeScheduler

setThreadFactory

public void setThreadFactory(org.jgroups.util.ThreadFactory factory)

Specified by:

setThreadFactory in interface org.jgroups.util.TimeScheduler

dumpTimerTasks

public String dumpTimerTasks()

Specified by:

dumpTimerTasks in interface org.jgroups.util.TimeScheduler

getMinThreads

public int getMinThreads()

Specified by:

getMinThreads in interface org.jgroups.util.TimeScheduler

setMinThreads

public void setMinThreads(int size)

Specified by:

setMinThreads in interface org.jgroups.util.TimeScheduler

getMaxThreads

public int getMaxThreads()

Specified by:

getMaxThreads in interface org.jgroups.util.TimeScheduler

setMaxThreads

public void setMaxThreads(int size)

Specified by:

setMaxThreads in interface org.jgroups.util.TimeScheduler

getKeepAliveTime

public long getKeepAliveTime()

Specified by:

getKeepAliveTime in interface org.jgroups.util.TimeScheduler

setKeepAliveTime

public void setKeepAliveTime(long time)

Specified by:

setKeepAliveTime in interface org.jgroups.util.TimeScheduler

getCurrentThreads

public int getCurrentThreads()

Specified by:

getCurrentThreads in interface org.jgroups.util.TimeScheduler

size

public int size()

Specified by:

size in interface org.jgroups.util.TimeScheduler

stop

public void stop()

Specified by:

stop in interface org.jgroups.util.TimeScheduler

isShutdown

public boolean isShutdown()

Specified by:

isShutdown in interface org.jgroups.util.TimeScheduler