http://lmax-exchange.github.com/disruptor: Disruptor - Concurrent Programming Framework
  • LMAX Disruptor Development Team 
public final class com.lmax.disruptor.WorkerPool<T>
  minor version: 0
  major version: 59
  flags: flags: (0x0031) ACC_PUBLIC, ACC_FINAL, ACC_SUPER
  this_class: com.lmax.disruptor.WorkerPool
  super_class: java.lang.Object
{
  private final java.util.concurrent.atomic.AtomicBoolean started;
    descriptor: Ljava/util/concurrent/atomic/AtomicBoolean;
    flags: (0x0012) ACC_PRIVATE, ACC_FINAL

  private final com.lmax.disruptor.Sequence workSequence;
    descriptor: Lcom/lmax/disruptor/Sequence;
    flags: (0x0012) ACC_PRIVATE, ACC_FINAL

  private final com.lmax.disruptor.RingBuffer<T> ringBuffer;
    descriptor: Lcom/lmax/disruptor/RingBuffer;
    flags: (0x0012) ACC_PRIVATE, ACC_FINAL
    Signature: Lcom/lmax/disruptor/RingBuffer<TT;>;

  private final com.lmax.disruptor.WorkProcessor<?>[] workProcessors;
    descriptor: [Lcom/lmax/disruptor/WorkProcessor;
    flags: (0x0012) ACC_PRIVATE, ACC_FINAL
    Signature: [Lcom/lmax/disruptor/WorkProcessor<*>;

  public void <init>(com.lmax.disruptor.RingBuffer<T>, com.lmax.disruptor.SequenceBarrier, com.lmax.disruptor.ExceptionHandler<? super T>, com.lmax.disruptor.WorkHandler<? super T>[]);
    descriptor: (Lcom/lmax/disruptor/RingBuffer;Lcom/lmax/disruptor/SequenceBarrier;Lcom/lmax/disruptor/ExceptionHandler;[Lcom/lmax/disruptor/WorkHandler;)V
    flags: (0x0081) ACC_PUBLIC, ACC_VARARGS
    Code:
      stack=9, locals=7, args_size=5
        start local 0 // com.lmax.disruptor.WorkerPool this
        start local 1 // com.lmax.disruptor.RingBuffer ringBuffer
        start local 2 // com.lmax.disruptor.SequenceBarrier sequenceBarrier
        start local 3 // com.lmax.disruptor.ExceptionHandler exceptionHandler
        start local 4 // com.lmax.disruptor.WorkHandler[] workHandlers
         0: .line 49
            aload 0 /* this */
            invokespecial java.lang.Object.<init>:()V
         1: .line 31
            aload 0 /* this */
            new java.util.concurrent.atomic.AtomicBoolean
            dup
            iconst_0
            invokespecial java.util.concurrent.atomic.AtomicBoolean.<init>:(Z)V
            putfield com.lmax.disruptor.WorkerPool.started:Ljava/util/concurrent/atomic/AtomicBoolean;
         2: .line 32
            aload 0 /* this */
            new com.lmax.disruptor.Sequence
            dup
            ldc -1
            invokespecial com.lmax.disruptor.Sequence.<init>:(J)V
            putfield com.lmax.disruptor.WorkerPool.workSequence:Lcom/lmax/disruptor/Sequence;
         3: .line 55
            aload 0 /* this */
            aload 1 /* ringBuffer */
            putfield com.lmax.disruptor.WorkerPool.ringBuffer:Lcom/lmax/disruptor/RingBuffer;
         4: .line 56
            aload 4 /* workHandlers */
            arraylength
            istore 5 /* numWorkers */
        start local 5 // int numWorkers
         5: .line 57
            aload 0 /* this */
            iload 5 /* numWorkers */
            anewarray com.lmax.disruptor.WorkProcessor
            putfield com.lmax.disruptor.WorkerPool.workProcessors:[Lcom/lmax/disruptor/WorkProcessor;
         6: .line 59
            iconst_0
            istore 6 /* i */
        start local 6 // int i
         7: goto 16
         8: .line 61
      StackMap locals: com.lmax.disruptor.WorkerPool com.lmax.disruptor.RingBuffer com.lmax.disruptor.SequenceBarrier com.lmax.disruptor.ExceptionHandler com.lmax.disruptor.WorkHandler[] int int
      StackMap stack:
            aload 0 /* this */
            getfield com.lmax.disruptor.WorkerPool.workProcessors:[Lcom/lmax/disruptor/WorkProcessor;
            iload 6 /* i */
            new com.lmax.disruptor.WorkProcessor
            dup
         9: .line 62
            aload 1 /* ringBuffer */
        10: .line 63
            aload 2 /* sequenceBarrier */
        11: .line 64
            aload 4 /* workHandlers */
            iload 6 /* i */
            aaload
        12: .line 65
            aload 3 /* exceptionHandler */
        13: .line 66
            aload 0 /* this */
            getfield com.lmax.disruptor.WorkerPool.workSequence:Lcom/lmax/disruptor/Sequence;
            invokespecial com.lmax.disruptor.WorkProcessor.<init>:(Lcom/lmax/disruptor/RingBuffer;Lcom/lmax/disruptor/SequenceBarrier;Lcom/lmax/disruptor/WorkHandler;Lcom/lmax/disruptor/ExceptionHandler;Lcom/lmax/disruptor/Sequence;)V
        14: .line 61
            aastore
        15: .line 59
            iinc 6 /* i */ 1
      StackMap locals:
      StackMap stack:
        16: iload 6 /* i */
            iload 5 /* numWorkers */
            if_icmplt 8
        end local 6 // int i
        17: .line 68
            return
        end local 5 // int numWorkers
        end local 4 // com.lmax.disruptor.WorkHandler[] workHandlers
        end local 3 // com.lmax.disruptor.ExceptionHandler exceptionHandler
        end local 2 // com.lmax.disruptor.SequenceBarrier sequenceBarrier
        end local 1 // com.lmax.disruptor.RingBuffer ringBuffer
        end local 0 // com.lmax.disruptor.WorkerPool this
      LocalVariableTable:
        Start  End  Slot              Name  Signature
            0   18     0              this  Lcom/lmax/disruptor/WorkerPool<TT;>;
            0   18     1        ringBuffer  Lcom/lmax/disruptor/RingBuffer<TT;>;
            0   18     2   sequenceBarrier  Lcom/lmax/disruptor/SequenceBarrier;
            0   18     3  exceptionHandler  Lcom/lmax/disruptor/ExceptionHandler<-TT;>;
            0   18     4      workHandlers  [Lcom/lmax/disruptor/WorkHandler;
            5   18     5        numWorkers  I
            7   17     6                 i  I
    Signature: (Lcom/lmax/disruptor/RingBuffer<TT;>;Lcom/lmax/disruptor/SequenceBarrier;Lcom/lmax/disruptor/ExceptionHandler<-TT;>;[Lcom/lmax/disruptor/WorkHandler<-TT;>;)V
    RuntimeVisibleAnnotations: 
      java.lang.SafeVarargs()
    MethodParameters:
                  Name  Flags
      ringBuffer        final
      sequenceBarrier   final
      exceptionHandler  final
      workHandlers      final

  public void <init>(com.lmax.disruptor.EventFactory<T>, com.lmax.disruptor.ExceptionHandler<? super T>, com.lmax.disruptor.WorkHandler<? super T>[]);
    descriptor: (Lcom/lmax/disruptor/EventFactory;Lcom/lmax/disruptor/ExceptionHandler;[Lcom/lmax/disruptor/WorkHandler;)V
    flags: (0x0081) ACC_PUBLIC, ACC_VARARGS
    Code:
      stack=9, locals=7, args_size=4
        start local 0 // com.lmax.disruptor.WorkerPool this
        start local 1 // com.lmax.disruptor.EventFactory eventFactory
        start local 2 // com.lmax.disruptor.ExceptionHandler exceptionHandler
        start local 3 // com.lmax.disruptor.WorkHandler[] workHandlers
         0: .line 80
            aload 0 /* this */
            invokespecial java.lang.Object.<init>:()V
         1: .line 31
            aload 0 /* this */
            new java.util.concurrent.atomic.AtomicBoolean
            dup
            iconst_0
            invokespecial java.util.concurrent.atomic.AtomicBoolean.<init>:(Z)V
            putfield com.lmax.disruptor.WorkerPool.started:Ljava/util/concurrent/atomic/AtomicBoolean;
         2: .line 32
            aload 0 /* this */
            new com.lmax.disruptor.Sequence
            dup
            ldc -1
            invokespecial com.lmax.disruptor.Sequence.<init>:(J)V
            putfield com.lmax.disruptor.WorkerPool.workSequence:Lcom/lmax/disruptor/Sequence;
         3: .line 85
            aload 0 /* this */
            aload 1 /* eventFactory */
            sipush 1024
            new com.lmax.disruptor.BlockingWaitStrategy
            dup
            invokespecial com.lmax.disruptor.BlockingWaitStrategy.<init>:()V
            invokestatic com.lmax.disruptor.RingBuffer.createMultiProducer:(Lcom/lmax/disruptor/EventFactory;ILcom/lmax/disruptor/WaitStrategy;)Lcom/lmax/disruptor/RingBuffer;
            putfield com.lmax.disruptor.WorkerPool.ringBuffer:Lcom/lmax/disruptor/RingBuffer;
         4: .line 86
            aload 0 /* this */
            getfield com.lmax.disruptor.WorkerPool.ringBuffer:Lcom/lmax/disruptor/RingBuffer;
            iconst_0
            anewarray com.lmax.disruptor.Sequence
            invokevirtual com.lmax.disruptor.RingBuffer.newBarrier:([Lcom/lmax/disruptor/Sequence;)Lcom/lmax/disruptor/SequenceBarrier;
            astore 4 /* barrier */
        start local 4 // com.lmax.disruptor.SequenceBarrier barrier
         5: .line 87
            aload 3 /* workHandlers */
            arraylength
            istore 5 /* numWorkers */
        start local 5 // int numWorkers
         6: .line 88
            aload 0 /* this */
            iload 5 /* numWorkers */
            anewarray com.lmax.disruptor.WorkProcessor
            putfield com.lmax.disruptor.WorkerPool.workProcessors:[Lcom/lmax/disruptor/WorkProcessor;
         7: .line 90
            iconst_0
            istore 6 /* i */
        start local 6 // int i
         8: goto 17
         9: .line 92
      StackMap locals: com.lmax.disruptor.WorkerPool com.lmax.disruptor.EventFactory com.lmax.disruptor.ExceptionHandler com.lmax.disruptor.WorkHandler[] com.lmax.disruptor.SequenceBarrier int int
      StackMap stack:
            aload 0 /* this */
            getfield com.lmax.disruptor.WorkerPool.workProcessors:[Lcom/lmax/disruptor/WorkProcessor;
            iload 6 /* i */
            new com.lmax.disruptor.WorkProcessor
            dup
        10: .line 93
            aload 0 /* this */
            getfield com.lmax.disruptor.WorkerPool.ringBuffer:Lcom/lmax/disruptor/RingBuffer;
        11: .line 94
            aload 4 /* barrier */
        12: .line 95
            aload 3 /* workHandlers */
            iload 6 /* i */
            aaload
        13: .line 96
            aload 2 /* exceptionHandler */
        14: .line 97
            aload 0 /* this */
            getfield com.lmax.disruptor.WorkerPool.workSequence:Lcom/lmax/disruptor/Sequence;
            invokespecial com.lmax.disruptor.WorkProcessor.<init>:(Lcom/lmax/disruptor/RingBuffer;Lcom/lmax/disruptor/SequenceBarrier;Lcom/lmax/disruptor/WorkHandler;Lcom/lmax/disruptor/ExceptionHandler;Lcom/lmax/disruptor/Sequence;)V
        15: .line 92
            aastore
        16: .line 90
            iinc 6 /* i */ 1
      StackMap locals:
      StackMap stack:
        17: iload 6 /* i */
            iload 5 /* numWorkers */
            if_icmplt 9
        end local 6 // int i
        18: .line 100
            aload 0 /* this */
            getfield com.lmax.disruptor.WorkerPool.ringBuffer:Lcom/lmax/disruptor/RingBuffer;
            aload 0 /* this */
            invokevirtual com.lmax.disruptor.WorkerPool.getWorkerSequences:()[Lcom/lmax/disruptor/Sequence;
            invokevirtual com.lmax.disruptor.RingBuffer.addGatingSequences:([Lcom/lmax/disruptor/Sequence;)V
        19: .line 101
            return
        end local 5 // int numWorkers
        end local 4 // com.lmax.disruptor.SequenceBarrier barrier
        end local 3 // com.lmax.disruptor.WorkHandler[] workHandlers
        end local 2 // com.lmax.disruptor.ExceptionHandler exceptionHandler
        end local 1 // com.lmax.disruptor.EventFactory eventFactory
        end local 0 // com.lmax.disruptor.WorkerPool this
      LocalVariableTable:
        Start  End  Slot              Name  Signature
            0   20     0              this  Lcom/lmax/disruptor/WorkerPool<TT;>;
            0   20     1      eventFactory  Lcom/lmax/disruptor/EventFactory<TT;>;
            0   20     2  exceptionHandler  Lcom/lmax/disruptor/ExceptionHandler<-TT;>;
            0   20     3      workHandlers  [Lcom/lmax/disruptor/WorkHandler;
            5   20     4           barrier  Lcom/lmax/disruptor/SequenceBarrier;
            6   20     5        numWorkers  I
            8   18     6                 i  I
    Signature: (Lcom/lmax/disruptor/EventFactory<TT;>;Lcom/lmax/disruptor/ExceptionHandler<-TT;>;[Lcom/lmax/disruptor/WorkHandler<-TT;>;)V
    RuntimeVisibleAnnotations: 
      java.lang.SafeVarargs()
    MethodParameters:
                  Name  Flags
      eventFactory      final
      exceptionHandler  final
      workHandlers      final

  public com.lmax.disruptor.Sequence[] getWorkerSequences();
    descriptor: ()[Lcom/lmax/disruptor/Sequence;
    flags: (0x0001) ACC_PUBLIC
    Code:
      stack=4, locals=4, args_size=1
        start local 0 // com.lmax.disruptor.WorkerPool this
         0: .line 110
            aload 0 /* this */
            getfield com.lmax.disruptor.WorkerPool.workProcessors:[Lcom/lmax/disruptor/WorkProcessor;
            arraylength
            iconst_1
            iadd
            anewarray com.lmax.disruptor.Sequence
            astore 1 /* sequences */
        start local 1 // com.lmax.disruptor.Sequence[] sequences
         1: .line 111
            iconst_0
            istore 2 /* i */
        start local 2 // int i
         2: aload 0 /* this */
            getfield com.lmax.disruptor.WorkerPool.workProcessors:[Lcom/lmax/disruptor/WorkProcessor;
            arraylength
            istore 3 /* size */
        start local 3 // int size
         3: goto 6
         4: .line 113
      StackMap locals: com.lmax.disruptor.Sequence[] int int
      StackMap stack:
            aload 1 /* sequences */
            iload 2 /* i */
            aload 0 /* this */
            getfield com.lmax.disruptor.WorkerPool.workProcessors:[Lcom/lmax/disruptor/WorkProcessor;
            iload 2 /* i */
            aaload
            invokevirtual com.lmax.disruptor.WorkProcessor.getSequence:()Lcom/lmax/disruptor/Sequence;
            aastore
         5: .line 111
            iinc 2 /* i */ 1
      StackMap locals:
      StackMap stack:
         6: iload 2 /* i */
            iload 3 /* size */
            if_icmplt 4
        end local 3 // int size
        end local 2 // int i
         7: .line 115
            aload 1 /* sequences */
            aload 1 /* sequences */
            arraylength
            iconst_1
            isub
            aload 0 /* this */
            getfield com.lmax.disruptor.WorkerPool.workSequence:Lcom/lmax/disruptor/Sequence;
            aastore
         8: .line 117
            aload 1 /* sequences */
            areturn
        end local 1 // com.lmax.disruptor.Sequence[] sequences
        end local 0 // com.lmax.disruptor.WorkerPool this
      LocalVariableTable:
        Start  End  Slot       Name  Signature
            0    9     0       this  Lcom/lmax/disruptor/WorkerPool<TT;>;
            1    9     1  sequences  [Lcom/lmax/disruptor/Sequence;
            2    7     2          i  I
            3    7     3       size  I

  public com.lmax.disruptor.RingBuffer<T> start(java.util.concurrent.Executor);
    descriptor: (Ljava/util/concurrent/Executor;)Lcom/lmax/disruptor/RingBuffer;
    flags: (0x0001) ACC_PUBLIC
    Code:
      stack=3, locals=8, args_size=2
        start local 0 // com.lmax.disruptor.WorkerPool this
        start local 1 // java.util.concurrent.Executor executor
         0: .line 129
            aload 0 /* this */
            getfield com.lmax.disruptor.WorkerPool.started:Ljava/util/concurrent/atomic/AtomicBoolean;
            iconst_0
            iconst_1
            invokevirtual java.util.concurrent.atomic.AtomicBoolean.compareAndSet:(ZZ)Z
            ifne 2
         1: .line 131
            new java.lang.IllegalStateException
            dup
            ldc "WorkerPool has already been started and cannot be restarted until halted."
            invokespecial java.lang.IllegalStateException.<init>:(Ljava/lang/String;)V
            athrow
         2: .line 134
      StackMap locals:
      StackMap stack:
            aload 0 /* this */
            getfield com.lmax.disruptor.WorkerPool.ringBuffer:Lcom/lmax/disruptor/RingBuffer;
            invokevirtual com.lmax.disruptor.RingBuffer.getCursor:()J
            lstore 2 /* cursor */
        start local 2 // long cursor
         3: .line 135
            aload 0 /* this */
            getfield com.lmax.disruptor.WorkerPool.workSequence:Lcom/lmax/disruptor/Sequence;
            lload 2 /* cursor */
            invokevirtual com.lmax.disruptor.Sequence.set:(J)V
         4: .line 137
            aload 0 /* this */
            getfield com.lmax.disruptor.WorkerPool.workProcessors:[Lcom/lmax/disruptor/WorkProcessor;
            dup
            astore 7
            arraylength
            istore 6
            iconst_0
            istore 5
            goto 9
      StackMap locals: com.lmax.disruptor.WorkerPool java.util.concurrent.Executor long top int int com.lmax.disruptor.WorkProcessor[]
      StackMap stack:
         5: aload 7
            iload 5
            aaload
            astore 4 /* processor */
        start local 4 // com.lmax.disruptor.WorkProcessor processor
         6: .line 139
            aload 4 /* processor */
            invokevirtual com.lmax.disruptor.WorkProcessor.getSequence:()Lcom/lmax/disruptor/Sequence;
            lload 2 /* cursor */
            invokevirtual com.lmax.disruptor.Sequence.set:(J)V
         7: .line 140
            aload 1 /* executor */
            aload 4 /* processor */
            invokeinterface java.util.concurrent.Executor.execute:(Ljava/lang/Runnable;)V
        end local 4 // com.lmax.disruptor.WorkProcessor processor
         8: .line 137
            iinc 5 1
      StackMap locals:
      StackMap stack:
         9: iload 5
            iload 6
            if_icmplt 5
        10: .line 143
            aload 0 /* this */
            getfield com.lmax.disruptor.WorkerPool.ringBuffer:Lcom/lmax/disruptor/RingBuffer;
            areturn
        end local 2 // long cursor
        end local 1 // java.util.concurrent.Executor executor
        end local 0 // com.lmax.disruptor.WorkerPool this
      LocalVariableTable:
        Start  End  Slot       Name  Signature
            0   11     0       this  Lcom/lmax/disruptor/WorkerPool<TT;>;
            0   11     1   executor  Ljava/util/concurrent/Executor;
            3   11     2     cursor  J
            6    8     4  processor  Lcom/lmax/disruptor/WorkProcessor<*>;
    Signature: (Ljava/util/concurrent/Executor;)Lcom/lmax/disruptor/RingBuffer<TT;>;
    MethodParameters:
          Name  Flags
      executor  final

  public void drainAndHalt();
    descriptor: ()V
    flags: (0x0001) ACC_PUBLIC
    Code:
      stack=4, locals=6, args_size=1
        start local 0 // com.lmax.disruptor.WorkerPool this
         0: .line 151
            aload 0 /* this */
            invokevirtual com.lmax.disruptor.WorkerPool.getWorkerSequences:()[Lcom/lmax/disruptor/Sequence;
            astore 1 /* workerSequences */
        start local 1 // com.lmax.disruptor.Sequence[] workerSequences
         1: .line 152
            goto 3
         2: .line 154
      StackMap locals: com.lmax.disruptor.Sequence[]
      StackMap stack:
            invokestatic java.lang.Thread.yield:()V
         3: .line 152
      StackMap locals:
      StackMap stack:
            aload 0 /* this */
            getfield com.lmax.disruptor.WorkerPool.ringBuffer:Lcom/lmax/disruptor/RingBuffer;
            invokevirtual com.lmax.disruptor.RingBuffer.getCursor:()J
            aload 1 /* workerSequences */
            invokestatic com.lmax.disruptor.util.Util.getMinimumSequence:([Lcom/lmax/disruptor/Sequence;)J
            lcmp
            ifgt 2
         4: .line 157
            aload 0 /* this */
            getfield com.lmax.disruptor.WorkerPool.workProcessors:[Lcom/lmax/disruptor/WorkProcessor;
            dup
            astore 5
            arraylength
            istore 4
            iconst_0
            istore 3
            goto 8
      StackMap locals: com.lmax.disruptor.WorkerPool com.lmax.disruptor.Sequence[] top int int com.lmax.disruptor.WorkProcessor[]
      StackMap stack:
         5: aload 5
            iload 3
            aaload
            astore 2 /* processor */
        start local 2 // com.lmax.disruptor.WorkProcessor processor
         6: .line 159
            aload 2 /* processor */
            invokevirtual com.lmax.disruptor.WorkProcessor.halt:()V
        end local 2 // com.lmax.disruptor.WorkProcessor processor
         7: .line 157
            iinc 3 1
      StackMap locals:
      StackMap stack:
         8: iload 3
            iload 4
            if_icmplt 5
         9: .line 162
            aload 0 /* this */
            getfield com.lmax.disruptor.WorkerPool.started:Ljava/util/concurrent/atomic/AtomicBoolean;
            iconst_0
            invokevirtual java.util.concurrent.atomic.AtomicBoolean.set:(Z)V
        10: .line 163
            return
        end local 1 // com.lmax.disruptor.Sequence[] workerSequences
        end local 0 // com.lmax.disruptor.WorkerPool this
      LocalVariableTable:
        Start  End  Slot             Name  Signature
            0   11     0             this  Lcom/lmax/disruptor/WorkerPool<TT;>;
            1   11     1  workerSequences  [Lcom/lmax/disruptor/Sequence;
            6    7     2        processor  Lcom/lmax/disruptor/WorkProcessor<*>;

  public void halt();
    descriptor: ()V
    flags: (0x0001) ACC_PUBLIC
    Code:
      stack=2, locals=5, args_size=1
        start local 0 // com.lmax.disruptor.WorkerPool this
         0: .line 170
            aload 0 /* this */
            getfield com.lmax.disruptor.WorkerPool.workProcessors:[Lcom/lmax/disruptor/WorkProcessor;
            dup
            astore 4
            arraylength
            istore 3
            iconst_0
            istore 2
            goto 4
      StackMap locals: com.lmax.disruptor.WorkerPool top int int com.lmax.disruptor.WorkProcessor[]
      StackMap stack:
         1: aload 4
            iload 2
            aaload
            astore 1 /* processor */
        start local 1 // com.lmax.disruptor.WorkProcessor processor
         2: .line 172
            aload 1 /* processor */
            invokevirtual com.lmax.disruptor.WorkProcessor.halt:()V
        end local 1 // com.lmax.disruptor.WorkProcessor processor
         3: .line 170
            iinc 2 1
      StackMap locals:
      StackMap stack:
         4: iload 2
            iload 3
            if_icmplt 1
         5: .line 175
            aload 0 /* this */
            getfield com.lmax.disruptor.WorkerPool.started:Ljava/util/concurrent/atomic/AtomicBoolean;
            iconst_0
            invokevirtual java.util.concurrent.atomic.AtomicBoolean.set:(Z)V
         6: .line 176
            return
        end local 0 // com.lmax.disruptor.WorkerPool this
      LocalVariableTable:
        Start  End  Slot       Name  Signature
            0    7     0       this  Lcom/lmax/disruptor/WorkerPool<TT;>;
            2    3     1  processor  Lcom/lmax/disruptor/WorkProcessor<*>;

  public boolean isRunning();
    descriptor: ()Z
    flags: (0x0001) ACC_PUBLIC
    Code:
      stack=1, locals=1, args_size=1
        start local 0 // com.lmax.disruptor.WorkerPool this
         0: .line 180
            aload 0 /* this */
            getfield com.lmax.disruptor.WorkerPool.started:Ljava/util/concurrent/atomic/AtomicBoolean;
            invokevirtual java.util.concurrent.atomic.AtomicBoolean.get:()Z
            ireturn
        end local 0 // com.lmax.disruptor.WorkerPool this
      LocalVariableTable:
        Start  End  Slot  Name  Signature
            0    1     0  this  Lcom/lmax/disruptor/WorkerPool<TT;>;
}
Signature: <T:Ljava/lang/Object;>Ljava/lang/Object;
SourceFile: "WorkerPool.java"