public class AppJobManager extends AppServiceBase<AppJobManager>
Destroyable.Util
logger
Constructor and Description |
---|
AppJobManager(App app) |
Modifier and Type | Method and Description |
---|---|
void |
afterAppStart(java.lang.Runnable runnable) |
void |
alongWith(AppEventId appEvent,
java.lang.String jobId,
java.lang.Runnable runnable) |
void |
beforeAppStart(java.lang.Runnable runnable) |
void |
beforeAppStop(java.lang.Runnable runnable) |
void |
cancel(java.lang.String jobId)
Cancel a scheduled Job by ID
|
<T> java.util.concurrent.Future<T> |
delay(java.util.concurrent.Callable<T> callable,
long delay,
java.util.concurrent.TimeUnit timeUnit) |
<T> java.util.concurrent.Future<T> |
delay(java.util.concurrent.Callable<T> callable,
java.lang.String delay) |
void |
delay(java.lang.Runnable runnable,
long delay,
java.util.concurrent.TimeUnit timeUnit) |
void |
delay(java.lang.Runnable runnable,
java.lang.String delay) |
void |
every(java.lang.Runnable runnable,
long interval,
java.util.concurrent.TimeUnit timeUnit) |
void |
every(java.lang.Runnable runnable,
java.lang.String interval) |
void |
every(java.lang.String id,
java.lang.Runnable runnable,
long interval,
java.util.concurrent.TimeUnit timeUnit) |
void |
every(java.lang.String id,
java.lang.Runnable runnable,
java.lang.String interval) |
void |
fixedDelay(java.lang.Runnable runnable,
long interval,
java.util.concurrent.TimeUnit timeUnit) |
void |
fixedDelay(java.lang.Runnable runnable,
java.lang.String interval) |
void |
fixedDelay(java.lang.String id,
java.lang.Runnable runnable,
long interval,
java.util.concurrent.TimeUnit timeUnit) |
void |
fixedDelay(java.lang.String id,
java.lang.Runnable runnable,
java.lang.String interval) |
<T> java.util.concurrent.Future<T> |
now(java.util.concurrent.Callable<T> callable) |
java.lang.String |
now(org.osgl.Osgl.Function<ProgressGauge,?> worker) |
void |
now(java.lang.Runnable runnable) |
void |
now(java.lang.String jobId)
Run a job by ID now
|
<T> java.util.concurrent.Future<T> |
now(java.lang.String jobId,
java.util.concurrent.Callable<T> callable) |
java.lang.String |
now(java.lang.String jobId,
org.osgl.Osgl.Function<ProgressGauge,?> worker) |
void |
now(java.lang.String jobId,
java.lang.Runnable runnable) |
void |
on(AppEventId appEvent,
java.lang.Runnable runnable) |
void |
on(AppEventId appEvent,
java.lang.Runnable runnable,
boolean runImmediatelyIfEventDispatched) |
void |
on(AppEventId appEvent,
java.lang.String jobId,
java.lang.Runnable runnable) |
void |
on(AppEventId appEvent,
java.lang.String jobId,
java.lang.Runnable runnable,
boolean runImmediatelyIfEventDispatched) |
<T> java.util.concurrent.Future<T> |
on(org.joda.time.DateTime instant,
java.util.concurrent.Callable<T> callable) |
void |
on(org.joda.time.DateTime instant,
java.lang.Runnable runnable) |
void |
post(AppEventId appEvent,
java.lang.Runnable runnable) |
void |
post(AppEventId appEvent,
java.lang.Runnable runnable,
boolean runImmediatelyIfEventDispatched) |
void |
post(AppEventId appEvent,
java.lang.String jobId,
java.lang.Runnable runnable) |
void |
post(AppEventId appEvent,
java.lang.String jobId,
java.lang.Runnable runnable,
boolean runImmediatelyIfEventDispatched) |
java.lang.String |
prepare(org.osgl.Osgl.Function<ProgressGauge,?> worker)
Prepare a job from worker.
|
SimpleProgressGauge |
progressGauge(java.lang.String jobId) |
protected void |
releaseResources() |
void |
setJobProgressGauge(java.lang.String jobId,
ProgressGauge progressGauge) |
protected void |
warn(java.lang.String format,
java.lang.Object... args) |
app, onAppStart, onAppStartAsync
app, me
addSubResource, destroy, isDestroyed, reload, scope
debug, debug, error, error, fatal, fatal, info, info, isDebugEnabled, isTraceEnabled, trace, trace, warn
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
destroy, isDestroyed, scope
public AppJobManager(App app)
protected void releaseResources()
releaseResources
in class AppServiceBase<AppJobManager>
public <T> java.util.concurrent.Future<T> now(java.util.concurrent.Callable<T> callable)
public <T> java.util.concurrent.Future<T> now(java.lang.String jobId, java.util.concurrent.Callable<T> callable)
public void now(java.lang.Runnable runnable)
public void now(java.lang.String jobId, java.lang.Runnable runnable)
public java.lang.String now(org.osgl.Osgl.Function<ProgressGauge,?> worker)
public java.lang.String now(java.lang.String jobId, org.osgl.Osgl.Function<ProgressGauge,?> worker)
public java.lang.String prepare(org.osgl.Osgl.Function<ProgressGauge,?> worker)
Prepare a job from worker. This function will return a job ID and can be used to feed into the now(String)
call
worker
- the workerpublic void now(java.lang.String jobId)
Run a job by ID now
jobId
- the job IDprepare(Osgl.Function)
public <T> java.util.concurrent.Future<T> delay(java.util.concurrent.Callable<T> callable, long delay, java.util.concurrent.TimeUnit timeUnit)
public void delay(java.lang.Runnable runnable, long delay, java.util.concurrent.TimeUnit timeUnit)
public <T> java.util.concurrent.Future<T> delay(java.util.concurrent.Callable<T> callable, java.lang.String delay)
public void delay(java.lang.Runnable runnable, java.lang.String delay)
public void every(java.lang.String id, java.lang.Runnable runnable, java.lang.String interval)
public void every(java.lang.Runnable runnable, java.lang.String interval)
public void every(java.lang.Runnable runnable, long interval, java.util.concurrent.TimeUnit timeUnit)
public void every(java.lang.String id, java.lang.Runnable runnable, long interval, java.util.concurrent.TimeUnit timeUnit)
public void fixedDelay(java.lang.Runnable runnable, java.lang.String interval)
public void fixedDelay(java.lang.String id, java.lang.Runnable runnable, java.lang.String interval)
public void fixedDelay(java.lang.Runnable runnable, long interval, java.util.concurrent.TimeUnit timeUnit)
public void fixedDelay(java.lang.String id, java.lang.Runnable runnable, long interval, java.util.concurrent.TimeUnit timeUnit)
public void on(org.joda.time.DateTime instant, java.lang.Runnable runnable)
public <T> java.util.concurrent.Future<T> on(org.joda.time.DateTime instant, java.util.concurrent.Callable<T> callable)
public void on(AppEventId appEvent, java.lang.Runnable runnable)
public void on(AppEventId appEvent, java.lang.Runnable runnable, boolean runImmediatelyIfEventDispatched)
public void post(AppEventId appEvent, java.lang.Runnable runnable)
public void post(AppEventId appEvent, java.lang.Runnable runnable, boolean runImmediatelyIfEventDispatched)
public void on(AppEventId appEvent, java.lang.String jobId, java.lang.Runnable runnable)
public void on(AppEventId appEvent, java.lang.String jobId, java.lang.Runnable runnable, boolean runImmediatelyIfEventDispatched)
public void post(AppEventId appEvent, java.lang.String jobId, java.lang.Runnable runnable)
public void post(AppEventId appEvent, java.lang.String jobId, java.lang.Runnable runnable, boolean runImmediatelyIfEventDispatched)
public void alongWith(AppEventId appEvent, java.lang.String jobId, java.lang.Runnable runnable)
protected void warn(java.lang.String format, java.lang.Object... args)
warn
in class LogSupport
public void cancel(java.lang.String jobId)
Cancel a scheduled Job by ID
jobId
- the job Idpublic void beforeAppStart(java.lang.Runnable runnable)
public void afterAppStart(java.lang.Runnable runnable)
public void beforeAppStop(java.lang.Runnable runnable)
public SimpleProgressGauge progressGauge(java.lang.String jobId)
public void setJobProgressGauge(java.lang.String jobId, ProgressGauge progressGauge)
Copyright © 2014–2017 ActFramework. All rights reserved.