https://github.com/ReactiveX/RxJava: Reactive Extensions for Java
  • David Karnok 
public final class io.reactivex.internal.schedulers.IoScheduler extends io.reactivex.Scheduler
  minor version: 0
  major version: 59
  flags: flags: (0x0031) ACC_PUBLIC, ACC_FINAL, ACC_SUPER
  this_class: io.reactivex.internal.schedulers.IoScheduler
  super_class: io.reactivex.Scheduler
{
  private static final java.lang.String WORKER_THREAD_NAME_PREFIX;
    descriptor: Ljava/lang/String;
    flags: (0x001a) ACC_PRIVATE, ACC_STATIC, ACC_FINAL
    ConstantValue: "RxCachedThreadScheduler"

  static final io.reactivex.internal.schedulers.RxThreadFactory WORKER_THREAD_FACTORY;
    descriptor: Lio/reactivex/internal/schedulers/RxThreadFactory;
    flags: (0x0018) ACC_STATIC, ACC_FINAL

  private static final java.lang.String EVICTOR_THREAD_NAME_PREFIX;
    descriptor: Ljava/lang/String;
    flags: (0x001a) ACC_PRIVATE, ACC_STATIC, ACC_FINAL
    ConstantValue: "RxCachedWorkerPoolEvictor"

  static final io.reactivex.internal.schedulers.RxThreadFactory EVICTOR_THREAD_FACTORY;
    descriptor: Lio/reactivex/internal/schedulers/RxThreadFactory;
    flags: (0x0018) ACC_STATIC, ACC_FINAL

  private static final java.lang.String KEY_KEEP_ALIVE_TIME;
    descriptor: Ljava/lang/String;
    flags: (0x001a) ACC_PRIVATE, ACC_STATIC, ACC_FINAL
    ConstantValue: "rx2.io-keep-alive-time"

  public static final long KEEP_ALIVE_TIME_DEFAULT;
    descriptor: J
    flags: (0x0019) ACC_PUBLIC, ACC_STATIC, ACC_FINAL
    ConstantValue: 60

  private static final long KEEP_ALIVE_TIME;
    descriptor: J
    flags: (0x001a) ACC_PRIVATE, ACC_STATIC, ACC_FINAL

  private static final java.util.concurrent.TimeUnit KEEP_ALIVE_UNIT;
    descriptor: Ljava/util/concurrent/TimeUnit;
    flags: (0x001a) ACC_PRIVATE, ACC_STATIC, ACC_FINAL

  static final io.reactivex.internal.schedulers.IoScheduler$ThreadWorker SHUTDOWN_THREAD_WORKER;
    descriptor: Lio/reactivex/internal/schedulers/IoScheduler$ThreadWorker;
    flags: (0x0018) ACC_STATIC, ACC_FINAL

  final java.util.concurrent.ThreadFactory threadFactory;
    descriptor: Ljava/util/concurrent/ThreadFactory;
    flags: (0x0010) ACC_FINAL

  final java.util.concurrent.atomic.AtomicReference<io.reactivex.internal.schedulers.IoScheduler$CachedWorkerPool> pool;
    descriptor: Ljava/util/concurrent/atomic/AtomicReference;
    flags: (0x0010) ACC_FINAL
    Signature: Ljava/util/concurrent/atomic/AtomicReference<Lio/reactivex/internal/schedulers/IoScheduler$CachedWorkerPool;>;

  private static final java.lang.String KEY_IO_PRIORITY;
    descriptor: Ljava/lang/String;
    flags: (0x001a) ACC_PRIVATE, ACC_STATIC, ACC_FINAL
    ConstantValue: "rx2.io-priority"

  static final io.reactivex.internal.schedulers.IoScheduler$CachedWorkerPool NONE;
    descriptor: Lio/reactivex/internal/schedulers/IoScheduler$CachedWorkerPool;
    flags: (0x0018) ACC_STATIC, ACC_FINAL

  static void <clinit>();
    descriptor: ()V
    flags: (0x0008) ACC_STATIC
    Code:
      stack=6, locals=1, args_size=0
         0: .line 42
            getstatic java.util.concurrent.TimeUnit.SECONDS:Ljava/util/concurrent/TimeUnit;
            putstatic io.reactivex.internal.schedulers.IoScheduler.KEEP_ALIVE_UNIT:Ljava/util/concurrent/TimeUnit;
         1: .line 54
            ldc "rx2.io-keep-alive-time"
            ldc 60
            invokestatic java.lang.Long.getLong:(Ljava/lang/String;J)Ljava/lang/Long;
            invokevirtual java.lang.Long.longValue:()J
            putstatic io.reactivex.internal.schedulers.IoScheduler.KEEP_ALIVE_TIME:J
         2: .line 56
            new io.reactivex.internal.schedulers.IoScheduler$ThreadWorker
            dup
            new io.reactivex.internal.schedulers.RxThreadFactory
            dup
            ldc "RxCachedThreadSchedulerShutdown"
            invokespecial io.reactivex.internal.schedulers.RxThreadFactory.<init>:(Ljava/lang/String;)V
            invokespecial io.reactivex.internal.schedulers.IoScheduler$ThreadWorker.<init>:(Ljava/util/concurrent/ThreadFactory;)V
            putstatic io.reactivex.internal.schedulers.IoScheduler.SHUTDOWN_THREAD_WORKER:Lio/reactivex/internal/schedulers/IoScheduler$ThreadWorker;
         3: .line 57
            getstatic io.reactivex.internal.schedulers.IoScheduler.SHUTDOWN_THREAD_WORKER:Lio/reactivex/internal/schedulers/IoScheduler$ThreadWorker;
            invokevirtual io.reactivex.internal.schedulers.IoScheduler$ThreadWorker.dispose:()V
         4: .line 59
            iconst_1
            bipush 10
         5: .line 60
            ldc "rx2.io-priority"
            iconst_5
            invokestatic java.lang.Integer.getInteger:(Ljava/lang/String;I)Ljava/lang/Integer;
            invokevirtual java.lang.Integer.intValue:()I
         6: .line 59
            invokestatic java.lang.Math.min:(II)I
            invokestatic java.lang.Math.max:(II)I
            istore 0 /* priority */
        start local 0 // int priority
         7: .line 62
            new io.reactivex.internal.schedulers.RxThreadFactory
            dup
            ldc "RxCachedThreadScheduler"
            iload 0 /* priority */
            invokespecial io.reactivex.internal.schedulers.RxThreadFactory.<init>:(Ljava/lang/String;I)V
            putstatic io.reactivex.internal.schedulers.IoScheduler.WORKER_THREAD_FACTORY:Lio/reactivex/internal/schedulers/RxThreadFactory;
         8: .line 64
            new io.reactivex.internal.schedulers.RxThreadFactory
            dup
            ldc "RxCachedWorkerPoolEvictor"
            iload 0 /* priority */
            invokespecial io.reactivex.internal.schedulers.RxThreadFactory.<init>:(Ljava/lang/String;I)V
            putstatic io.reactivex.internal.schedulers.IoScheduler.EVICTOR_THREAD_FACTORY:Lio/reactivex/internal/schedulers/RxThreadFactory;
         9: .line 66
            new io.reactivex.internal.schedulers.IoScheduler$CachedWorkerPool
            dup
            lconst_0
            aconst_null
            getstatic io.reactivex.internal.schedulers.IoScheduler.WORKER_THREAD_FACTORY:Lio/reactivex/internal/schedulers/RxThreadFactory;
            invokespecial io.reactivex.internal.schedulers.IoScheduler$CachedWorkerPool.<init>:(JLjava/util/concurrent/TimeUnit;Ljava/util/concurrent/ThreadFactory;)V
            putstatic io.reactivex.internal.schedulers.IoScheduler.NONE:Lio/reactivex/internal/schedulers/IoScheduler$CachedWorkerPool;
        10: .line 67
            getstatic io.reactivex.internal.schedulers.IoScheduler.NONE:Lio/reactivex/internal/schedulers/IoScheduler$CachedWorkerPool;
            invokevirtual io.reactivex.internal.schedulers.IoScheduler$CachedWorkerPool.shutdown:()V
        end local 0 // int priority
        11: .line 68
            return
      LocalVariableTable:
        Start  End  Slot      Name  Signature
            7   11     0  priority  I

  public void <init>();
    descriptor: ()V
    flags: (0x0001) ACC_PUBLIC
    Code:
      stack=2, locals=1, args_size=1
        start local 0 // io.reactivex.internal.schedulers.IoScheduler this
         0: .line 157
            aload 0 /* this */
            getstatic io.reactivex.internal.schedulers.IoScheduler.WORKER_THREAD_FACTORY:Lio/reactivex/internal/schedulers/RxThreadFactory;
            invokespecial io.reactivex.internal.schedulers.IoScheduler.<init>:(Ljava/util/concurrent/ThreadFactory;)V
         1: .line 158
            return
        end local 0 // io.reactivex.internal.schedulers.IoScheduler this
      LocalVariableTable:
        Start  End  Slot  Name  Signature
            0    2     0  this  Lio/reactivex/internal/schedulers/IoScheduler;

  public void <init>(java.util.concurrent.ThreadFactory);
    descriptor: (Ljava/util/concurrent/ThreadFactory;)V
    flags: (0x0001) ACC_PUBLIC
    Code:
      stack=4, locals=2, args_size=2
        start local 0 // io.reactivex.internal.schedulers.IoScheduler this
        start local 1 // java.util.concurrent.ThreadFactory threadFactory
         0: .line 165
            aload 0 /* this */
            invokespecial io.reactivex.Scheduler.<init>:()V
         1: .line 166
            aload 0 /* this */
            aload 1 /* threadFactory */
            putfield io.reactivex.internal.schedulers.IoScheduler.threadFactory:Ljava/util/concurrent/ThreadFactory;
         2: .line 167
            aload 0 /* this */
            new java.util.concurrent.atomic.AtomicReference
            dup
            getstatic io.reactivex.internal.schedulers.IoScheduler.NONE:Lio/reactivex/internal/schedulers/IoScheduler$CachedWorkerPool;
            invokespecial java.util.concurrent.atomic.AtomicReference.<init>:(Ljava/lang/Object;)V
            putfield io.reactivex.internal.schedulers.IoScheduler.pool:Ljava/util/concurrent/atomic/AtomicReference;
         3: .line 168
            aload 0 /* this */
            invokevirtual io.reactivex.internal.schedulers.IoScheduler.start:()V
         4: .line 169
            return
        end local 1 // java.util.concurrent.ThreadFactory threadFactory
        end local 0 // io.reactivex.internal.schedulers.IoScheduler this
      LocalVariableTable:
        Start  End  Slot           Name  Signature
            0    5     0           this  Lio/reactivex/internal/schedulers/IoScheduler;
            0    5     1  threadFactory  Ljava/util/concurrent/ThreadFactory;
    MethodParameters:
               Name  Flags
      threadFactory  

  public void start();
    descriptor: ()V
    flags: (0x0001) ACC_PUBLIC
    Code:
      stack=6, locals=2, args_size=1
        start local 0 // io.reactivex.internal.schedulers.IoScheduler this
         0: .line 173
            new io.reactivex.internal.schedulers.IoScheduler$CachedWorkerPool
            dup
            getstatic io.reactivex.internal.schedulers.IoScheduler.KEEP_ALIVE_TIME:J
            getstatic io.reactivex.internal.schedulers.IoScheduler.KEEP_ALIVE_UNIT:Ljava/util/concurrent/TimeUnit;
            aload 0 /* this */
            getfield io.reactivex.internal.schedulers.IoScheduler.threadFactory:Ljava/util/concurrent/ThreadFactory;
            invokespecial io.reactivex.internal.schedulers.IoScheduler$CachedWorkerPool.<init>:(JLjava/util/concurrent/TimeUnit;Ljava/util/concurrent/ThreadFactory;)V
            astore 1 /* update */
        start local 1 // io.reactivex.internal.schedulers.IoScheduler$CachedWorkerPool update
         1: .line 174
            aload 0 /* this */
            getfield io.reactivex.internal.schedulers.IoScheduler.pool:Ljava/util/concurrent/atomic/AtomicReference;
            getstatic io.reactivex.internal.schedulers.IoScheduler.NONE:Lio/reactivex/internal/schedulers/IoScheduler$CachedWorkerPool;
            aload 1 /* update */
            invokevirtual java.util.concurrent.atomic.AtomicReference.compareAndSet:(Ljava/lang/Object;Ljava/lang/Object;)Z
            ifne 3
         2: .line 175
            aload 1 /* update */
            invokevirtual io.reactivex.internal.schedulers.IoScheduler$CachedWorkerPool.shutdown:()V
         3: .line 177
      StackMap locals: io.reactivex.internal.schedulers.IoScheduler$CachedWorkerPool
      StackMap stack:
            return
        end local 1 // io.reactivex.internal.schedulers.IoScheduler$CachedWorkerPool update
        end local 0 // io.reactivex.internal.schedulers.IoScheduler this
      LocalVariableTable:
        Start  End  Slot    Name  Signature
            0    4     0    this  Lio/reactivex/internal/schedulers/IoScheduler;
            1    4     1  update  Lio/reactivex/internal/schedulers/IoScheduler$CachedWorkerPool;

  public void shutdown();
    descriptor: ()V
    flags: (0x0001) ACC_PUBLIC
    Code:
      stack=3, locals=2, args_size=1
        start local 0 // io.reactivex.internal.schedulers.IoScheduler this
         0: .line 182
      StackMap locals:
      StackMap stack:
            aload 0 /* this */
            getfield io.reactivex.internal.schedulers.IoScheduler.pool:Ljava/util/concurrent/atomic/AtomicReference;
            invokevirtual java.util.concurrent.atomic.AtomicReference.get:()Ljava/lang/Object;
            checkcast io.reactivex.internal.schedulers.IoScheduler$CachedWorkerPool
            astore 1 /* curr */
        start local 1 // io.reactivex.internal.schedulers.IoScheduler$CachedWorkerPool curr
         1: .line 183
            aload 1 /* curr */
            getstatic io.reactivex.internal.schedulers.IoScheduler.NONE:Lio/reactivex/internal/schedulers/IoScheduler$CachedWorkerPool;
            if_acmpne 3
         2: .line 184
            return
         3: .line 186
      StackMap locals: io.reactivex.internal.schedulers.IoScheduler$CachedWorkerPool
      StackMap stack:
            aload 0 /* this */
            getfield io.reactivex.internal.schedulers.IoScheduler.pool:Ljava/util/concurrent/atomic/AtomicReference;
            aload 1 /* curr */
            getstatic io.reactivex.internal.schedulers.IoScheduler.NONE:Lio/reactivex/internal/schedulers/IoScheduler$CachedWorkerPool;
            invokevirtual java.util.concurrent.atomic.AtomicReference.compareAndSet:(Ljava/lang/Object;Ljava/lang/Object;)Z
            ifeq 0
         4: .line 187
            aload 1 /* curr */
            invokevirtual io.reactivex.internal.schedulers.IoScheduler$CachedWorkerPool.shutdown:()V
         5: .line 188
            return
        end local 1 // io.reactivex.internal.schedulers.IoScheduler$CachedWorkerPool curr
        end local 0 // io.reactivex.internal.schedulers.IoScheduler this
      LocalVariableTable:
        Start  End  Slot  Name  Signature
            0    6     0  this  Lio/reactivex/internal/schedulers/IoScheduler;
            1    6     1  curr  Lio/reactivex/internal/schedulers/IoScheduler$CachedWorkerPool;

  public io.reactivex.Scheduler$Worker createWorker();
    descriptor: ()Lio/reactivex/Scheduler$Worker;
    flags: (0x0001) ACC_PUBLIC
    Code:
      stack=3, locals=1, args_size=1
        start local 0 // io.reactivex.internal.schedulers.IoScheduler this
         0: .line 196
            new io.reactivex.internal.schedulers.IoScheduler$EventLoopWorker
            dup
            aload 0 /* this */
            getfield io.reactivex.internal.schedulers.IoScheduler.pool:Ljava/util/concurrent/atomic/AtomicReference;
            invokevirtual java.util.concurrent.atomic.AtomicReference.get:()Ljava/lang/Object;
            checkcast io.reactivex.internal.schedulers.IoScheduler$CachedWorkerPool
            invokespecial io.reactivex.internal.schedulers.IoScheduler$EventLoopWorker.<init>:(Lio/reactivex/internal/schedulers/IoScheduler$CachedWorkerPool;)V
            areturn
        end local 0 // io.reactivex.internal.schedulers.IoScheduler this
      LocalVariableTable:
        Start  End  Slot  Name  Signature
            0    1     0  this  Lio/reactivex/internal/schedulers/IoScheduler;
    RuntimeInvisibleAnnotations: 
      io.reactivex.annotations.NonNull()

  public int size();
    descriptor: ()I
    flags: (0x0001) ACC_PUBLIC
    Code:
      stack=1, locals=1, args_size=1
        start local 0 // io.reactivex.internal.schedulers.IoScheduler this
         0: .line 200
            aload 0 /* this */
            getfield io.reactivex.internal.schedulers.IoScheduler.pool:Ljava/util/concurrent/atomic/AtomicReference;
            invokevirtual java.util.concurrent.atomic.AtomicReference.get:()Ljava/lang/Object;
            checkcast io.reactivex.internal.schedulers.IoScheduler$CachedWorkerPool
            getfield io.reactivex.internal.schedulers.IoScheduler$CachedWorkerPool.allWorkers:Lio/reactivex/disposables/CompositeDisposable;
            invokevirtual io.reactivex.disposables.CompositeDisposable.size:()I
            ireturn
        end local 0 // io.reactivex.internal.schedulers.IoScheduler this
      LocalVariableTable:
        Start  End  Slot  Name  Signature
            0    1     0  this  Lio/reactivex/internal/schedulers/IoScheduler;
}
SourceFile: "IoScheduler.java"
NestMembers:
  io.reactivex.internal.schedulers.IoScheduler$CachedWorkerPool  io.reactivex.internal.schedulers.IoScheduler$EventLoopWorker  io.reactivex.internal.schedulers.IoScheduler$ThreadWorker
InnerClasses:
  public abstract Worker = io.reactivex.Scheduler$Worker of io.reactivex.Scheduler
  final CachedWorkerPool = io.reactivex.internal.schedulers.IoScheduler$CachedWorkerPool of io.reactivex.internal.schedulers.IoScheduler
  final EventLoopWorker = io.reactivex.internal.schedulers.IoScheduler$EventLoopWorker of io.reactivex.internal.schedulers.IoScheduler
  final ThreadWorker = io.reactivex.internal.schedulers.IoScheduler$ThreadWorker of io.reactivex.internal.schedulers.IoScheduler