hu.akarnokd.rxjava2.internal.schedulers

Class NewThreadWorker

java.lang.Object

hu.akarnokd.rxjava2.Scheduler.Worker

hu.akarnokd.rxjava2.internal.schedulers.NewThreadWorker

All Implemented Interfaces:

Disposable

public class NewThreadWorker
extends Scheduler.Worker
implements Disposable

Base class that manages a single-threaded ScheduledExecutorService as a worker but doesn't perform task-tracking operations.

Constructor Summary

Constructors

Constructor and Description
NewThreadWorker(java.util.concurrent.ThreadFactory threadFactory)

Method Summary

Modifier and Type	Method and Description
void	dispose() Dispose the resource, the operation should be idempotent.
Disposable	schedule(java.lang.Runnable run)
Disposable	schedule(java.lang.Runnable action, long delayTime, java.util.concurrent.TimeUnit unit)
ScheduledRunnable	scheduleActual(java.lang.Runnable run, long delayTime, java.util.concurrent.TimeUnit unit, CompositeResource<Disposable> parent) Wraps the given runnable into a ScheduledRunnable and schedules it on the underlying ScheduledExecutorService.
Disposable	scheduleDirect(java.lang.Runnable run, long delayTime, java.util.concurrent.TimeUnit unit) Schedules the given runnable on the underlying executor directly and returns its future wrapped into a Disposable.
Disposable	schedulePeriodicallyDirect(java.lang.Runnable run, long initialDelay, long period, java.util.concurrent.TimeUnit unit) Schedules the given runnable periodically on the underlying executor directly and returns its future wrapped into a Disposable.

Methods inherited from class hu.akarnokd.rxjava2.Scheduler.Worker

now, schedulePeriodically

Methods inherited from class java.lang.Object

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

Constructor Detail

NewThreadWorker

public NewThreadWorker(java.util.concurrent.ThreadFactory threadFactory)

Method Detail

schedule

public Disposable schedule(java.lang.Runnable run)

Overrides:

schedule in class Scheduler.Worker

schedule

public Disposable schedule(java.lang.Runnable action,
                           long delayTime,
                           java.util.concurrent.TimeUnit unit)

Specified by:

schedule in class Scheduler.Worker

scheduleDirect

public Disposable scheduleDirect(java.lang.Runnable run,
                                 long delayTime,
                                 java.util.concurrent.TimeUnit unit)

Schedules the given runnable on the underlying executor directly and returns its future wrapped into a Disposable.

Parameters:

run -

delayTime -

unit -

Returns:

the ScheduledRunnable instance

schedulePeriodicallyDirect

public Disposable schedulePeriodicallyDirect(java.lang.Runnable run,
                                             long initialDelay,
                                             long period,
                                             java.util.concurrent.TimeUnit unit)

Schedules the given runnable periodically on the underlying executor directly and returns its future wrapped into a Disposable.

Parameters:

run -

initialDelay -

period -

unit -

Returns:

the ScheduledRunnable instance

scheduleActual

public ScheduledRunnable scheduleActual(java.lang.Runnable run,
                                        long delayTime,
                                        java.util.concurrent.TimeUnit unit,
                                        CompositeResource<Disposable> parent)

Wraps the given runnable into a ScheduledRunnable and schedules it on the underlying ScheduledExecutorService.

If the schedule has been rejected, the ScheduledRunnable.wasScheduled will return false.

Parameters:

run - the runnable instance

delayTime - the time to delay the execution

unit - the time unit

parent - the optional tracker parent to add the created ScheduledRunnable instance to before it gets scheduled

Returns:

the ScheduledRunnable instance

dispose

public void dispose()

Description copied from interface: Disposable

Dispose the resource, the operation should be idempotent.

Specified by:

dispose in interface Disposable