public final class io.reactivex.internal.schedulers.ExecutorScheduler$ExecutorWorker extends io.reactivex.Scheduler$Worker implements java.lang.Runnable
  minor version: 0
  major version: 59
  flags: flags: (0x0031) ACC_PUBLIC, ACC_FINAL, ACC_SUPER
  this_class: io.reactivex.internal.schedulers.ExecutorScheduler$ExecutorWorker
  super_class: io.reactivex.Scheduler$Worker
{
  final boolean interruptibleWorker;
    descriptor: Z
    flags: (0x0010) ACC_FINAL

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

  final io.reactivex.internal.queue.MpscLinkedQueue<java.lang.Runnable> queue;
    descriptor: Lio/reactivex/internal/queue/MpscLinkedQueue;
    flags: (0x0010) ACC_FINAL
    Signature: Lio/reactivex/internal/queue/MpscLinkedQueue<Ljava/lang/Runnable;>;

  volatile boolean disposed;
    descriptor: Z
    flags: (0x0040) ACC_VOLATILE

  final java.util.concurrent.atomic.AtomicInteger wip;
    descriptor: Ljava/util/concurrent/atomic/AtomicInteger;
    flags: (0x0010) ACC_FINAL

  final io.reactivex.disposables.CompositeDisposable tasks;
    descriptor: Lio/reactivex/disposables/CompositeDisposable;
    flags: (0x0010) ACC_FINAL

  public void <init>(java.util.concurrent.Executor, boolean);
    descriptor: (Ljava/util/concurrent/Executor;Z)V
    flags: (0x0001) ACC_PUBLIC
    Code:
      stack=3, locals=3, args_size=3
        start local 0 // io.reactivex.internal.schedulers.ExecutorScheduler$ExecutorWorker this
        start local 1 // java.util.concurrent.Executor executor
        start local 2 // boolean interruptibleWorker
         0: .line 136
            aload 0 /* this */
            invokespecial io.reactivex.Scheduler$Worker.<init>:()V
         1: .line 132
            aload 0 /* this */
            new java.util.concurrent.atomic.AtomicInteger
            dup
            invokespecial java.util.concurrent.atomic.AtomicInteger.<init>:()V
            putfield io.reactivex.internal.schedulers.ExecutorScheduler$ExecutorWorker.wip:Ljava/util/concurrent/atomic/AtomicInteger;
         2: .line 134
            aload 0 /* this */
            new io.reactivex.disposables.CompositeDisposable
            dup
            invokespecial io.reactivex.disposables.CompositeDisposable.<init>:()V
            putfield io.reactivex.internal.schedulers.ExecutorScheduler$ExecutorWorker.tasks:Lio/reactivex/disposables/CompositeDisposable;
         3: .line 137
            aload 0 /* this */
            aload 1 /* executor */
            putfield io.reactivex.internal.schedulers.ExecutorScheduler$ExecutorWorker.executor:Ljava/util/concurrent/Executor;
         4: .line 138
            aload 0 /* this */
            new io.reactivex.internal.queue.MpscLinkedQueue
            dup
            invokespecial io.reactivex.internal.queue.MpscLinkedQueue.<init>:()V
            putfield io.reactivex.internal.schedulers.ExecutorScheduler$ExecutorWorker.queue:Lio/reactivex/internal/queue/MpscLinkedQueue;
         5: .line 139
            aload 0 /* this */
            iload 2 /* interruptibleWorker */
            putfield io.reactivex.internal.schedulers.ExecutorScheduler$ExecutorWorker.interruptibleWorker:Z
         6: .line 140
            return
        end local 2 // boolean interruptibleWorker
        end local 1 // java.util.concurrent.Executor executor
        end local 0 // io.reactivex.internal.schedulers.ExecutorScheduler$ExecutorWorker this
      LocalVariableTable:
        Start  End  Slot                 Name  Signature
            0    7     0                 this  Lio/reactivex/internal/schedulers/ExecutorScheduler$ExecutorWorker;
            0    7     1             executor  Ljava/util/concurrent/Executor;
            0    7     2  interruptibleWorker  Z
    MethodParameters:
                     Name  Flags
      executor             
      interruptibleWorker  

  public io.reactivex.disposables.Disposable schedule(java.lang.Runnable);
    descriptor: (Ljava/lang/Runnable;)Lio/reactivex/disposables/Disposable;
    flags: (0x0001) ACC_PUBLIC
    Code:
      stack=4, locals=6, args_size=2
        start local 0 // io.reactivex.internal.schedulers.ExecutorScheduler$ExecutorWorker this
        start local 1 // java.lang.Runnable run
         0: .line 145
            aload 0 /* this */
            getfield io.reactivex.internal.schedulers.ExecutorScheduler$ExecutorWorker.disposed:Z
            ifeq 2
         1: .line 146
            getstatic io.reactivex.internal.disposables.EmptyDisposable.INSTANCE:Lio/reactivex/internal/disposables/EmptyDisposable;
            areturn
         2: .line 149
      StackMap locals:
      StackMap stack:
            aload 1 /* run */
            invokestatic io.reactivex.plugins.RxJavaPlugins.onSchedule:(Ljava/lang/Runnable;)Ljava/lang/Runnable;
            astore 2 /* decoratedRun */
        start local 2 // java.lang.Runnable decoratedRun
         3: .line 154
            aload 0 /* this */
            getfield io.reactivex.internal.schedulers.ExecutorScheduler$ExecutorWorker.interruptibleWorker:Z
            ifeq 9
         4: .line 155
            new io.reactivex.internal.schedulers.ExecutorScheduler$ExecutorWorker$InterruptibleRunnable
            dup
            aload 2 /* decoratedRun */
            aload 0 /* this */
            getfield io.reactivex.internal.schedulers.ExecutorScheduler$ExecutorWorker.tasks:Lio/reactivex/disposables/CompositeDisposable;
            invokespecial io.reactivex.internal.schedulers.ExecutorScheduler$ExecutorWorker$InterruptibleRunnable.<init>:(Ljava/lang/Runnable;Lio/reactivex/internal/disposables/DisposableContainer;)V
            astore 5 /* interruptibleTask */
        start local 5 // io.reactivex.internal.schedulers.ExecutorScheduler$ExecutorWorker$InterruptibleRunnable interruptibleTask
         5: .line 156
            aload 0 /* this */
            getfield io.reactivex.internal.schedulers.ExecutorScheduler$ExecutorWorker.tasks:Lio/reactivex/disposables/CompositeDisposable;
            aload 5 /* interruptibleTask */
            invokevirtual io.reactivex.disposables.CompositeDisposable.add:(Lio/reactivex/disposables/Disposable;)Z
            pop
         6: .line 158
            aload 5 /* interruptibleTask */
            astore 3 /* task */
        start local 3 // java.lang.Runnable task
         7: .line 159
            aload 5 /* interruptibleTask */
            astore 4 /* disposable */
        end local 5 // io.reactivex.internal.schedulers.ExecutorScheduler$ExecutorWorker$InterruptibleRunnable interruptibleTask
        start local 4 // io.reactivex.disposables.Disposable disposable
         8: .line 160
            goto 12
        end local 4 // io.reactivex.disposables.Disposable disposable
        end local 3 // java.lang.Runnable task
         9: .line 161
      StackMap locals: java.lang.Runnable
      StackMap stack:
            new io.reactivex.internal.schedulers.ExecutorScheduler$ExecutorWorker$BooleanRunnable
            dup
            aload 2 /* decoratedRun */
            invokespecial io.reactivex.internal.schedulers.ExecutorScheduler$ExecutorWorker$BooleanRunnable.<init>:(Ljava/lang/Runnable;)V
            astore 5 /* runnableTask */
        start local 5 // io.reactivex.internal.schedulers.ExecutorScheduler$ExecutorWorker$BooleanRunnable runnableTask
        10: .line 163
            aload 5 /* runnableTask */
            astore 3 /* task */
        start local 3 // java.lang.Runnable task
        11: .line 164
            aload 5 /* runnableTask */
            astore 4 /* disposable */
        end local 5 // io.reactivex.internal.schedulers.ExecutorScheduler$ExecutorWorker$BooleanRunnable runnableTask
        start local 4 // io.reactivex.disposables.Disposable disposable
        12: .line 167
      StackMap locals: java.lang.Runnable io.reactivex.disposables.Disposable
      StackMap stack:
            aload 0 /* this */
            getfield io.reactivex.internal.schedulers.ExecutorScheduler$ExecutorWorker.queue:Lio/reactivex/internal/queue/MpscLinkedQueue;
            aload 3 /* task */
            invokevirtual io.reactivex.internal.queue.MpscLinkedQueue.offer:(Ljava/lang/Object;)Z
            pop
        13: .line 169
            aload 0 /* this */
            getfield io.reactivex.internal.schedulers.ExecutorScheduler$ExecutorWorker.wip:Ljava/util/concurrent/atomic/AtomicInteger;
            invokevirtual java.util.concurrent.atomic.AtomicInteger.getAndIncrement:()I
            ifne 21
        14: .line 171
            aload 0 /* this */
            getfield io.reactivex.internal.schedulers.ExecutorScheduler$ExecutorWorker.executor:Ljava/util/concurrent/Executor;
            aload 0 /* this */
            invokeinterface java.util.concurrent.Executor.execute:(Ljava/lang/Runnable;)V
        15: .line 172
            goto 21
      StackMap locals:
      StackMap stack: java.util.concurrent.RejectedExecutionException
        16: astore 5 /* ex */
        start local 5 // java.util.concurrent.RejectedExecutionException ex
        17: .line 173
            aload 0 /* this */
            iconst_1
            putfield io.reactivex.internal.schedulers.ExecutorScheduler$ExecutorWorker.disposed:Z
        18: .line 174
            aload 0 /* this */
            getfield io.reactivex.internal.schedulers.ExecutorScheduler$ExecutorWorker.queue:Lio/reactivex/internal/queue/MpscLinkedQueue;
            invokevirtual io.reactivex.internal.queue.MpscLinkedQueue.clear:()V
        19: .line 175
            aload 5 /* ex */
            invokestatic io.reactivex.plugins.RxJavaPlugins.onError:(Ljava/lang/Throwable;)V
        20: .line 176
            getstatic io.reactivex.internal.disposables.EmptyDisposable.INSTANCE:Lio/reactivex/internal/disposables/EmptyDisposable;
            areturn
        end local 5 // java.util.concurrent.RejectedExecutionException ex
        21: .line 180
      StackMap locals:
      StackMap stack:
            aload 4 /* disposable */
            areturn
        end local 4 // io.reactivex.disposables.Disposable disposable
        end local 3 // java.lang.Runnable task
        end local 2 // java.lang.Runnable decoratedRun
        end local 1 // java.lang.Runnable run
        end local 0 // io.reactivex.internal.schedulers.ExecutorScheduler$ExecutorWorker this
      LocalVariableTable:
        Start  End  Slot               Name  Signature
            0   22     0               this  Lio/reactivex/internal/schedulers/ExecutorScheduler$ExecutorWorker;
            0   22     1                run  Ljava/lang/Runnable;
            3   22     2       decoratedRun  Ljava/lang/Runnable;
            7    9     3               task  Ljava/lang/Runnable;
           11   22     3               task  Ljava/lang/Runnable;
            8    9     4         disposable  Lio/reactivex/disposables/Disposable;
           12   22     4         disposable  Lio/reactivex/disposables/Disposable;
            5    8     5  interruptibleTask  Lio/reactivex/internal/schedulers/ExecutorScheduler$ExecutorWorker$InterruptibleRunnable;
           10   12     5       runnableTask  Lio/reactivex/internal/schedulers/ExecutorScheduler$ExecutorWorker$BooleanRunnable;
           17   21     5                 ex  Ljava/util/concurrent/RejectedExecutionException;
      Exception table:
        from    to  target  type
          14    15      16  Class java.util.concurrent.RejectedExecutionException
    RuntimeInvisibleAnnotations: 
      io.reactivex.annotations.NonNull()
    RuntimeInvisibleParameterAnnotations: 
      0:
        io.reactivex.annotations.NonNull()
    MethodParameters:
      Name  Flags
      run   

  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=7, locals=10, args_size=4
        start local 0 // io.reactivex.internal.schedulers.ExecutorScheduler$ExecutorWorker this
        start local 1 // java.lang.Runnable run
        start local 2 // long delay
        start local 4 // java.util.concurrent.TimeUnit unit
         0: .line 186
            lload 2 /* delay */
            lconst_0
            lcmp
            ifgt 2
         1: .line 187
            aload 0 /* this */
            aload 1 /* run */
            invokevirtual io.reactivex.internal.schedulers.ExecutorScheduler$ExecutorWorker.schedule:(Ljava/lang/Runnable;)Lio/reactivex/disposables/Disposable;
            areturn
         2: .line 189
      StackMap locals:
      StackMap stack:
            aload 0 /* this */
            getfield io.reactivex.internal.schedulers.ExecutorScheduler$ExecutorWorker.disposed:Z
            ifeq 4
         3: .line 190
            getstatic io.reactivex.internal.disposables.EmptyDisposable.INSTANCE:Lio/reactivex/internal/disposables/EmptyDisposable;
            areturn
         4: .line 193
      StackMap locals:
      StackMap stack:
            new io.reactivex.internal.disposables.SequentialDisposable
            dup
            invokespecial io.reactivex.internal.disposables.SequentialDisposable.<init>:()V
            astore 5 /* first */
        start local 5 // io.reactivex.internal.disposables.SequentialDisposable first
         5: .line 195
            new io.reactivex.internal.disposables.SequentialDisposable
            dup
            aload 5 /* first */
            invokespecial io.reactivex.internal.disposables.SequentialDisposable.<init>:(Lio/reactivex/disposables/Disposable;)V
            astore 6 /* mar */
        start local 6 // io.reactivex.internal.disposables.SequentialDisposable mar
         6: .line 197
            aload 1 /* run */
            invokestatic io.reactivex.plugins.RxJavaPlugins.onSchedule:(Ljava/lang/Runnable;)Ljava/lang/Runnable;
            astore 7 /* decoratedRun */
        start local 7 // java.lang.Runnable decoratedRun
         7: .line 199
            new io.reactivex.internal.schedulers.ScheduledRunnable
            dup
            new io.reactivex.internal.schedulers.ExecutorScheduler$ExecutorWorker$SequentialDispose
            dup
            aload 0 /* this */
            aload 6 /* mar */
            aload 7 /* decoratedRun */
            invokespecial io.reactivex.internal.schedulers.ExecutorScheduler$ExecutorWorker$SequentialDispose.<init>:(Lio/reactivex/internal/schedulers/ExecutorScheduler$ExecutorWorker;Lio/reactivex/internal/disposables/SequentialDisposable;Ljava/lang/Runnable;)V
            aload 0 /* this */
            getfield io.reactivex.internal.schedulers.ExecutorScheduler$ExecutorWorker.tasks:Lio/reactivex/disposables/CompositeDisposable;
            invokespecial io.reactivex.internal.schedulers.ScheduledRunnable.<init>:(Ljava/lang/Runnable;Lio/reactivex/internal/disposables/DisposableContainer;)V
            astore 8 /* sr */
        start local 8 // io.reactivex.internal.schedulers.ScheduledRunnable sr
         8: .line 200
            aload 0 /* this */
            getfield io.reactivex.internal.schedulers.ExecutorScheduler$ExecutorWorker.tasks:Lio/reactivex/disposables/CompositeDisposable;
            aload 8 /* sr */
            invokevirtual io.reactivex.disposables.CompositeDisposable.add:(Lio/reactivex/disposables/Disposable;)Z
            pop
         9: .line 202
            aload 0 /* this */
            getfield io.reactivex.internal.schedulers.ExecutorScheduler$ExecutorWorker.executor:Ljava/util/concurrent/Executor;
            instanceof java.util.concurrent.ScheduledExecutorService
            ifeq 17
        10: .line 204
            aload 0 /* this */
            getfield io.reactivex.internal.schedulers.ExecutorScheduler$ExecutorWorker.executor:Ljava/util/concurrent/Executor;
            checkcast java.util.concurrent.ScheduledExecutorService
            aload 8 /* sr */
            lload 2 /* delay */
            aload 4 /* unit */
            invokeinterface java.util.concurrent.ScheduledExecutorService.schedule:(Ljava/util/concurrent/Callable;JLjava/util/concurrent/TimeUnit;)Ljava/util/concurrent/ScheduledFuture;
            astore 9 /* f */
        start local 9 // java.util.concurrent.Future f
        11: .line 205
            aload 8 /* sr */
            aload 9 /* f */
            invokevirtual io.reactivex.internal.schedulers.ScheduledRunnable.setFuture:(Ljava/util/concurrent/Future;)V
        end local 9 // java.util.concurrent.Future f
        12: .line 206
            goto 19
      StackMap locals: io.reactivex.internal.schedulers.ExecutorScheduler$ExecutorWorker java.lang.Runnable long java.util.concurrent.TimeUnit io.reactivex.internal.disposables.SequentialDisposable io.reactivex.internal.disposables.SequentialDisposable java.lang.Runnable io.reactivex.internal.schedulers.ScheduledRunnable
      StackMap stack: java.util.concurrent.RejectedExecutionException
        13: astore 9 /* ex */
        start local 9 // java.util.concurrent.RejectedExecutionException ex
        14: .line 207
            aload 0 /* this */
            iconst_1
            putfield io.reactivex.internal.schedulers.ExecutorScheduler$ExecutorWorker.disposed:Z
        15: .line 208
            aload 9 /* ex */
            invokestatic io.reactivex.plugins.RxJavaPlugins.onError:(Ljava/lang/Throwable;)V
        16: .line 209
            getstatic io.reactivex.internal.disposables.EmptyDisposable.INSTANCE:Lio/reactivex/internal/disposables/EmptyDisposable;
            areturn
        end local 9 // java.util.concurrent.RejectedExecutionException ex
        17: .line 212
      StackMap locals:
      StackMap stack:
            getstatic io.reactivex.internal.schedulers.ExecutorScheduler.HELPER:Lio/reactivex/Scheduler;
            aload 8 /* sr */
            lload 2 /* delay */
            aload 4 /* unit */
            invokevirtual io.reactivex.Scheduler.scheduleDirect:(Ljava/lang/Runnable;JLjava/util/concurrent/TimeUnit;)Lio/reactivex/disposables/Disposable;
            astore 9 /* d */
        start local 9 // io.reactivex.disposables.Disposable d
        18: .line 213
            aload 8 /* sr */
            new io.reactivex.internal.schedulers.DisposeOnCancel
            dup
            aload 9 /* d */
            invokespecial io.reactivex.internal.schedulers.DisposeOnCancel.<init>:(Lio/reactivex/disposables/Disposable;)V
            invokevirtual io.reactivex.internal.schedulers.ScheduledRunnable.setFuture:(Ljava/util/concurrent/Future;)V
        end local 9 // io.reactivex.disposables.Disposable d
        19: .line 216
      StackMap locals:
      StackMap stack:
            aload 5 /* first */
            aload 8 /* sr */
            invokevirtual io.reactivex.internal.disposables.SequentialDisposable.replace:(Lio/reactivex/disposables/Disposable;)Z
            pop
        20: .line 218
            aload 6 /* mar */
            areturn
        end local 8 // io.reactivex.internal.schedulers.ScheduledRunnable sr
        end local 7 // java.lang.Runnable decoratedRun
        end local 6 // io.reactivex.internal.disposables.SequentialDisposable mar
        end local 5 // io.reactivex.internal.disposables.SequentialDisposable first
        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.ExecutorScheduler$ExecutorWorker this
      LocalVariableTable:
        Start  End  Slot          Name  Signature
            0   21     0          this  Lio/reactivex/internal/schedulers/ExecutorScheduler$ExecutorWorker;
            0   21     1           run  Ljava/lang/Runnable;
            0   21     2         delay  J
            0   21     4          unit  Ljava/util/concurrent/TimeUnit;
            5   21     5         first  Lio/reactivex/internal/disposables/SequentialDisposable;
            6   21     6           mar  Lio/reactivex/internal/disposables/SequentialDisposable;
            7   21     7  decoratedRun  Ljava/lang/Runnable;
            8   21     8            sr  Lio/reactivex/internal/schedulers/ScheduledRunnable;
           11   12     9             f  Ljava/util/concurrent/Future<*>;
           14   17     9            ex  Ljava/util/concurrent/RejectedExecutionException;
           18   19     9             d  Lio/reactivex/disposables/Disposable;
      Exception table:
        from    to  target  type
          10    12      13  Class java.util.concurrent.RejectedExecutionException
    RuntimeInvisibleAnnotations: 
      io.reactivex.annotations.NonNull()
    RuntimeInvisibleParameterAnnotations: 
      0:
        io.reactivex.annotations.NonNull()
      1:
      2:
        io.reactivex.annotations.NonNull()
    MethodParameters:
       Name  Flags
      run    
      delay  
      unit   

  public void dispose();
    descriptor: ()V
    flags: (0x0001) ACC_PUBLIC
    Code:
      stack=2, locals=1, args_size=1
        start local 0 // io.reactivex.internal.schedulers.ExecutorScheduler$ExecutorWorker this
         0: .line 223
            aload 0 /* this */
            getfield io.reactivex.internal.schedulers.ExecutorScheduler$ExecutorWorker.disposed:Z
            ifne 5
         1: .line 224
            aload 0 /* this */
            iconst_1
            putfield io.reactivex.internal.schedulers.ExecutorScheduler$ExecutorWorker.disposed:Z
         2: .line 225
            aload 0 /* this */
            getfield io.reactivex.internal.schedulers.ExecutorScheduler$ExecutorWorker.tasks:Lio/reactivex/disposables/CompositeDisposable;
            invokevirtual io.reactivex.disposables.CompositeDisposable.dispose:()V
         3: .line 226
            aload 0 /* this */
            getfield io.reactivex.internal.schedulers.ExecutorScheduler$ExecutorWorker.wip:Ljava/util/concurrent/atomic/AtomicInteger;
            invokevirtual java.util.concurrent.atomic.AtomicInteger.getAndIncrement:()I
            ifne 5
         4: .line 227
            aload 0 /* this */
            getfield io.reactivex.internal.schedulers.ExecutorScheduler$ExecutorWorker.queue:Lio/reactivex/internal/queue/MpscLinkedQueue;
            invokevirtual io.reactivex.internal.queue.MpscLinkedQueue.clear:()V
         5: .line 230
      StackMap locals:
      StackMap stack:
            return
        end local 0 // io.reactivex.internal.schedulers.ExecutorScheduler$ExecutorWorker this
      LocalVariableTable:
        Start  End  Slot  Name  Signature
            0    6     0  this  Lio/reactivex/internal/schedulers/ExecutorScheduler$ExecutorWorker;

  public boolean isDisposed();
    descriptor: ()Z
    flags: (0x0001) ACC_PUBLIC
    Code:
      stack=1, locals=1, args_size=1
        start local 0 // io.reactivex.internal.schedulers.ExecutorScheduler$ExecutorWorker this
         0: .line 234
            aload 0 /* this */
            getfield io.reactivex.internal.schedulers.ExecutorScheduler$ExecutorWorker.disposed:Z
            ireturn
        end local 0 // io.reactivex.internal.schedulers.ExecutorScheduler$ExecutorWorker this
      LocalVariableTable:
        Start  End  Slot  Name  Signature
            0    1     0  this  Lio/reactivex/internal/schedulers/ExecutorScheduler$ExecutorWorker;

  public void run();
    descriptor: ()V
    flags: (0x0001) ACC_PUBLIC
    Code:
      stack=2, locals=4, args_size=1
        start local 0 // io.reactivex.internal.schedulers.ExecutorScheduler$ExecutorWorker this
         0: .line 239
            iconst_1
            istore 1 /* missed */
        start local 1 // int missed
         1: .line 240
            aload 0 /* this */
            getfield io.reactivex.internal.schedulers.ExecutorScheduler$ExecutorWorker.queue:Lio/reactivex/internal/queue/MpscLinkedQueue;
            astore 2 /* q */
        start local 2 // io.reactivex.internal.queue.MpscLinkedQueue q
         2: .line 243
      StackMap locals: int io.reactivex.internal.queue.MpscLinkedQueue
      StackMap stack:
            aload 0 /* this */
            getfield io.reactivex.internal.schedulers.ExecutorScheduler$ExecutorWorker.disposed:Z
            ifeq 5
         3: .line 244
            aload 2 /* q */
            invokevirtual io.reactivex.internal.queue.MpscLinkedQueue.clear:()V
         4: .line 245
            return
         5: .line 249
      StackMap locals:
      StackMap stack:
            aload 2 /* q */
            invokevirtual io.reactivex.internal.queue.MpscLinkedQueue.poll:()Ljava/lang/Object;
            checkcast java.lang.Runnable
            astore 3 /* run */
        start local 3 // java.lang.Runnable run
         6: .line 250
            aload 3 /* run */
            ifnonnull 8
         7: .line 251
            goto 12
         8: .line 253
      StackMap locals: java.lang.Runnable
      StackMap stack:
            aload 3 /* run */
            invokeinterface java.lang.Runnable.run:()V
         9: .line 255
            aload 0 /* this */
            getfield io.reactivex.internal.schedulers.ExecutorScheduler$ExecutorWorker.disposed:Z
            ifeq 5
        10: .line 256
            aload 2 /* q */
            invokevirtual io.reactivex.internal.queue.MpscLinkedQueue.clear:()V
        11: .line 257
            return
        end local 3 // java.lang.Runnable run
        12: .line 261
      StackMap locals:
      StackMap stack:
            aload 0 /* this */
            getfield io.reactivex.internal.schedulers.ExecutorScheduler$ExecutorWorker.disposed:Z
            ifeq 15
        13: .line 262
            aload 2 /* q */
            invokevirtual io.reactivex.internal.queue.MpscLinkedQueue.clear:()V
        14: .line 263
            return
        15: .line 266
      StackMap locals:
      StackMap stack:
            aload 0 /* this */
            getfield io.reactivex.internal.schedulers.ExecutorScheduler$ExecutorWorker.wip:Ljava/util/concurrent/atomic/AtomicInteger;
            iload 1 /* missed */
            ineg
            invokevirtual java.util.concurrent.atomic.AtomicInteger.addAndGet:(I)I
            istore 1 /* missed */
        16: .line 267
            iload 1 /* missed */
            ifne 2
        17: .line 271
            return
        end local 2 // io.reactivex.internal.queue.MpscLinkedQueue q
        end local 1 // int missed
        end local 0 // io.reactivex.internal.schedulers.ExecutorScheduler$ExecutorWorker this
      LocalVariableTable:
        Start  End  Slot    Name  Signature
            0   18     0    this  Lio/reactivex/internal/schedulers/ExecutorScheduler$ExecutorWorker;
            1   18     1  missed  I
            2   18     2       q  Lio/reactivex/internal/queue/MpscLinkedQueue<Ljava/lang/Runnable;>;
            6   12     3     run  Ljava/lang/Runnable;
}
SourceFile: "ExecutorScheduler.java"
NestHost: io.reactivex.internal.schedulers.ExecutorScheduler
InnerClasses:
  public abstract Worker = io.reactivex.Scheduler$Worker of io.reactivex.Scheduler
  public final ExecutorWorker = io.reactivex.internal.schedulers.ExecutorScheduler$ExecutorWorker of io.reactivex.internal.schedulers.ExecutorScheduler
  final BooleanRunnable = io.reactivex.internal.schedulers.ExecutorScheduler$ExecutorWorker$BooleanRunnable of io.reactivex.internal.schedulers.ExecutorScheduler$ExecutorWorker
  final InterruptibleRunnable = io.reactivex.internal.schedulers.ExecutorScheduler$ExecutorWorker$InterruptibleRunnable of io.reactivex.internal.schedulers.ExecutorScheduler$ExecutorWorker
  final SequentialDispose = io.reactivex.internal.schedulers.ExecutorScheduler$ExecutorWorker$SequentialDispose of io.reactivex.internal.schedulers.ExecutorScheduler$ExecutorWorker