org.eclipse.jetty/jetty-util/10.0.0-alpha0 : org/eclipse/jetty/util/thread/strategy/ExecuteProduceConsume.class

ExecuteProduceConsume
http://www.eclipse.org/jetty: Utility classes for Jetty (Webtide)
Greg Wilkins (Webtide, LLC)
Jan Bartel (Webtide, LLC)
Jesse McConnell (Webtide, LLC)
Joakim Erdfelt (Webtide, LLC)
Simone Bordet (Webtide, LLC)
David Jencks (IBM)
Olivier Lamy (Webtide, LLC)
public class org.eclipse.jetty.util.thread.strategy.ExecuteProduceConsume implements org.eclipse.jetty.util.thread.ExecutionStrategy, java.lang.Runnable
  minor version: 0
  major version: 59
  flags: flags: (0x0021) ACC_PUBLIC, ACC_SUPER
  this_class: org.eclipse.jetty.util.thread.strategy.ExecuteProduceConsume
  super_class: java.lang.Object
{
  private static final org.eclipse.jetty.util.log.Logger LOG;
    descriptor: Lorg/eclipse/jetty/util/log/Logger;
    flags: (0x001a) ACC_PRIVATE, ACC_STATIC, ACC_FINAL

  private final org.eclipse.jetty.util.thread.Locker _locker;
    descriptor: Lorg/eclipse/jetty/util/thread/Locker;
    flags: (0x0012) ACC_PRIVATE, ACC_FINAL

  private final java.lang.Runnable _runProduce;
    descriptor: Ljava/lang/Runnable;
    flags: (0x0012) ACC_PRIVATE, ACC_FINAL

  private final org.eclipse.jetty.util.thread.ExecutionStrategy$Producer _producer;
    descriptor: Lorg/eclipse/jetty/util/thread/ExecutionStrategy$Producer;
    flags: (0x0012) ACC_PRIVATE, ACC_FINAL

  private final java.util.concurrent.Executor _executor;
    descriptor: Ljava/util/concurrent/Executor;
    flags: (0x0012) ACC_PRIVATE, ACC_FINAL

  private boolean _idle;
    descriptor: Z
    flags: (0x0002) ACC_PRIVATE

  private boolean _execute;
    descriptor: Z
    flags: (0x0002) ACC_PRIVATE

  private boolean _producing;
    descriptor: Z
    flags: (0x0002) ACC_PRIVATE

  private boolean _pending;
    descriptor: Z
    flags: (0x0002) ACC_PRIVATE

  static void <clinit>();
    descriptor: ()V
    flags: (0x0008) ACC_STATIC
    Code:
      stack=1, locals=0, args_size=0
         0: .line 46
            ldc Lorg/eclipse/jetty/util/thread/strategy/ExecuteProduceConsume;
            invokestatic org.eclipse.jetty.util.log.Log.getLogger:(Ljava/lang/Class;)Lorg/eclipse/jetty/util/log/Logger;
            putstatic org.eclipse.jetty.util.thread.strategy.ExecuteProduceConsume.LOG:Lorg/eclipse/jetty/util/log/Logger;
            return
      LocalVariableTable:
        Start  End  Slot  Name  Signature

  public void <init>(org.eclipse.jetty.util.thread.ExecutionStrategy$Producer, java.util.concurrent.Executor);
    descriptor: (Lorg/eclipse/jetty/util/thread/ExecutionStrategy$Producer;Ljava/util/concurrent/Executor;)V
    flags: (0x0001) ACC_PUBLIC
    Code:
      stack=4, locals=3, args_size=3
        start local 0 // org.eclipse.jetty.util.thread.strategy.ExecuteProduceConsume this
        start local 1 // org.eclipse.jetty.util.thread.ExecutionStrategy$Producer producer
        start local 2 // java.util.concurrent.Executor executor
         0: .line 57
            aload 0 /* this */
            invokespecial java.lang.Object.<init>:()V
         1: .line 48
            aload 0 /* this */
            new org.eclipse.jetty.util.thread.Locker
            dup
            invokespecial org.eclipse.jetty.util.thread.Locker.<init>:()V
            putfield org.eclipse.jetty.util.thread.strategy.ExecuteProduceConsume._locker:Lorg/eclipse/jetty/util/thread/Locker;
         2: .line 49
            aload 0 /* this */
            new org.eclipse.jetty.util.thread.strategy.ExecuteProduceConsume$RunProduce
            dup
            aload 0 /* this */
            invokespecial org.eclipse.jetty.util.thread.strategy.ExecuteProduceConsume$RunProduce.<init>:(Lorg/eclipse/jetty/util/thread/strategy/ExecuteProduceConsume;)V
            putfield org.eclipse.jetty.util.thread.strategy.ExecuteProduceConsume._runProduce:Ljava/lang/Runnable;
         3: .line 52
            aload 0 /* this */
            iconst_1
            putfield org.eclipse.jetty.util.thread.strategy.ExecuteProduceConsume._idle:Z
         4: .line 59
            aload 0 /* this */
            aload 1 /* producer */
            putfield org.eclipse.jetty.util.thread.strategy.ExecuteProduceConsume._producer:Lorg/eclipse/jetty/util/thread/ExecutionStrategy$Producer;
         5: .line 60
            aload 0 /* this */
            aload 2 /* executor */
            putfield org.eclipse.jetty.util.thread.strategy.ExecuteProduceConsume._executor:Ljava/util/concurrent/Executor;
         6: .line 61
            return
        end local 2 // java.util.concurrent.Executor executor
        end local 1 // org.eclipse.jetty.util.thread.ExecutionStrategy$Producer producer
        end local 0 // org.eclipse.jetty.util.thread.strategy.ExecuteProduceConsume this
      LocalVariableTable:
        Start  End  Slot      Name  Signature
            0    7     0      this  Lorg/eclipse/jetty/util/thread/strategy/ExecuteProduceConsume;
            0    7     1  producer  Lorg/eclipse/jetty/util/thread/ExecutionStrategy$Producer;
            0    7     2  executor  Ljava/util/concurrent/Executor;
    MethodParameters:
          Name  Flags
      producer  
      executor  

  public void produce();
    descriptor: ()V
    flags: (0x0001) ACC_PUBLIC
    Code:
      stack=6, locals=5, args_size=1
        start local 0 // org.eclipse.jetty.util.thread.strategy.ExecuteProduceConsume this
         0: .line 66
            getstatic org.eclipse.jetty.util.thread.strategy.ExecuteProduceConsume.LOG:Lorg/eclipse/jetty/util/log/Logger;
            invokeinterface org.eclipse.jetty.util.log.Logger.isDebugEnabled:()Z
            ifeq 2
         1: .line 67
            getstatic org.eclipse.jetty.util.thread.strategy.ExecuteProduceConsume.LOG:Lorg/eclipse/jetty/util/log/Logger;
            ldc "{} execute"
            iconst_1
            anewarray java.lang.Object
            dup
            iconst_0
            aload 0 /* this */
            aastore
            invokeinterface org.eclipse.jetty.util.log.Logger.debug:(Ljava/lang/String;[Ljava/lang/Object;)V
         2: .line 69
      StackMap locals:
      StackMap stack:
            iconst_0
            istore 1 /* produce */
        start local 1 // boolean produce
         3: .line 70
            aconst_null
            astore 2
            aconst_null
            astore 3
         4: aload 0 /* this */
            getfield org.eclipse.jetty.util.thread.strategy.ExecuteProduceConsume._locker:Lorg/eclipse/jetty/util/thread/Locker;
            invokevirtual org.eclipse.jetty.util.thread.Locker.lock:()Lorg/eclipse/jetty/util/thread/Locker$Lock;
            astore 4 /* locked */
        start local 4 // org.eclipse.jetty.util.thread.Locker$Lock locked
         5: .line 73
            aload 0 /* this */
            getfield org.eclipse.jetty.util.thread.strategy.ExecuteProduceConsume._idle:Z
            ifeq 11
         6: .line 75
            aload 0 /* this */
            getfield org.eclipse.jetty.util.thread.strategy.ExecuteProduceConsume._producing:Z
            ifeq 8
         7: .line 76
            new java.lang.IllegalStateException
            dup
            invokespecial java.lang.IllegalStateException.<init>:()V
            athrow
         8: .line 79
      StackMap locals: org.eclipse.jetty.util.thread.strategy.ExecuteProduceConsume int java.lang.Throwable java.lang.Throwable org.eclipse.jetty.util.thread.Locker$Lock
      StackMap stack:
            aload 0 /* this */
            iconst_1
            dup_x1
            putfield org.eclipse.jetty.util.thread.strategy.ExecuteProduceConsume._producing:Z
            istore 1 /* produce */
         9: .line 81
            aload 0 /* this */
            iconst_0
            putfield org.eclipse.jetty.util.thread.strategy.ExecuteProduceConsume._idle:Z
        10: .line 82
            goto 12
        11: .line 87
      StackMap locals:
      StackMap stack:
            aload 0 /* this */
            iconst_1
            putfield org.eclipse.jetty.util.thread.strategy.ExecuteProduceConsume._execute:Z
        12: .line 89
      StackMap locals:
      StackMap stack:
            aload 4 /* locked */
            ifnull 18
            aload 4 /* locked */
            invokevirtual org.eclipse.jetty.util.thread.Locker$Lock.close:()V
            goto 18
      StackMap locals:
      StackMap stack: java.lang.Throwable
        13: astore 2
            aload 4 /* locked */
            ifnull 14
            aload 4 /* locked */
            invokevirtual org.eclipse.jetty.util.thread.Locker$Lock.close:()V
        end local 4 // org.eclipse.jetty.util.thread.Locker$Lock locked
      StackMap locals:
      StackMap stack:
        14: aload 2
            athrow
      StackMap locals:
      StackMap stack: java.lang.Throwable
        15: astore 3
            aload 2
            ifnonnull 16
            aload 3
            astore 2
            goto 17
      StackMap locals:
      StackMap stack:
        16: aload 2
            aload 3
            if_acmpeq 17
            aload 2
            aload 3
            invokevirtual java.lang.Throwable.addSuppressed:(Ljava/lang/Throwable;)V
      StackMap locals:
      StackMap stack:
        17: aload 2
            athrow
        18: .line 91
      StackMap locals:
      StackMap stack:
            iload 1 /* produce */
            ifeq 20
        19: .line 92
            aload 0 /* this */
            invokevirtual org.eclipse.jetty.util.thread.strategy.ExecuteProduceConsume.produceConsume:()V
        20: .line 93
      StackMap locals:
      StackMap stack:
            return
        end local 1 // boolean produce
        end local 0 // org.eclipse.jetty.util.thread.strategy.ExecuteProduceConsume this
      LocalVariableTable:
        Start  End  Slot     Name  Signature
            0   21     0     this  Lorg/eclipse/jetty/util/thread/strategy/ExecuteProduceConsume;
            3   21     1  produce  Z
            5   14     4   locked  Lorg/eclipse/jetty/util/thread/Locker$Lock;
      Exception table:
        from    to  target  type
           5    12      13  any
           4    15      15  any

  public void dispatch();
    descriptor: ()V
    flags: (0x0001) ACC_PUBLIC
    Code:
      stack=6, locals=5, args_size=1
        start local 0 // org.eclipse.jetty.util.thread.strategy.ExecuteProduceConsume this
         0: .line 98
            getstatic org.eclipse.jetty.util.thread.strategy.ExecuteProduceConsume.LOG:Lorg/eclipse/jetty/util/log/Logger;
            invokeinterface org.eclipse.jetty.util.log.Logger.isDebugEnabled:()Z
            ifeq 2
         1: .line 99
            getstatic org.eclipse.jetty.util.thread.strategy.ExecuteProduceConsume.LOG:Lorg/eclipse/jetty/util/log/Logger;
            ldc "{} spawning"
            iconst_1
            anewarray java.lang.Object
            dup
            iconst_0
            aload 0 /* this */
            aastore
            invokeinterface org.eclipse.jetty.util.log.Logger.debug:(Ljava/lang/String;[Ljava/lang/Object;)V
         2: .line 100
      StackMap locals:
      StackMap stack:
            iconst_0
            istore 1 /* dispatch */
        start local 1 // boolean dispatch
         3: .line 101
            aconst_null
            astore 2
            aconst_null
            astore 3
         4: aload 0 /* this */
            getfield org.eclipse.jetty.util.thread.strategy.ExecuteProduceConsume._locker:Lorg/eclipse/jetty/util/thread/Locker;
            invokevirtual org.eclipse.jetty.util.thread.Locker.lock:()Lorg/eclipse/jetty/util/thread/Locker$Lock;
            astore 4 /* locked */
        start local 4 // org.eclipse.jetty.util.thread.Locker$Lock locked
         5: .line 103
            aload 0 /* this */
            getfield org.eclipse.jetty.util.thread.strategy.ExecuteProduceConsume._idle:Z
            ifeq 7
         6: .line 104
            iconst_1
            istore 1 /* dispatch */
            goto 8
         7: .line 106
      StackMap locals: org.eclipse.jetty.util.thread.strategy.ExecuteProduceConsume int java.lang.Throwable java.lang.Throwable org.eclipse.jetty.util.thread.Locker$Lock
      StackMap stack:
            aload 0 /* this */
            iconst_1
            putfield org.eclipse.jetty.util.thread.strategy.ExecuteProduceConsume._execute:Z
         8: .line 107
      StackMap locals:
      StackMap stack:
            aload 4 /* locked */
            ifnull 14
            aload 4 /* locked */
            invokevirtual org.eclipse.jetty.util.thread.Locker$Lock.close:()V
            goto 14
      StackMap locals:
      StackMap stack: java.lang.Throwable
         9: astore 2
            aload 4 /* locked */
            ifnull 10
            aload 4 /* locked */
            invokevirtual org.eclipse.jetty.util.thread.Locker$Lock.close:()V
        end local 4 // org.eclipse.jetty.util.thread.Locker$Lock locked
      StackMap locals:
      StackMap stack:
        10: aload 2
            athrow
      StackMap locals:
      StackMap stack: java.lang.Throwable
        11: astore 3
            aload 2
            ifnonnull 12
            aload 3
            astore 2
            goto 13
      StackMap locals:
      StackMap stack:
        12: aload 2
            aload 3
            if_acmpeq 13
            aload 2
            aload 3
            invokevirtual java.lang.Throwable.addSuppressed:(Ljava/lang/Throwable;)V
      StackMap locals:
      StackMap stack:
        13: aload 2
            athrow
        14: .line 108
      StackMap locals:
      StackMap stack:
            iload 1 /* dispatch */
            ifeq 16
        15: .line 109
            aload 0 /* this */
            getfield org.eclipse.jetty.util.thread.strategy.ExecuteProduceConsume._executor:Ljava/util/concurrent/Executor;
            aload 0 /* this */
            getfield org.eclipse.jetty.util.thread.strategy.ExecuteProduceConsume._runProduce:Ljava/lang/Runnable;
            invokeinterface java.util.concurrent.Executor.execute:(Ljava/lang/Runnable;)V
        16: .line 110
      StackMap locals:
      StackMap stack:
            return
        end local 1 // boolean dispatch
        end local 0 // org.eclipse.jetty.util.thread.strategy.ExecuteProduceConsume this
      LocalVariableTable:
        Start  End  Slot      Name  Signature
            0   17     0      this  Lorg/eclipse/jetty/util/thread/strategy/ExecuteProduceConsume;
            3   17     1  dispatch  Z
            5   10     4    locked  Lorg/eclipse/jetty/util/thread/Locker$Lock;
      Exception table:
        from    to  target  type
           5     8       9  any
           4    11      11  any

  public void run();
    descriptor: ()V
    flags: (0x0001) ACC_PUBLIC
    Code:
      stack=6, locals=5, args_size=1
        start local 0 // org.eclipse.jetty.util.thread.strategy.ExecuteProduceConsume this
         0: .line 115
            getstatic org.eclipse.jetty.util.thread.strategy.ExecuteProduceConsume.LOG:Lorg/eclipse/jetty/util/log/Logger;
            invokeinterface org.eclipse.jetty.util.log.Logger.isDebugEnabled:()Z
            ifeq 2
         1: .line 116
            getstatic org.eclipse.jetty.util.thread.strategy.ExecuteProduceConsume.LOG:Lorg/eclipse/jetty/util/log/Logger;
            ldc "{} run"
            iconst_1
            anewarray java.lang.Object
            dup
            iconst_0
            aload 0 /* this */
            aastore
            invokeinterface org.eclipse.jetty.util.log.Logger.debug:(Ljava/lang/String;[Ljava/lang/Object;)V
         2: .line 117
      StackMap locals:
      StackMap stack:
            iconst_0
            istore 1 /* produce */
        start local 1 // boolean produce
         3: .line 118
            aconst_null
            astore 2
            aconst_null
            astore 3
         4: aload 0 /* this */
            getfield org.eclipse.jetty.util.thread.strategy.ExecuteProduceConsume._locker:Lorg/eclipse/jetty/util/thread/Locker;
            invokevirtual org.eclipse.jetty.util.thread.Locker.lock:()Lorg/eclipse/jetty/util/thread/Locker$Lock;
            astore 4 /* locked */
        start local 4 // org.eclipse.jetty.util.thread.Locker$Lock locked
         5: .line 120
            aload 0 /* this */
            iconst_0
            putfield org.eclipse.jetty.util.thread.strategy.ExecuteProduceConsume._pending:Z
         6: .line 121
            aload 0 /* this */
            getfield org.eclipse.jetty.util.thread.strategy.ExecuteProduceConsume._idle:Z
            ifne 8
            aload 0 /* this */
            getfield org.eclipse.jetty.util.thread.strategy.ExecuteProduceConsume._producing:Z
            ifne 8
         7: .line 123
            aload 0 /* this */
            iconst_1
            dup_x1
            putfield org.eclipse.jetty.util.thread.strategy.ExecuteProduceConsume._producing:Z
            istore 1 /* produce */
         8: .line 125
      StackMap locals: org.eclipse.jetty.util.thread.strategy.ExecuteProduceConsume int java.lang.Throwable java.lang.Throwable org.eclipse.jetty.util.thread.Locker$Lock
      StackMap stack:
            aload 4 /* locked */
            ifnull 14
            aload 4 /* locked */
            invokevirtual org.eclipse.jetty.util.thread.Locker$Lock.close:()V
            goto 14
      StackMap locals:
      StackMap stack: java.lang.Throwable
         9: astore 2
            aload 4 /* locked */
            ifnull 10
            aload 4 /* locked */
            invokevirtual org.eclipse.jetty.util.thread.Locker$Lock.close:()V
        end local 4 // org.eclipse.jetty.util.thread.Locker$Lock locked
      StackMap locals:
      StackMap stack:
        10: aload 2
            athrow
      StackMap locals:
      StackMap stack: java.lang.Throwable
        11: astore 3
            aload 2
            ifnonnull 12
            aload 3
            astore 2
            goto 13
      StackMap locals:
      StackMap stack:
        12: aload 2
            aload 3
            if_acmpeq 13
            aload 2
            aload 3
            invokevirtual java.lang.Throwable.addSuppressed:(Ljava/lang/Throwable;)V
      StackMap locals:
      StackMap stack:
        13: aload 2
            athrow
        14: .line 127
      StackMap locals:
      StackMap stack:
            iload 1 /* produce */
            ifeq 16
        15: .line 128
            aload 0 /* this */
            invokevirtual org.eclipse.jetty.util.thread.strategy.ExecuteProduceConsume.produceConsume:()V
        16: .line 129
      StackMap locals:
      StackMap stack:
            return
        end local 1 // boolean produce
        end local 0 // org.eclipse.jetty.util.thread.strategy.ExecuteProduceConsume this
      LocalVariableTable:
        Start  End  Slot     Name  Signature
            0   17     0     this  Lorg/eclipse/jetty/util/thread/strategy/ExecuteProduceConsume;
            3   17     1  produce  Z
            5   10     4   locked  Lorg/eclipse/jetty/util/thread/Locker$Lock;
      Exception table:
        from    to  target  type
           5     8       9  any
           4    11      11  any

  private void produceConsume();
    descriptor: ()V
    flags: (0x0002) ACC_PRIVATE
    Code:
      stack=6, locals=6, args_size=1
        start local 0 // org.eclipse.jetty.util.thread.strategy.ExecuteProduceConsume this
         0: .line 133
            getstatic org.eclipse.jetty.util.thread.strategy.ExecuteProduceConsume.LOG:Lorg/eclipse/jetty/util/log/Logger;
            invokeinterface org.eclipse.jetty.util.log.Logger.isDebugEnabled:()Z
            ifeq 2
         1: .line 134
            getstatic org.eclipse.jetty.util.thread.strategy.ExecuteProduceConsume.LOG:Lorg/eclipse/jetty/util/log/Logger;
            ldc "{} produce enter"
            iconst_1
            anewarray java.lang.Object
            dup
            iconst_0
            aload 0 /* this */
            aastore
            invokeinterface org.eclipse.jetty.util.log.Logger.debug:(Ljava/lang/String;[Ljava/lang/Object;)V
         2: .line 139
      StackMap locals:
      StackMap stack:
            getstatic org.eclipse.jetty.util.thread.strategy.ExecuteProduceConsume.LOG:Lorg/eclipse/jetty/util/log/Logger;
            invokeinterface org.eclipse.jetty.util.log.Logger.isDebugEnabled:()Z
            ifeq 4
         3: .line 140
            getstatic org.eclipse.jetty.util.thread.strategy.ExecuteProduceConsume.LOG:Lorg/eclipse/jetty/util/log/Logger;
            ldc "{} producing"
            iconst_1
            anewarray java.lang.Object
            dup
            iconst_0
            aload 0 /* this */
            aastore
            invokeinterface org.eclipse.jetty.util.log.Logger.debug:(Ljava/lang/String;[Ljava/lang/Object;)V
         4: .line 142
      StackMap locals:
      StackMap stack:
            aload 0 /* this */
            getfield org.eclipse.jetty.util.thread.strategy.ExecuteProduceConsume._producer:Lorg/eclipse/jetty/util/thread/ExecutionStrategy$Producer;
            invokeinterface org.eclipse.jetty.util.thread.ExecutionStrategy$Producer.produce:()Ljava/lang/Runnable;
            astore 1 /* task */
        start local 1 // java.lang.Runnable task
         5: .line 144
            getstatic org.eclipse.jetty.util.thread.strategy.ExecuteProduceConsume.LOG:Lorg/eclipse/jetty/util/log/Logger;
            invokeinterface org.eclipse.jetty.util.log.Logger.isDebugEnabled:()Z
            ifeq 7
         6: .line 145
            getstatic org.eclipse.jetty.util.thread.strategy.ExecuteProduceConsume.LOG:Lorg/eclipse/jetty/util/log/Logger;
            ldc "{} produced {}"
            iconst_2
            anewarray java.lang.Object
            dup
            iconst_0
            aload 0 /* this */
            aastore
            dup
            iconst_1
            aload 1 /* task */
            aastore
            invokeinterface org.eclipse.jetty.util.log.Logger.debug:(Ljava/lang/String;[Ljava/lang/Object;)V
         7: .line 147
      StackMap locals: java.lang.Runnable
      StackMap stack:
            iconst_0
            istore 2 /* dispatch */
        start local 2 // boolean dispatch
         8: .line 148
            aconst_null
            astore 3
            aconst_null
            astore 4
         9: aload 0 /* this */
            getfield org.eclipse.jetty.util.thread.strategy.ExecuteProduceConsume._locker:Lorg/eclipse/jetty/util/thread/Locker;
            invokevirtual org.eclipse.jetty.util.thread.Locker.lock:()Lorg/eclipse/jetty/util/thread/Locker$Lock;
            astore 5 /* locked */
        start local 5 // org.eclipse.jetty.util.thread.Locker$Lock locked
        10: .line 151
            aload 0 /* this */
            iconst_0
            putfield org.eclipse.jetty.util.thread.strategy.ExecuteProduceConsume._producing:Z
        11: .line 154
            aload 1 /* task */
            ifnonnull 21
        12: .line 158
            aload 0 /* this */
            getfield org.eclipse.jetty.util.thread.strategy.ExecuteProduceConsume._execute:Z
            ifeq 18
        13: .line 160
            aload 0 /* this */
            iconst_0
            putfield org.eclipse.jetty.util.thread.strategy.ExecuteProduceConsume._idle:Z
        14: .line 161
            aload 0 /* this */
            iconst_1
            putfield org.eclipse.jetty.util.thread.strategy.ExecuteProduceConsume._producing:Z
        15: .line 162
            aload 0 /* this */
            iconst_0
            putfield org.eclipse.jetty.util.thread.strategy.ExecuteProduceConsume._execute:Z
        16: .line 180
            aload 5 /* locked */
            ifnull 2
            aload 5 /* locked */
            invokevirtual org.eclipse.jetty.util.thread.Locker$Lock.close:()V
        17: .line 163
            goto 2
        18: .line 167
      StackMap locals: org.eclipse.jetty.util.thread.strategy.ExecuteProduceConsume java.lang.Runnable int java.lang.Throwable java.lang.Throwable org.eclipse.jetty.util.thread.Locker$Lock
      StackMap stack:
            aload 0 /* this */
            iconst_1
            putfield org.eclipse.jetty.util.thread.strategy.ExecuteProduceConsume._idle:Z
        19: .line 180
            aload 5 /* locked */
            ifnull 54
            aload 5 /* locked */
            invokevirtual org.eclipse.jetty.util.thread.Locker$Lock.close:()V
        20: .line 168
            goto 54
        21: .line 173
      StackMap locals:
      StackMap stack:
            aload 0 /* this */
            getfield org.eclipse.jetty.util.thread.strategy.ExecuteProduceConsume._pending:Z
            ifne 25
        22: .line 176
            aload 0 /* this */
            aload 1 /* task */
            invokestatic org.eclipse.jetty.util.thread.Invocable.getInvocationType:(Ljava/lang/Object;)Lorg/eclipse/jetty/util/thread/Invocable$InvocationType;
            getstatic org.eclipse.jetty.util.thread.Invocable$InvocationType.NON_BLOCKING:Lorg/eclipse/jetty/util/thread/Invocable$InvocationType;
            if_acmpeq 23
            iconst_1
            goto 24
      StackMap locals:
      StackMap stack: org.eclipse.jetty.util.thread.strategy.ExecuteProduceConsume
        23: iconst_0
      StackMap locals: org.eclipse.jetty.util.thread.strategy.ExecuteProduceConsume java.lang.Runnable int java.lang.Throwable java.lang.Throwable org.eclipse.jetty.util.thread.Locker$Lock
      StackMap stack: org.eclipse.jetty.util.thread.strategy.ExecuteProduceConsume int
        24: dup_x1
            putfield org.eclipse.jetty.util.thread.strategy.ExecuteProduceConsume._pending:Z
            istore 2 /* dispatch */
        25: .line 179
      StackMap locals:
      StackMap stack:
            aload 0 /* this */
            iconst_0
            putfield org.eclipse.jetty.util.thread.strategy.ExecuteProduceConsume._execute:Z
        26: .line 180
            aload 5 /* locked */
            ifnull 32
            aload 5 /* locked */
            invokevirtual org.eclipse.jetty.util.thread.Locker$Lock.close:()V
            goto 32
      StackMap locals:
      StackMap stack: java.lang.Throwable
        27: astore 3
            aload 5 /* locked */
            ifnull 28
            aload 5 /* locked */
            invokevirtual org.eclipse.jetty.util.thread.Locker$Lock.close:()V
        end local 5 // org.eclipse.jetty.util.thread.Locker$Lock locked
      StackMap locals:
      StackMap stack:
        28: aload 3
            athrow
      StackMap locals:
      StackMap stack: java.lang.Throwable
        29: astore 4
            aload 3
            ifnonnull 30
            aload 4
            astore 3
            goto 31
      StackMap locals:
      StackMap stack:
        30: aload 3
            aload 4
            if_acmpeq 31
            aload 3
            aload 4
            invokevirtual java.lang.Throwable.addSuppressed:(Ljava/lang/Throwable;)V
      StackMap locals:
      StackMap stack:
        31: aload 3
            athrow
        32: .line 183
      StackMap locals:
      StackMap stack:
            iload 2 /* dispatch */
            ifeq 36
        33: .line 186
            getstatic org.eclipse.jetty.util.thread.strategy.ExecuteProduceConsume.LOG:Lorg/eclipse/jetty/util/log/Logger;
            invokeinterface org.eclipse.jetty.util.log.Logger.isDebugEnabled:()Z
            ifeq 35
        34: .line 187
            getstatic org.eclipse.jetty.util.thread.strategy.ExecuteProduceConsume.LOG:Lorg/eclipse/jetty/util/log/Logger;
            ldc "{} dispatch"
            iconst_1
            anewarray java.lang.Object
            dup
            iconst_0
            aload 0 /* this */
            aastore
            invokeinterface org.eclipse.jetty.util.log.Logger.debug:(Ljava/lang/String;[Ljava/lang/Object;)V
        35: .line 188
      StackMap locals:
      StackMap stack:
            aload 0 /* this */
            getfield org.eclipse.jetty.util.thread.strategy.ExecuteProduceConsume._executor:Ljava/util/concurrent/Executor;
            aload 0 /* this */
            invokeinterface java.util.concurrent.Executor.execute:(Ljava/lang/Runnable;)V
        36: .line 192
      StackMap locals:
      StackMap stack:
            getstatic org.eclipse.jetty.util.thread.strategy.ExecuteProduceConsume.LOG:Lorg/eclipse/jetty/util/log/Logger;
            invokeinterface org.eclipse.jetty.util.log.Logger.isDebugEnabled:()Z
            ifeq 38
        37: .line 193
            getstatic org.eclipse.jetty.util.thread.strategy.ExecuteProduceConsume.LOG:Lorg/eclipse/jetty/util/log/Logger;
            ldc "{} run {}"
            iconst_2
            anewarray java.lang.Object
            dup
            iconst_0
            aload 0 /* this */
            aastore
            dup
            iconst_1
            aload 1 /* task */
            aastore
            invokeinterface org.eclipse.jetty.util.log.Logger.debug:(Ljava/lang/String;[Ljava/lang/Object;)V
        38: .line 194
      StackMap locals:
      StackMap stack:
            aload 1 /* task */
            ifnull 40
        39: .line 195
            aload 1 /* task */
            invokeinterface java.lang.Runnable.run:()V
        40: .line 196
      StackMap locals:
      StackMap stack:
            getstatic org.eclipse.jetty.util.thread.strategy.ExecuteProduceConsume.LOG:Lorg/eclipse/jetty/util/log/Logger;
            invokeinterface org.eclipse.jetty.util.log.Logger.isDebugEnabled:()Z
            ifeq 42
        41: .line 197
            getstatic org.eclipse.jetty.util.thread.strategy.ExecuteProduceConsume.LOG:Lorg/eclipse/jetty/util/log/Logger;
            ldc "{} ran {}"
            iconst_2
            anewarray java.lang.Object
            dup
            iconst_0
            aload 0 /* this */
            aastore
            dup
            iconst_1
            aload 1 /* task */
            aastore
            invokeinterface org.eclipse.jetty.util.log.Logger.debug:(Ljava/lang/String;[Ljava/lang/Object;)V
        42: .line 200
      StackMap locals:
      StackMap stack:
            aconst_null
            astore 3
            aconst_null
            astore 4
        43: aload 0 /* this */
            getfield org.eclipse.jetty.util.thread.strategy.ExecuteProduceConsume._locker:Lorg/eclipse/jetty/util/thread/Locker;
            invokevirtual org.eclipse.jetty.util.thread.Locker.lock:()Lorg/eclipse/jetty/util/thread/Locker$Lock;
            astore 5 /* locked */
        start local 5 // org.eclipse.jetty.util.thread.Locker$Lock locked
        44: .line 203
            aload 0 /* this */
            getfield org.eclipse.jetty.util.thread.strategy.ExecuteProduceConsume._producing:Z
            ifne 45
            aload 0 /* this */
            getfield org.eclipse.jetty.util.thread.strategy.ExecuteProduceConsume._idle:Z
            ifeq 47
        45: .line 206
      StackMap locals: java.lang.Throwable java.lang.Throwable org.eclipse.jetty.util.thread.Locker$Lock
      StackMap stack:
            aload 5 /* locked */
            ifnull 54
            aload 5 /* locked */
            invokevirtual org.eclipse.jetty.util.thread.Locker$Lock.close:()V
        46: .line 204
            goto 54
        47: .line 205
      StackMap locals:
      StackMap stack:
            aload 0 /* this */
            iconst_1
            putfield org.eclipse.jetty.util.thread.strategy.ExecuteProduceConsume._producing:Z
        48: .line 206
            aload 5 /* locked */
            ifnull 2
            aload 5 /* locked */
            invokevirtual org.eclipse.jetty.util.thread.Locker$Lock.close:()V
            goto 2
      StackMap locals:
      StackMap stack: java.lang.Throwable
        49: astore 3
            aload 5 /* locked */
            ifnull 50
            aload 5 /* locked */
            invokevirtual org.eclipse.jetty.util.thread.Locker$Lock.close:()V
        end local 5 // org.eclipse.jetty.util.thread.Locker$Lock locked
      StackMap locals:
      StackMap stack:
        50: aload 3
            athrow
      StackMap locals:
      StackMap stack: java.lang.Throwable
        51: astore 4
            aload 3
            ifnonnull 52
            aload 4
            astore 3
            goto 53
      StackMap locals:
      StackMap stack:
        52: aload 3
            aload 4
            if_acmpeq 53
            aload 3
            aload 4
            invokevirtual java.lang.Throwable.addSuppressed:(Ljava/lang/Throwable;)V
      StackMap locals:
      StackMap stack:
        53: aload 3
            athrow
        end local 2 // boolean dispatch
        end local 1 // java.lang.Runnable task
        54: .line 209
      StackMap locals: org.eclipse.jetty.util.thread.strategy.ExecuteProduceConsume
      StackMap stack:
            getstatic org.eclipse.jetty.util.thread.strategy.ExecuteProduceConsume.LOG:Lorg/eclipse/jetty/util/log/Logger;
            invokeinterface org.eclipse.jetty.util.log.Logger.isDebugEnabled:()Z
            ifeq 56
        55: .line 210
            getstatic org.eclipse.jetty.util.thread.strategy.ExecuteProduceConsume.LOG:Lorg/eclipse/jetty/util/log/Logger;
            ldc "{} produce exit"
            iconst_1
            anewarray java.lang.Object
            dup
            iconst_0
            aload 0 /* this */
            aastore
            invokeinterface org.eclipse.jetty.util.log.Logger.debug:(Ljava/lang/String;[Ljava/lang/Object;)V
        56: .line 211
      StackMap locals:
      StackMap stack:
            return
        end local 0 // org.eclipse.jetty.util.thread.strategy.ExecuteProduceConsume this
      LocalVariableTable:
        Start  End  Slot      Name  Signature
            0   57     0      this  Lorg/eclipse/jetty/util/thread/strategy/ExecuteProduceConsume;
            5   54     1      task  Ljava/lang/Runnable;
            8   54     2  dispatch  Z
           10   28     5    locked  Lorg/eclipse/jetty/util/thread/Locker$Lock;
           44   50     5    locked  Lorg/eclipse/jetty/util/thread/Locker$Lock;
      Exception table:
        from    to  target  type
          10    16      27  any
          18    19      27  any
          21    26      27  any
           9    17      29  any
          18    20      29  any
          21    29      29  any
          44    45      49  any
          47    48      49  any
          43    46      51  any
          47    51      51  any

  public java.lang.Boolean isIdle();
    descriptor: ()Ljava/lang/Boolean;
    flags: (0x0001) ACC_PUBLIC
    Code:
      stack=2, locals=4, args_size=1
        start local 0 // org.eclipse.jetty.util.thread.strategy.ExecuteProduceConsume this
         0: .line 215
            aconst_null
            astore 1
            aconst_null
            astore 2
         1: aload 0 /* this */
            getfield org.eclipse.jetty.util.thread.strategy.ExecuteProduceConsume._locker:Lorg/eclipse/jetty/util/thread/Locker;
            invokevirtual org.eclipse.jetty.util.thread.Locker.lock:()Lorg/eclipse/jetty/util/thread/Locker$Lock;
            astore 3 /* locked */
        start local 3 // org.eclipse.jetty.util.thread.Locker$Lock locked
         2: .line 217
            aload 0 /* this */
            getfield org.eclipse.jetty.util.thread.strategy.ExecuteProduceConsume._idle:Z
            invokestatic java.lang.Boolean.valueOf:(Z)Ljava/lang/Boolean;
         3: .line 218
            aload 3 /* locked */
            ifnull 4
            aload 3 /* locked */
            invokevirtual org.eclipse.jetty.util.thread.Locker$Lock.close:()V
         4: .line 217
      StackMap locals: org.eclipse.jetty.util.thread.strategy.ExecuteProduceConsume java.lang.Throwable java.lang.Throwable org.eclipse.jetty.util.thread.Locker$Lock
      StackMap stack: java.lang.Boolean
            areturn
      StackMap locals:
      StackMap stack: java.lang.Throwable
         5: astore 1
         6: .line 218
            aload 3 /* locked */
            ifnull 7
            aload 3 /* locked */
            invokevirtual org.eclipse.jetty.util.thread.Locker$Lock.close:()V
        end local 3 // org.eclipse.jetty.util.thread.Locker$Lock locked
      StackMap locals:
      StackMap stack:
         7: aload 1
            athrow
      StackMap locals:
      StackMap stack: java.lang.Throwable
         8: astore 2
            aload 1
            ifnonnull 9
            aload 2
            astore 1
            goto 10
      StackMap locals:
      StackMap stack:
         9: aload 1
            aload 2
            if_acmpeq 10
            aload 1
            aload 2
            invokevirtual java.lang.Throwable.addSuppressed:(Ljava/lang/Throwable;)V
      StackMap locals:
      StackMap stack:
        10: aload 1
            athrow
        end local 0 // org.eclipse.jetty.util.thread.strategy.ExecuteProduceConsume this
      LocalVariableTable:
        Start  End  Slot    Name  Signature
            0   11     0    this  Lorg/eclipse/jetty/util/thread/strategy/ExecuteProduceConsume;
            2    7     3  locked  Lorg/eclipse/jetty/util/thread/Locker$Lock;
      Exception table:
        from    to  target  type
           2     3       5  any
           1     4       8  any
           5     8       8  any

  public java.lang.String toString();
    descriptor: ()Ljava/lang/String;
    flags: (0x0001) ACC_PUBLIC
    Code:
      stack=2, locals=5, args_size=1
        start local 0 // org.eclipse.jetty.util.thread.strategy.ExecuteProduceConsume this
         0: .line 224
            new java.lang.StringBuilder
            dup
            invokespecial java.lang.StringBuilder.<init>:()V
            astore 1 /* builder */
        start local 1 // java.lang.StringBuilder builder
         1: .line 225
            aload 1 /* builder */
            ldc "EPC "
            invokevirtual java.lang.StringBuilder.append:(Ljava/lang/String;)Ljava/lang/StringBuilder;
            pop
         2: .line 226
            aconst_null
            astore 2
            aconst_null
            astore 3
         3: aload 0 /* this */
            getfield org.eclipse.jetty.util.thread.strategy.ExecuteProduceConsume._locker:Lorg/eclipse/jetty/util/thread/Locker;
            invokevirtual org.eclipse.jetty.util.thread.Locker.lock:()Lorg/eclipse/jetty/util/thread/Locker$Lock;
            astore 4 /* locked */
        start local 4 // org.eclipse.jetty.util.thread.Locker$Lock locked
         4: .line 228
            aload 1 /* builder */
            aload 0 /* this */
            getfield org.eclipse.jetty.util.thread.strategy.ExecuteProduceConsume._idle:Z
            ifeq 5
            ldc "Idle/"
            goto 6
      StackMap locals: org.eclipse.jetty.util.thread.strategy.ExecuteProduceConsume java.lang.StringBuilder java.lang.Throwable java.lang.Throwable org.eclipse.jetty.util.thread.Locker$Lock
      StackMap stack: java.lang.StringBuilder
         5: ldc ""
      StackMap locals: org.eclipse.jetty.util.thread.strategy.ExecuteProduceConsume java.lang.StringBuilder java.lang.Throwable java.lang.Throwable org.eclipse.jetty.util.thread.Locker$Lock
      StackMap stack: java.lang.StringBuilder java.lang.String
         6: invokevirtual java.lang.StringBuilder.append:(Ljava/lang/String;)Ljava/lang/StringBuilder;
            pop
         7: .line 229
            aload 1 /* builder */
            aload 0 /* this */
            getfield org.eclipse.jetty.util.thread.strategy.ExecuteProduceConsume._producing:Z
            ifeq 8
            ldc "Prod/"
            goto 9
      StackMap locals:
      StackMap stack: java.lang.StringBuilder
         8: ldc ""
      StackMap locals: org.eclipse.jetty.util.thread.strategy.ExecuteProduceConsume java.lang.StringBuilder java.lang.Throwable java.lang.Throwable org.eclipse.jetty.util.thread.Locker$Lock
      StackMap stack: java.lang.StringBuilder java.lang.String
         9: invokevirtual java.lang.StringBuilder.append:(Ljava/lang/String;)Ljava/lang/StringBuilder;
            pop
        10: .line 230
            aload 1 /* builder */
            aload 0 /* this */
            getfield org.eclipse.jetty.util.thread.strategy.ExecuteProduceConsume._pending:Z
            ifeq 11
            ldc "Pend/"
            goto 12
      StackMap locals:
      StackMap stack: java.lang.StringBuilder
        11: ldc ""
      StackMap locals: org.eclipse.jetty.util.thread.strategy.ExecuteProduceConsume java.lang.StringBuilder java.lang.Throwable java.lang.Throwable org.eclipse.jetty.util.thread.Locker$Lock
      StackMap stack: java.lang.StringBuilder java.lang.String
        12: invokevirtual java.lang.StringBuilder.append:(Ljava/lang/String;)Ljava/lang/StringBuilder;
            pop
        13: .line 231
            aload 1 /* builder */
            aload 0 /* this */
            getfield org.eclipse.jetty.util.thread.strategy.ExecuteProduceConsume._execute:Z
            ifeq 14
            ldc "Exec/"
            goto 15
      StackMap locals:
      StackMap stack: java.lang.StringBuilder
        14: ldc ""
      StackMap locals: org.eclipse.jetty.util.thread.strategy.ExecuteProduceConsume java.lang.StringBuilder java.lang.Throwable java.lang.Throwable org.eclipse.jetty.util.thread.Locker$Lock
      StackMap stack: java.lang.StringBuilder java.lang.String
        15: invokevirtual java.lang.StringBuilder.append:(Ljava/lang/String;)Ljava/lang/StringBuilder;
            pop
        16: .line 232
            aload 4 /* locked */
            ifnull 22
            aload 4 /* locked */
            invokevirtual org.eclipse.jetty.util.thread.Locker$Lock.close:()V
            goto 22
      StackMap locals:
      StackMap stack: java.lang.Throwable
        17: astore 2
            aload 4 /* locked */
            ifnull 18
            aload 4 /* locked */
            invokevirtual org.eclipse.jetty.util.thread.Locker$Lock.close:()V
        end local 4 // org.eclipse.jetty.util.thread.Locker$Lock locked
      StackMap locals:
      StackMap stack:
        18: aload 2
            athrow
      StackMap locals:
      StackMap stack: java.lang.Throwable
        19: astore 3
            aload 2
            ifnonnull 20
            aload 3
            astore 2
            goto 21
      StackMap locals:
      StackMap stack:
        20: aload 2
            aload 3
            if_acmpeq 21
            aload 2
            aload 3
            invokevirtual java.lang.Throwable.addSuppressed:(Ljava/lang/Throwable;)V
      StackMap locals:
      StackMap stack:
        21: aload 2
            athrow
        22: .line 233
      StackMap locals:
      StackMap stack:
            aload 1 /* builder */
            aload 0 /* this */
            getfield org.eclipse.jetty.util.thread.strategy.ExecuteProduceConsume._producer:Lorg/eclipse/jetty/util/thread/ExecutionStrategy$Producer;
            invokevirtual java.lang.StringBuilder.append:(Ljava/lang/Object;)Ljava/lang/StringBuilder;
            pop
        23: .line 234
            aload 1 /* builder */
            invokevirtual java.lang.StringBuilder.toString:()Ljava/lang/String;
            areturn
        end local 1 // java.lang.StringBuilder builder
        end local 0 // org.eclipse.jetty.util.thread.strategy.ExecuteProduceConsume this
      LocalVariableTable:
        Start  End  Slot     Name  Signature
            0   24     0     this  Lorg/eclipse/jetty/util/thread/strategy/ExecuteProduceConsume;
            1   24     1  builder  Ljava/lang/StringBuilder;
            4   18     4   locked  Lorg/eclipse/jetty/util/thread/Locker$Lock;
      Exception table:
        from    to  target  type
           4    16      17  any
           3    19      19  any
}
SourceFile: "ExecuteProduceConsume.java"
NestMembers:
  org.eclipse.jetty.util.thread.strategy.ExecuteProduceConsume$RunProduce
InnerClasses:
  public abstract Producer = org.eclipse.jetty.util.thread.ExecutionStrategy$Producer of org.eclipse.jetty.util.thread.ExecutionStrategy
  public final InvocationType = org.eclipse.jetty.util.thread.Invocable$InvocationType of org.eclipse.jetty.util.thread.Invocable
  public Lock = org.eclipse.jetty.util.thread.Locker$Lock of org.eclipse.jetty.util.thread.Locker
  private RunProduce = org.eclipse.jetty.util.thread.strategy.ExecuteProduceConsume$RunProduce of org.eclipse.jetty.util.thread.strategy.ExecuteProduceConsume
/

org.eclipse.jetty/ jetty-util/ 10.0.0-alpha0/ org/eclipse/jetty/util/thread/strategy/ExecuteProduceConsume.class
