https://github.com/ReactiveX/RxJava: Reactive Extensions for Java
  • David Karnok 
public final class io.reactivex.internal.schedulers.ComputationScheduler extends io.reactivex.Scheduler implements io.reactivex.internal.schedulers.SchedulerMultiWorkerSupport
  minor version: 0
  major version: 59
  flags: flags: (0x0031) ACC_PUBLIC, ACC_FINAL, ACC_SUPER
  this_class: io.reactivex.internal.schedulers.ComputationScheduler
  super_class: io.reactivex.Scheduler
{
  static final io.reactivex.internal.schedulers.ComputationScheduler$FixedSchedulerPool NONE;
    descriptor: Lio/reactivex/internal/schedulers/ComputationScheduler$FixedSchedulerPool;
    flags: (0x0018) ACC_STATIC, ACC_FINAL

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

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

  static final java.lang.String KEY_MAX_THREADS;
    descriptor: Ljava/lang/String;
    flags: (0x0018) ACC_STATIC, ACC_FINAL
    ConstantValue: "rx2.computation-threads"

  static final int MAX_THREADS;
    descriptor: I
    flags: (0x0018) ACC_STATIC, ACC_FINAL

  static final io.reactivex.internal.schedulers.ComputationScheduler$PoolWorker SHUTDOWN_WORKER;
    descriptor: Lio/reactivex/internal/schedulers/ComputationScheduler$PoolWorker;
    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.ComputationScheduler$FixedSchedulerPool> pool;
    descriptor: Ljava/util/concurrent/atomic/AtomicReference;
    flags: (0x0010) ACC_FINAL
    Signature: Ljava/util/concurrent/atomic/AtomicReference<Lio/reactivex/internal/schedulers/ComputationScheduler$FixedSchedulerPool;>;

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

  static void <clinit>();
    descriptor: ()V
    flags: (0x0008) ACC_STATIC
    Code:
      stack=5, locals=1, args_size=0
         0: .line 53
            invokestatic java.lang.Runtime.getRuntime:()Ljava/lang/Runtime;
            invokevirtual java.lang.Runtime.availableProcessors:()I
            ldc "rx2.computation-threads"
            iconst_0
            invokestatic java.lang.Integer.getInteger:(Ljava/lang/String;I)Ljava/lang/Integer;
            invokevirtual java.lang.Integer.intValue:()I
            invokestatic io.reactivex.internal.schedulers.ComputationScheduler.cap:(II)I
            putstatic io.reactivex.internal.schedulers.ComputationScheduler.MAX_THREADS:I
         1: .line 55
            new io.reactivex.internal.schedulers.ComputationScheduler$PoolWorker
            dup
            new io.reactivex.internal.schedulers.RxThreadFactory
            dup
            ldc "RxComputationShutdown"
            invokespecial io.reactivex.internal.schedulers.RxThreadFactory.<init>:(Ljava/lang/String;)V
            invokespecial io.reactivex.internal.schedulers.ComputationScheduler$PoolWorker.<init>:(Ljava/util/concurrent/ThreadFactory;)V
            putstatic io.reactivex.internal.schedulers.ComputationScheduler.SHUTDOWN_WORKER:Lio/reactivex/internal/schedulers/ComputationScheduler$PoolWorker;
         2: .line 56
            getstatic io.reactivex.internal.schedulers.ComputationScheduler.SHUTDOWN_WORKER:Lio/reactivex/internal/schedulers/ComputationScheduler$PoolWorker;
            invokevirtual io.reactivex.internal.schedulers.ComputationScheduler$PoolWorker.dispose:()V
         3: .line 58
            iconst_1
            bipush 10
         4: .line 59
            ldc "rx2.computation-priority"
            iconst_5
            invokestatic java.lang.Integer.getInteger:(Ljava/lang/String;I)Ljava/lang/Integer;
            invokevirtual java.lang.Integer.intValue:()I
         5: .line 58
            invokestatic java.lang.Math.min:(II)I
            invokestatic java.lang.Math.max:(II)I
            istore 0 /* priority */
        start local 0 // int priority
         6: .line 61
            new io.reactivex.internal.schedulers.RxThreadFactory
            dup
            ldc "RxComputationThreadPool"
            iload 0 /* priority */
            iconst_1
            invokespecial io.reactivex.internal.schedulers.RxThreadFactory.<init>:(Ljava/lang/String;IZ)V
            putstatic io.reactivex.internal.schedulers.ComputationScheduler.THREAD_FACTORY:Lio/reactivex/internal/schedulers/RxThreadFactory;
         7: .line 63
            new io.reactivex.internal.schedulers.ComputationScheduler$FixedSchedulerPool
            dup
            iconst_0
            getstatic io.reactivex.internal.schedulers.ComputationScheduler.THREAD_FACTORY:Lio/reactivex/internal/schedulers/RxThreadFactory;
            invokespecial io.reactivex.internal.schedulers.ComputationScheduler$FixedSchedulerPool.<init>:(ILjava/util/concurrent/ThreadFactory;)V
            putstatic io.reactivex.internal.schedulers.ComputationScheduler.NONE:Lio/reactivex/internal/schedulers/ComputationScheduler$FixedSchedulerPool;
         8: .line 64
            getstatic io.reactivex.internal.schedulers.ComputationScheduler.NONE:Lio/reactivex/internal/schedulers/ComputationScheduler$FixedSchedulerPool;
            invokevirtual io.reactivex.internal.schedulers.ComputationScheduler$FixedSchedulerPool.shutdown:()V
        end local 0 // int priority
         9: .line 65
            return
      LocalVariableTable:
        Start  End  Slot      Name  Signature
            6    9     0  priority  I

  static int cap(int, int);
    descriptor: (II)I
    flags: (0x0008) ACC_STATIC
    Code:
      stack=2, locals=2, args_size=2
        start local 0 // int cpuCount
        start local 1 // int paramThreads
         0: .line 68
            iload 1 /* paramThreads */
            ifle 1
            iload 1 /* paramThreads */
            iload 0 /* cpuCount */
            if_icmple 2
      StackMap locals:
      StackMap stack:
         1: iload 0 /* cpuCount */
            goto 3
      StackMap locals:
      StackMap stack:
         2: iload 1 /* paramThreads */
      StackMap locals:
      StackMap stack: int
         3: ireturn
        end local 1 // int paramThreads
        end local 0 // int cpuCount
      LocalVariableTable:
        Start  End  Slot          Name  Signature
            0    4     0      cpuCount  I
            0    4     1  paramThreads  I
    MethodParameters:
              Name  Flags
      cpuCount      
      paramThreads  

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

  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.ComputationScheduler this
        start local 1 // java.util.concurrent.ThreadFactory threadFactory
         0: .line 136
            aload 0 /* this */
            invokespecial io.reactivex.Scheduler.<init>:()V
         1: .line 137
            aload 0 /* this */
            aload 1 /* threadFactory */
            putfield io.reactivex.internal.schedulers.ComputationScheduler.threadFactory:Ljava/util/concurrent/ThreadFactory;
         2: .line 138
            aload 0 /* this */
            new java.util.concurrent.atomic.AtomicReference
            dup
            getstatic io.reactivex.internal.schedulers.ComputationScheduler.NONE:Lio/reactivex/internal/schedulers/ComputationScheduler$FixedSchedulerPool;
            invokespecial java.util.concurrent.atomic.AtomicReference.<init>:(Ljava/lang/Object;)V
            putfield io.reactivex.internal.schedulers.ComputationScheduler.pool:Ljava/util/concurrent/atomic/AtomicReference;
         3: .line 139
            aload 0 /* this */
            invokevirtual io.reactivex.internal.schedulers.ComputationScheduler.start:()V
         4: .line 140
            return
        end local 1 // java.util.concurrent.ThreadFactory threadFactory
        end local 0 // io.reactivex.internal.schedulers.ComputationScheduler this
      LocalVariableTable:
        Start  End  Slot           Name  Signature
            0    5     0           this  Lio/reactivex/internal/schedulers/ComputationScheduler;
            0    5     1  threadFactory  Ljava/util/concurrent/ThreadFactory;
    MethodParameters:
               Name  Flags
      threadFactory  

  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.ComputationScheduler this
         0: .line 145
            new io.reactivex.internal.schedulers.ComputationScheduler$EventLoopWorker
            dup
            aload 0 /* this */
            getfield io.reactivex.internal.schedulers.ComputationScheduler.pool:Ljava/util/concurrent/atomic/AtomicReference;
            invokevirtual java.util.concurrent.atomic.AtomicReference.get:()Ljava/lang/Object;
            checkcast io.reactivex.internal.schedulers.ComputationScheduler$FixedSchedulerPool
            invokevirtual io.reactivex.internal.schedulers.ComputationScheduler$FixedSchedulerPool.getEventLoop:()Lio/reactivex/internal/schedulers/ComputationScheduler$PoolWorker;
            invokespecial io.reactivex.internal.schedulers.ComputationScheduler$EventLoopWorker.<init>:(Lio/reactivex/internal/schedulers/ComputationScheduler$PoolWorker;)V
            areturn
        end local 0 // io.reactivex.internal.schedulers.ComputationScheduler this
      LocalVariableTable:
        Start  End  Slot  Name  Signature
            0    1     0  this  Lio/reactivex/internal/schedulers/ComputationScheduler;
    RuntimeInvisibleAnnotations: 
      io.reactivex.annotations.NonNull()

  public void createWorkers(int, io.reactivex.internal.schedulers.SchedulerMultiWorkerSupport$WorkerCallback);
    descriptor: (ILio/reactivex/internal/schedulers/SchedulerMultiWorkerSupport$WorkerCallback;)V
    flags: (0x0001) ACC_PUBLIC
    Code:
      stack=3, locals=3, args_size=3
        start local 0 // io.reactivex.internal.schedulers.ComputationScheduler this
        start local 1 // int number
        start local 2 // io.reactivex.internal.schedulers.SchedulerMultiWorkerSupport$WorkerCallback callback
         0: .line 150
            iload 1 /* number */
            ldc "number > 0 required"
            invokestatic io.reactivex.internal.functions.ObjectHelper.verifyPositive:(ILjava/lang/String;)I
            pop
         1: .line 151
            aload 0 /* this */
            getfield io.reactivex.internal.schedulers.ComputationScheduler.pool:Ljava/util/concurrent/atomic/AtomicReference;
            invokevirtual java.util.concurrent.atomic.AtomicReference.get:()Ljava/lang/Object;
            checkcast io.reactivex.internal.schedulers.ComputationScheduler$FixedSchedulerPool
            iload 1 /* number */
            aload 2 /* callback */
            invokevirtual io.reactivex.internal.schedulers.ComputationScheduler$FixedSchedulerPool.createWorkers:(ILio/reactivex/internal/schedulers/SchedulerMultiWorkerSupport$WorkerCallback;)V
         2: .line 152
            return
        end local 2 // io.reactivex.internal.schedulers.SchedulerMultiWorkerSupport$WorkerCallback callback
        end local 1 // int number
        end local 0 // io.reactivex.internal.schedulers.ComputationScheduler this
      LocalVariableTable:
        Start  End  Slot      Name  Signature
            0    3     0      this  Lio/reactivex/internal/schedulers/ComputationScheduler;
            0    3     1    number  I
            0    3     2  callback  Lio/reactivex/internal/schedulers/SchedulerMultiWorkerSupport$WorkerCallback;
    MethodParameters:
          Name  Flags
      number    
      callback  

  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=6, args_size=4
        start local 0 // io.reactivex.internal.schedulers.ComputationScheduler this
        start local 1 // java.lang.Runnable run
        start local 2 // long delay
        start local 4 // java.util.concurrent.TimeUnit unit
         0: .line 157
            aload 0 /* this */
            getfield io.reactivex.internal.schedulers.ComputationScheduler.pool:Ljava/util/concurrent/atomic/AtomicReference;
            invokevirtual java.util.concurrent.atomic.AtomicReference.get:()Ljava/lang/Object;
            checkcast io.reactivex.internal.schedulers.ComputationScheduler$FixedSchedulerPool
            invokevirtual io.reactivex.internal.schedulers.ComputationScheduler$FixedSchedulerPool.getEventLoop:()Lio/reactivex/internal/schedulers/ComputationScheduler$PoolWorker;
            astore 5 /* w */
        start local 5 // io.reactivex.internal.schedulers.ComputationScheduler$PoolWorker w
         1: .line 158
            aload 5 /* w */
            aload 1 /* run */
            lload 2 /* delay */
            aload 4 /* unit */
            invokevirtual io.reactivex.internal.schedulers.ComputationScheduler$PoolWorker.scheduleDirect:(Ljava/lang/Runnable;JLjava/util/concurrent/TimeUnit;)Lio/reactivex/disposables/Disposable;
            areturn
        end local 5 // io.reactivex.internal.schedulers.ComputationScheduler$PoolWorker w
        end local 4 // java.util.concurrent.TimeUnit unit
        end local 2 // long delay
        end local 1 // java.lang.Runnable run
        end local 0 // io.reactivex.internal.schedulers.ComputationScheduler this
      LocalVariableTable:
        Start  End  Slot   Name  Signature
            0    2     0   this  Lio/reactivex/internal/schedulers/ComputationScheduler;
            0    2     1    run  Ljava/lang/Runnable;
            0    2     2  delay  J
            0    2     4   unit  Ljava/util/concurrent/TimeUnit;
            1    2     5      w  Lio/reactivex/internal/schedulers/ComputationScheduler$PoolWorker;
    RuntimeInvisibleAnnotations: 
      io.reactivex.annotations.NonNull()
    RuntimeInvisibleParameterAnnotations: 
      0:
        io.reactivex.annotations.NonNull()
      1:
      2:
    MethodParameters:
       Name  Flags
      run    
      delay  
      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=8, args_size=5
        start local 0 // io.reactivex.internal.schedulers.ComputationScheduler this
        start local 1 // java.lang.Runnable run
        start local 2 // long initialDelay
        start local 4 // long period
        start local 6 // java.util.concurrent.TimeUnit unit
         0: .line 164
            aload 0 /* this */
            getfield io.reactivex.internal.schedulers.ComputationScheduler.pool:Ljava/util/concurrent/atomic/AtomicReference;
            invokevirtual java.util.concurrent.atomic.AtomicReference.get:()Ljava/lang/Object;
            checkcast io.reactivex.internal.schedulers.ComputationScheduler$FixedSchedulerPool
            invokevirtual io.reactivex.internal.schedulers.ComputationScheduler$FixedSchedulerPool.getEventLoop:()Lio/reactivex/internal/schedulers/ComputationScheduler$PoolWorker;
            astore 7 /* w */
        start local 7 // io.reactivex.internal.schedulers.ComputationScheduler$PoolWorker w
         1: .line 165
            aload 7 /* w */
            aload 1 /* run */
            lload 2 /* initialDelay */
            lload 4 /* period */
            aload 6 /* unit */
            invokevirtual io.reactivex.internal.schedulers.ComputationScheduler$PoolWorker.schedulePeriodicallyDirect:(Ljava/lang/Runnable;JJLjava/util/concurrent/TimeUnit;)Lio/reactivex/disposables/Disposable;
            areturn
        end local 7 // io.reactivex.internal.schedulers.ComputationScheduler$PoolWorker w
        end local 6 // java.util.concurrent.TimeUnit unit
        end local 4 // long period
        end local 2 // long initialDelay
        end local 1 // java.lang.Runnable run
        end local 0 // io.reactivex.internal.schedulers.ComputationScheduler this
      LocalVariableTable:
        Start  End  Slot          Name  Signature
            0    2     0          this  Lio/reactivex/internal/schedulers/ComputationScheduler;
            0    2     1           run  Ljava/lang/Runnable;
            0    2     2  initialDelay  J
            0    2     4        period  J
            0    2     6          unit  Ljava/util/concurrent/TimeUnit;
            1    2     7             w  Lio/reactivex/internal/schedulers/ComputationScheduler$PoolWorker;
    RuntimeInvisibleAnnotations: 
      io.reactivex.annotations.NonNull()
    RuntimeInvisibleParameterAnnotations: 
      0:
        io.reactivex.annotations.NonNull()
      1:
      2:
      3:
    MethodParameters:
              Name  Flags
      run           
      initialDelay  
      period        
      unit          

  public void start();
    descriptor: ()V
    flags: (0x0001) ACC_PUBLIC
    Code:
      stack=4, locals=2, args_size=1
        start local 0 // io.reactivex.internal.schedulers.ComputationScheduler this
         0: .line 170
            new io.reactivex.internal.schedulers.ComputationScheduler$FixedSchedulerPool
            dup
            getstatic io.reactivex.internal.schedulers.ComputationScheduler.MAX_THREADS:I
            aload 0 /* this */
            getfield io.reactivex.internal.schedulers.ComputationScheduler.threadFactory:Ljava/util/concurrent/ThreadFactory;
            invokespecial io.reactivex.internal.schedulers.ComputationScheduler$FixedSchedulerPool.<init>:(ILjava/util/concurrent/ThreadFactory;)V
            astore 1 /* update */
        start local 1 // io.reactivex.internal.schedulers.ComputationScheduler$FixedSchedulerPool update
         1: .line 171
            aload 0 /* this */
            getfield io.reactivex.internal.schedulers.ComputationScheduler.pool:Ljava/util/concurrent/atomic/AtomicReference;
            getstatic io.reactivex.internal.schedulers.ComputationScheduler.NONE:Lio/reactivex/internal/schedulers/ComputationScheduler$FixedSchedulerPool;
            aload 1 /* update */
            invokevirtual java.util.concurrent.atomic.AtomicReference.compareAndSet:(Ljava/lang/Object;Ljava/lang/Object;)Z
            ifne 3
         2: .line 172
            aload 1 /* update */
            invokevirtual io.reactivex.internal.schedulers.ComputationScheduler$FixedSchedulerPool.shutdown:()V
         3: .line 174
      StackMap locals: io.reactivex.internal.schedulers.ComputationScheduler$FixedSchedulerPool
      StackMap stack:
            return
        end local 1 // io.reactivex.internal.schedulers.ComputationScheduler$FixedSchedulerPool update
        end local 0 // io.reactivex.internal.schedulers.ComputationScheduler this
      LocalVariableTable:
        Start  End  Slot    Name  Signature
            0    4     0    this  Lio/reactivex/internal/schedulers/ComputationScheduler;
            1    4     1  update  Lio/reactivex/internal/schedulers/ComputationScheduler$FixedSchedulerPool;

  public void shutdown();
    descriptor: ()V
    flags: (0x0001) ACC_PUBLIC
    Code:
      stack=3, locals=2, args_size=1
        start local 0 // io.reactivex.internal.schedulers.ComputationScheduler this
         0: .line 179
      StackMap locals:
      StackMap stack:
            aload 0 /* this */
            getfield io.reactivex.internal.schedulers.ComputationScheduler.pool:Ljava/util/concurrent/atomic/AtomicReference;
            invokevirtual java.util.concurrent.atomic.AtomicReference.get:()Ljava/lang/Object;
            checkcast io.reactivex.internal.schedulers.ComputationScheduler$FixedSchedulerPool
            astore 1 /* curr */
        start local 1 // io.reactivex.internal.schedulers.ComputationScheduler$FixedSchedulerPool curr
         1: .line 180
            aload 1 /* curr */
            getstatic io.reactivex.internal.schedulers.ComputationScheduler.NONE:Lio/reactivex/internal/schedulers/ComputationScheduler$FixedSchedulerPool;
            if_acmpne 3
         2: .line 181
            return
         3: .line 183
      StackMap locals: io.reactivex.internal.schedulers.ComputationScheduler$FixedSchedulerPool
      StackMap stack:
            aload 0 /* this */
            getfield io.reactivex.internal.schedulers.ComputationScheduler.pool:Ljava/util/concurrent/atomic/AtomicReference;
            aload 1 /* curr */
            getstatic io.reactivex.internal.schedulers.ComputationScheduler.NONE:Lio/reactivex/internal/schedulers/ComputationScheduler$FixedSchedulerPool;
            invokevirtual java.util.concurrent.atomic.AtomicReference.compareAndSet:(Ljava/lang/Object;Ljava/lang/Object;)Z
            ifeq 0
         4: .line 184
            aload 1 /* curr */
            invokevirtual io.reactivex.internal.schedulers.ComputationScheduler$FixedSchedulerPool.shutdown:()V
         5: .line 185
            return
        end local 1 // io.reactivex.internal.schedulers.ComputationScheduler$FixedSchedulerPool curr
        end local 0 // io.reactivex.internal.schedulers.ComputationScheduler this
      LocalVariableTable:
        Start  End  Slot  Name  Signature
            0    6     0  this  Lio/reactivex/internal/schedulers/ComputationScheduler;
            1    6     1  curr  Lio/reactivex/internal/schedulers/ComputationScheduler$FixedSchedulerPool;
}
SourceFile: "ComputationScheduler.java"
NestMembers:
  io.reactivex.internal.schedulers.ComputationScheduler$EventLoopWorker  io.reactivex.internal.schedulers.ComputationScheduler$FixedSchedulerPool  io.reactivex.internal.schedulers.ComputationScheduler$PoolWorker
InnerClasses:
  public abstract Worker = io.reactivex.Scheduler$Worker of io.reactivex.Scheduler
  final EventLoopWorker = io.reactivex.internal.schedulers.ComputationScheduler$EventLoopWorker of io.reactivex.internal.schedulers.ComputationScheduler
  final FixedSchedulerPool = io.reactivex.internal.schedulers.ComputationScheduler$FixedSchedulerPool of io.reactivex.internal.schedulers.ComputationScheduler
  final PoolWorker = io.reactivex.internal.schedulers.ComputationScheduler$PoolWorker of io.reactivex.internal.schedulers.ComputationScheduler
  public abstract WorkerCallback = io.reactivex.internal.schedulers.SchedulerMultiWorkerSupport$WorkerCallback of io.reactivex.internal.schedulers.SchedulerMultiWorkerSupport