public class io.reactivex.internal.schedulers.NewThreadWorker extends io.reactivex.Scheduler$Worker implements io.reactivex.disposables.Disposable
minor version: 0
major version: 59
flags: flags: (0x0021) ACC_PUBLIC, ACC_SUPER
this_class: io.reactivex.internal.schedulers.NewThreadWorker
super_class: io.reactivex.Scheduler$Worker
{
private final java.util.concurrent.ScheduledExecutorService executor;
descriptor: Ljava/util/concurrent/ScheduledExecutorService;
flags: (0x0012) ACC_PRIVATE, ACC_FINAL
volatile boolean disposed;
descriptor: Z
flags: (0x0040) ACC_VOLATILE
public void <init>(java.util.concurrent.ThreadFactory);
descriptor: (Ljava/util/concurrent/ThreadFactory;)V
flags: (0x0001) ACC_PUBLIC
Code:
stack=2, locals=2, args_size=2
start local 0 start local 1 0: aload 0
invokespecial io.reactivex.Scheduler$Worker.<init>:()V
1: aload 0
aload 1
invokestatic io.reactivex.internal.schedulers.SchedulerPoolFactory.create:(Ljava/util/concurrent/ThreadFactory;)Ljava/util/concurrent/ScheduledExecutorService;
putfield io.reactivex.internal.schedulers.NewThreadWorker.executor:Ljava/util/concurrent/ScheduledExecutorService;
2: return
end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 3 0 this Lio/reactivex/internal/schedulers/NewThreadWorker;
0 3 1 threadFactory Ljava/util/concurrent/ThreadFactory;
MethodParameters:
Name Flags
threadFactory
public io.reactivex.disposables.Disposable schedule(java.lang.Runnable);
descriptor: (Ljava/lang/Runnable;)Lio/reactivex/disposables/Disposable;
flags: (0x0001) ACC_PUBLIC
Code:
stack=5, locals=2, args_size=2
start local 0 start local 1 0: aload 0
aload 1
lconst_0
aconst_null
invokevirtual io.reactivex.internal.schedulers.NewThreadWorker.schedule:(Ljava/lang/Runnable;JLjava/util/concurrent/TimeUnit;)Lio/reactivex/disposables/Disposable;
areturn
end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 1 0 this Lio/reactivex/internal/schedulers/NewThreadWorker;
0 1 1 run Ljava/lang/Runnable;
RuntimeInvisibleAnnotations:
io.reactivex.annotations.NonNull()
RuntimeInvisibleParameterAnnotations:
0:
io.reactivex.annotations.NonNull()
MethodParameters:
Name Flags
run final
public io.reactivex.disposables.Disposable schedule(java.lang.Runnable, long, java.util.concurrent.TimeUnit);
descriptor: (Ljava/lang/Runnable;JLjava/util/concurrent/TimeUnit;)Lio/reactivex/disposables/Disposable;
flags: (0x0001) ACC_PUBLIC
Code:
stack=6, locals=5, args_size=4
start local 0 start local 1 start local 2 start local 4 0: aload 0
getfield io.reactivex.internal.schedulers.NewThreadWorker.disposed:Z
ifeq 2
1: getstatic io.reactivex.internal.disposables.EmptyDisposable.INSTANCE:Lio/reactivex/internal/disposables/EmptyDisposable;
areturn
2: StackMap locals:
StackMap stack:
aload 0
aload 1
lload 2
aload 4
aconst_null
invokevirtual io.reactivex.internal.schedulers.NewThreadWorker.scheduleActual:(Ljava/lang/Runnable;JLjava/util/concurrent/TimeUnit;Lio/reactivex/internal/disposables/DisposableContainer;)Lio/reactivex/internal/schedulers/ScheduledRunnable;
areturn
end local 4 end local 2 end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 3 0 this Lio/reactivex/internal/schedulers/NewThreadWorker;
0 3 1 action Ljava/lang/Runnable;
0 3 2 delayTime J
0 3 4 unit Ljava/util/concurrent/TimeUnit;
RuntimeInvisibleAnnotations:
io.reactivex.annotations.NonNull()
RuntimeInvisibleParameterAnnotations:
0:
io.reactivex.annotations.NonNull()
1:
2:
io.reactivex.annotations.NonNull()
MethodParameters:
Name Flags
action final
delayTime
unit
public io.reactivex.disposables.Disposable scheduleDirect(java.lang.Runnable, long, java.util.concurrent.TimeUnit);
descriptor: (Ljava/lang/Runnable;JLjava/util/concurrent/TimeUnit;)Lio/reactivex/disposables/Disposable;
flags: (0x0001) ACC_PUBLIC
Code:
stack=5, locals=7, args_size=4
start local 0 start local 1 start local 2 start local 4 0: new io.reactivex.internal.schedulers.ScheduledDirectTask
dup
aload 1
invokestatic io.reactivex.plugins.RxJavaPlugins.onSchedule:(Ljava/lang/Runnable;)Ljava/lang/Runnable;
invokespecial io.reactivex.internal.schedulers.ScheduledDirectTask.<init>:(Ljava/lang/Runnable;)V
astore 5
start local 5 1: lload 2
lconst_0
lcmp
ifgt 4
2: aload 0
getfield io.reactivex.internal.schedulers.NewThreadWorker.executor:Ljava/util/concurrent/ScheduledExecutorService;
aload 5
invokeinterface java.util.concurrent.ScheduledExecutorService.submit:(Ljava/util/concurrent/Callable;)Ljava/util/concurrent/Future;
astore 6
start local 6 3: goto 5
end local 6 4: StackMap locals: io.reactivex.internal.schedulers.ScheduledDirectTask
StackMap stack:
aload 0
getfield io.reactivex.internal.schedulers.NewThreadWorker.executor:Ljava/util/concurrent/ScheduledExecutorService;
aload 5
lload 2
aload 4
invokeinterface java.util.concurrent.ScheduledExecutorService.schedule:(Ljava/util/concurrent/Callable;JLjava/util/concurrent/TimeUnit;)Ljava/util/concurrent/ScheduledFuture;
astore 6
start local 6 5: StackMap locals: java.util.concurrent.Future
StackMap stack:
aload 5
aload 6
invokevirtual io.reactivex.internal.schedulers.ScheduledDirectTask.setFuture:(Ljava/util/concurrent/Future;)V
6: aload 5
7: areturn
end local 6 8: StackMap locals: io.reactivex.internal.schedulers.NewThreadWorker java.lang.Runnable long java.util.concurrent.TimeUnit io.reactivex.internal.schedulers.ScheduledDirectTask
StackMap stack: java.util.concurrent.RejectedExecutionException
astore 6
start local 6 9: aload 6
invokestatic io.reactivex.plugins.RxJavaPlugins.onError:(Ljava/lang/Throwable;)V
10: getstatic io.reactivex.internal.disposables.EmptyDisposable.INSTANCE:Lio/reactivex/internal/disposables/EmptyDisposable;
areturn
end local 6 end local 5 end local 4 end local 2 end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 11 0 this Lio/reactivex/internal/schedulers/NewThreadWorker;
0 11 1 run Ljava/lang/Runnable;
0 11 2 delayTime J
0 11 4 unit Ljava/util/concurrent/TimeUnit;
1 11 5 task Lio/reactivex/internal/schedulers/ScheduledDirectTask;
3 4 6 f Ljava/util/concurrent/Future<*>;
5 8 6 f Ljava/util/concurrent/Future<*>;
9 11 6 ex Ljava/util/concurrent/RejectedExecutionException;
Exception table:
from to target type
1 7 8 Class java.util.concurrent.RejectedExecutionException
MethodParameters:
Name Flags
run final
delayTime
unit
public io.reactivex.disposables.Disposable schedulePeriodicallyDirect(java.lang.Runnable, long, long, java.util.concurrent.TimeUnit);
descriptor: (Ljava/lang/Runnable;JJLjava/util/concurrent/TimeUnit;)Lio/reactivex/disposables/Disposable;
flags: (0x0001) ACC_PUBLIC
Code:
stack=7, locals=10, args_size=5
start local 0 start local 1 start local 2 start local 4 start local 6 0: aload 1
invokestatic io.reactivex.plugins.RxJavaPlugins.onSchedule:(Ljava/lang/Runnable;)Ljava/lang/Runnable;
astore 7
start local 7 1: lload 4
lconst_0
lcmp
ifgt 13
2: new io.reactivex.internal.schedulers.InstantPeriodicTask
dup
aload 7
aload 0
getfield io.reactivex.internal.schedulers.NewThreadWorker.executor:Ljava/util/concurrent/ScheduledExecutorService;
invokespecial io.reactivex.internal.schedulers.InstantPeriodicTask.<init>:(Ljava/lang/Runnable;Ljava/util/concurrent/ExecutorService;)V
astore 8
start local 8 3: lload 2
lconst_0
lcmp
ifgt 6
4: aload 0
getfield io.reactivex.internal.schedulers.NewThreadWorker.executor:Ljava/util/concurrent/ScheduledExecutorService;
aload 8
invokeinterface java.util.concurrent.ScheduledExecutorService.submit:(Ljava/util/concurrent/Callable;)Ljava/util/concurrent/Future;
astore 9
start local 9 5: goto 7
end local 9 6: StackMap locals: java.lang.Runnable io.reactivex.internal.schedulers.InstantPeriodicTask
StackMap stack:
aload 0
getfield io.reactivex.internal.schedulers.NewThreadWorker.executor:Ljava/util/concurrent/ScheduledExecutorService;
aload 8
lload 2
aload 6
invokeinterface java.util.concurrent.ScheduledExecutorService.schedule:(Ljava/util/concurrent/Callable;JLjava/util/concurrent/TimeUnit;)Ljava/util/concurrent/ScheduledFuture;
astore 9
start local 9 7: StackMap locals: java.util.concurrent.Future
StackMap stack:
aload 8
aload 9
invokevirtual io.reactivex.internal.schedulers.InstantPeriodicTask.setFirst:(Ljava/util/concurrent/Future;)V
end local 9 8: goto 12
StackMap locals: io.reactivex.internal.schedulers.NewThreadWorker java.lang.Runnable long long java.util.concurrent.TimeUnit java.lang.Runnable io.reactivex.internal.schedulers.InstantPeriodicTask
StackMap stack: java.util.concurrent.RejectedExecutionException
9: astore 9
start local 9 10: aload 9
invokestatic io.reactivex.plugins.RxJavaPlugins.onError:(Ljava/lang/Throwable;)V
11: getstatic io.reactivex.internal.disposables.EmptyDisposable.INSTANCE:Lio/reactivex/internal/disposables/EmptyDisposable;
areturn
end local 9 12: StackMap locals:
StackMap stack:
aload 8
areturn
end local 8 13: StackMap locals:
StackMap stack:
new io.reactivex.internal.schedulers.ScheduledDirectPeriodicTask
dup
aload 7
invokespecial io.reactivex.internal.schedulers.ScheduledDirectPeriodicTask.<init>:(Ljava/lang/Runnable;)V
astore 8
start local 8 14: aload 0
getfield io.reactivex.internal.schedulers.NewThreadWorker.executor:Ljava/util/concurrent/ScheduledExecutorService;
aload 8
lload 2
lload 4
aload 6
invokeinterface java.util.concurrent.ScheduledExecutorService.scheduleAtFixedRate:(Ljava/lang/Runnable;JJLjava/util/concurrent/TimeUnit;)Ljava/util/concurrent/ScheduledFuture;
astore 9
start local 9 15: aload 8
aload 9
invokevirtual io.reactivex.internal.schedulers.ScheduledDirectPeriodicTask.setFuture:(Ljava/util/concurrent/Future;)V
16: aload 8
17: areturn
end local 9 18: StackMap locals: io.reactivex.internal.schedulers.NewThreadWorker java.lang.Runnable long long java.util.concurrent.TimeUnit java.lang.Runnable io.reactivex.internal.schedulers.ScheduledDirectPeriodicTask
StackMap stack: java.util.concurrent.RejectedExecutionException
astore 9
start local 9 19: aload 9
invokestatic io.reactivex.plugins.RxJavaPlugins.onError:(Ljava/lang/Throwable;)V
20: getstatic io.reactivex.internal.disposables.EmptyDisposable.INSTANCE:Lio/reactivex/internal/disposables/EmptyDisposable;
areturn
end local 9 end local 8 end local 7 end local 6 end local 4 end local 2 end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 21 0 this Lio/reactivex/internal/schedulers/NewThreadWorker;
0 21 1 run Ljava/lang/Runnable;
0 21 2 initialDelay J
0 21 4 period J
0 21 6 unit Ljava/util/concurrent/TimeUnit;
1 21 7 decoratedRun Ljava/lang/Runnable;
3 13 8 periodicWrapper Lio/reactivex/internal/schedulers/InstantPeriodicTask;
5 6 9 f Ljava/util/concurrent/Future<*>;
7 8 9 f Ljava/util/concurrent/Future<*>;
10 12 9 ex Ljava/util/concurrent/RejectedExecutionException;
14 21 8 task Lio/reactivex/internal/schedulers/ScheduledDirectPeriodicTask;
15 18 9 f Ljava/util/concurrent/Future<*>;
19 21 9 ex Ljava/util/concurrent/RejectedExecutionException;
Exception table:
from to target type
3 8 9 Class java.util.concurrent.RejectedExecutionException
14 17 18 Class java.util.concurrent.RejectedExecutionException
MethodParameters:
Name Flags
run
initialDelay
period
unit
public io.reactivex.internal.schedulers.ScheduledRunnable scheduleActual(java.lang.Runnable, long, java.util.concurrent.TimeUnit, io.reactivex.internal.disposables.DisposableContainer);
descriptor: (Ljava/lang/Runnable;JLjava/util/concurrent/TimeUnit;Lio/reactivex/internal/disposables/DisposableContainer;)Lio/reactivex/internal/schedulers/ScheduledRunnable;
flags: (0x0001) ACC_PUBLIC
Code:
stack=5, locals=10, args_size=5
start local 0 start local 1 start local 2 start local 4 start local 5 0: aload 1
invokestatic io.reactivex.plugins.RxJavaPlugins.onSchedule:(Ljava/lang/Runnable;)Ljava/lang/Runnable;
astore 6
start local 6 1: new io.reactivex.internal.schedulers.ScheduledRunnable
dup
aload 6
aload 5
invokespecial io.reactivex.internal.schedulers.ScheduledRunnable.<init>:(Ljava/lang/Runnable;Lio/reactivex/internal/disposables/DisposableContainer;)V
astore 7
start local 7 2: aload 5
ifnull 5
3: aload 5
aload 7
invokeinterface io.reactivex.internal.disposables.DisposableContainer.add:(Lio/reactivex/disposables/Disposable;)Z
ifne 5
4: aload 7
areturn
5: StackMap locals: java.lang.Runnable io.reactivex.internal.schedulers.ScheduledRunnable
StackMap stack:
lload 2
lconst_0
lcmp
ifgt 8
6: aload 0
getfield io.reactivex.internal.schedulers.NewThreadWorker.executor:Ljava/util/concurrent/ScheduledExecutorService;
aload 7
invokeinterface java.util.concurrent.ScheduledExecutorService.submit:(Ljava/util/concurrent/Callable;)Ljava/util/concurrent/Future;
astore 8
start local 8 7: goto 9
end local 8 8: StackMap locals:
StackMap stack:
aload 0
getfield io.reactivex.internal.schedulers.NewThreadWorker.executor:Ljava/util/concurrent/ScheduledExecutorService;
aload 7
lload 2
aload 4
invokeinterface java.util.concurrent.ScheduledExecutorService.schedule:(Ljava/util/concurrent/Callable;JLjava/util/concurrent/TimeUnit;)Ljava/util/concurrent/ScheduledFuture;
astore 8
start local 8 9: StackMap locals: java.util.concurrent.Future
StackMap stack:
aload 7
aload 8
invokevirtual io.reactivex.internal.schedulers.ScheduledRunnable.setFuture:(Ljava/util/concurrent/Future;)V
10: goto 15
end local 8 StackMap locals: io.reactivex.internal.schedulers.NewThreadWorker java.lang.Runnable long java.util.concurrent.TimeUnit io.reactivex.internal.disposables.DisposableContainer java.lang.Runnable io.reactivex.internal.schedulers.ScheduledRunnable
StackMap stack: java.util.concurrent.RejectedExecutionException
11: astore 9
start local 9 12: aload 5
ifnull 14
13: aload 5
aload 7
invokeinterface io.reactivex.internal.disposables.DisposableContainer.remove:(Lio/reactivex/disposables/Disposable;)Z
pop
14: StackMap locals: io.reactivex.internal.schedulers.NewThreadWorker java.lang.Runnable long java.util.concurrent.TimeUnit io.reactivex.internal.disposables.DisposableContainer java.lang.Runnable io.reactivex.internal.schedulers.ScheduledRunnable top java.util.concurrent.RejectedExecutionException
StackMap stack:
aload 9
invokestatic io.reactivex.plugins.RxJavaPlugins.onError:(Ljava/lang/Throwable;)V
end local 9 15: StackMap locals: io.reactivex.internal.schedulers.NewThreadWorker java.lang.Runnable long java.util.concurrent.TimeUnit io.reactivex.internal.disposables.DisposableContainer java.lang.Runnable io.reactivex.internal.schedulers.ScheduledRunnable
StackMap stack:
aload 7
areturn
end local 7 end local 6 end local 5 end local 4 end local 2 end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 16 0 this Lio/reactivex/internal/schedulers/NewThreadWorker;
0 16 1 run Ljava/lang/Runnable;
0 16 2 delayTime J
0 16 4 unit Ljava/util/concurrent/TimeUnit;
0 16 5 parent Lio/reactivex/internal/disposables/DisposableContainer;
1 16 6 decoratedRun Ljava/lang/Runnable;
2 16 7 sr Lio/reactivex/internal/schedulers/ScheduledRunnable;
7 8 8 f Ljava/util/concurrent/Future<*>;
9 11 8 f Ljava/util/concurrent/Future<*>;
12 15 9 ex Ljava/util/concurrent/RejectedExecutionException;
Exception table:
from to target type
5 10 11 Class java.util.concurrent.RejectedExecutionException
RuntimeInvisibleAnnotations:
io.reactivex.annotations.NonNull()
RuntimeInvisibleParameterAnnotations:
0:
1:
2:
io.reactivex.annotations.NonNull()
3:
io.reactivex.annotations.Nullable()
MethodParameters:
Name Flags
run final
delayTime
unit
parent
public void dispose();
descriptor: ()V
flags: (0x0001) ACC_PUBLIC
Code:
stack=2, locals=1, args_size=1
start local 0 0: aload 0
getfield io.reactivex.internal.schedulers.NewThreadWorker.disposed:Z
ifne 3
1: aload 0
iconst_1
putfield io.reactivex.internal.schedulers.NewThreadWorker.disposed:Z
2: aload 0
getfield io.reactivex.internal.schedulers.NewThreadWorker.executor:Ljava/util/concurrent/ScheduledExecutorService;
invokeinterface java.util.concurrent.ScheduledExecutorService.shutdownNow:()Ljava/util/List;
pop
3: StackMap locals:
StackMap stack:
return
end local 0 LocalVariableTable:
Start End Slot Name Signature
0 4 0 this Lio/reactivex/internal/schedulers/NewThreadWorker;
public void shutdown();
descriptor: ()V
flags: (0x0001) ACC_PUBLIC
Code:
stack=2, locals=1, args_size=1
start local 0 0: aload 0
getfield io.reactivex.internal.schedulers.NewThreadWorker.disposed:Z
ifne 3
1: aload 0
iconst_1
putfield io.reactivex.internal.schedulers.NewThreadWorker.disposed:Z
2: aload 0
getfield io.reactivex.internal.schedulers.NewThreadWorker.executor:Ljava/util/concurrent/ScheduledExecutorService;
invokeinterface java.util.concurrent.ScheduledExecutorService.shutdown:()V
3: StackMap locals:
StackMap stack:
return
end local 0 LocalVariableTable:
Start End Slot Name Signature
0 4 0 this Lio/reactivex/internal/schedulers/NewThreadWorker;
public boolean isDisposed();
descriptor: ()Z
flags: (0x0001) ACC_PUBLIC
Code:
stack=1, locals=1, args_size=1
start local 0 0: aload 0
getfield io.reactivex.internal.schedulers.NewThreadWorker.disposed:Z
ireturn
end local 0 LocalVariableTable:
Start End Slot Name Signature
0 1 0 this Lio/reactivex/internal/schedulers/NewThreadWorker;
}
SourceFile: "NewThreadWorker.java"
InnerClasses:
public abstract Worker = io.reactivex.Scheduler$Worker of io.reactivex.Scheduler