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

ProduceExecuteConsume
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.ProduceExecuteConsume implements org.eclipse.jetty.util.thread.ExecutionStrategy
  minor version: 0
  major version: 59
  flags: flags: (0x0021) ACC_PUBLIC, ACC_SUPER
  this_class: org.eclipse.jetty.util.thread.strategy.ProduceExecuteConsume
  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 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 org.eclipse.jetty.util.thread.strategy.ProduceExecuteConsume$State _state;
    descriptor: Lorg/eclipse/jetty/util/thread/strategy/ProduceExecuteConsume$State;
    flags: (0x0002) ACC_PRIVATE

  private static volatile int[] $SWITCH_TABLE$org$eclipse$jetty$util$thread$strategy$ProduceExecuteConsume$State;
    descriptor: [I
    flags: (0x104a) ACC_PRIVATE, ACC_STATIC, ACC_VOLATILE, ACC_SYNTHETIC

  static void <clinit>();
    descriptor: ()V
    flags: (0x0008) ACC_STATIC
    Code:
      stack=1, locals=0, args_size=0
         0: .line 37
            ldc Lorg/eclipse/jetty/util/thread/strategy/ProduceExecuteConsume;
            invokestatic org.eclipse.jetty.util.log.Log.getLogger:(Ljava/lang/Class;)Lorg/eclipse/jetty/util/log/Logger;
            putstatic org.eclipse.jetty.util.thread.strategy.ProduceExecuteConsume.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=3, locals=3, args_size=3
        start local 0 // org.eclipse.jetty.util.thread.strategy.ProduceExecuteConsume this
        start local 1 // org.eclipse.jetty.util.thread.ExecutionStrategy$Producer producer
        start local 2 // java.util.concurrent.Executor executor
         0: .line 44
            aload 0 /* this */
            invokespecial java.lang.Object.<init>:()V
         1: .line 39
            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.ProduceExecuteConsume._locker:Lorg/eclipse/jetty/util/thread/Locker;
         2: .line 42
            aload 0 /* this */
            getstatic org.eclipse.jetty.util.thread.strategy.ProduceExecuteConsume$State.IDLE:Lorg/eclipse/jetty/util/thread/strategy/ProduceExecuteConsume$State;
            putfield org.eclipse.jetty.util.thread.strategy.ProduceExecuteConsume._state:Lorg/eclipse/jetty/util/thread/strategy/ProduceExecuteConsume$State;
         3: .line 46
            aload 0 /* this */
            aload 1 /* producer */
            putfield org.eclipse.jetty.util.thread.strategy.ProduceExecuteConsume._producer:Lorg/eclipse/jetty/util/thread/ExecutionStrategy$Producer;
         4: .line 47
            aload 0 /* this */
            aload 2 /* executor */
            putfield org.eclipse.jetty.util.thread.strategy.ProduceExecuteConsume._executor:Ljava/util/concurrent/Executor;
         5: .line 48
            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.ProduceExecuteConsume this
      LocalVariableTable:
        Start  End  Slot      Name  Signature
            0    6     0      this  Lorg/eclipse/jetty/util/thread/strategy/ProduceExecuteConsume;
            0    6     1  producer  Lorg/eclipse/jetty/util/thread/ExecutionStrategy$Producer;
            0    6     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.ProduceExecuteConsume this
         0: .line 53
            aconst_null
            astore 1
            aconst_null
            astore 2
         1: aload 0 /* this */
            getfield org.eclipse.jetty.util.thread.strategy.ProduceExecuteConsume._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 55
            invokestatic org.eclipse.jetty.util.thread.strategy.ProduceExecuteConsume.$SWITCH_TABLE$org$eclipse$jetty$util$thread$strategy$ProduceExecuteConsume$State:()[I
            aload 0 /* this */
            getfield org.eclipse.jetty.util.thread.strategy.ProduceExecuteConsume._state:Lorg/eclipse/jetty/util/thread/strategy/ProduceExecuteConsume$State;
            invokevirtual org.eclipse.jetty.util.thread.strategy.ProduceExecuteConsume$State.ordinal:()I
            iaload
            tableswitch { // 1 - 3
                    1: 3
                    2: 5
                    3: 5
              default: 8
          }
         3: .line 58
      StackMap locals: java.lang.Throwable java.lang.Throwable org.eclipse.jetty.util.thread.Locker$Lock
      StackMap stack:
            aload 0 /* this */
            getstatic org.eclipse.jetty.util.thread.strategy.ProduceExecuteConsume$State.PRODUCE:Lorg/eclipse/jetty/util/thread/strategy/ProduceExecuteConsume$State;
            putfield org.eclipse.jetty.util.thread.strategy.ProduceExecuteConsume._state:Lorg/eclipse/jetty/util/thread/strategy/ProduceExecuteConsume$State;
         4: .line 59
            goto 9
         5: .line 63
      StackMap locals:
      StackMap stack:
            aload 0 /* this */
            getstatic org.eclipse.jetty.util.thread.strategy.ProduceExecuteConsume$State.EXECUTE:Lorg/eclipse/jetty/util/thread/strategy/ProduceExecuteConsume$State;
            putfield org.eclipse.jetty.util.thread.strategy.ProduceExecuteConsume._state:Lorg/eclipse/jetty/util/thread/strategy/ProduceExecuteConsume$State;
         6: .line 68
            aload 3 /* locked */
            ifnull 7
            aload 3 /* locked */
            invokevirtual org.eclipse.jetty.util.thread.Locker$Lock.close:()V
         7: .line 64
      StackMap locals:
      StackMap stack:
            return
         8: .line 66
      StackMap locals:
      StackMap stack:
            new java.lang.IllegalStateException
            dup
            aload 0 /* this */
            getfield org.eclipse.jetty.util.thread.strategy.ProduceExecuteConsume._state:Lorg/eclipse/jetty/util/thread/strategy/ProduceExecuteConsume$State;
            invokevirtual org.eclipse.jetty.util.thread.strategy.ProduceExecuteConsume$State.toString:()Ljava/lang/String;
            invokespecial java.lang.IllegalStateException.<init>:(Ljava/lang/String;)V
            athrow
         9: .line 68
      StackMap locals:
      StackMap stack:
            aload 3 /* locked */
            ifnull 15
            aload 3 /* locked */
            invokevirtual org.eclipse.jetty.util.thread.Locker$Lock.close:()V
            goto 15
      StackMap locals:
      StackMap stack: java.lang.Throwable
        10: astore 1
            aload 3 /* locked */
            ifnull 11
            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:
        11: aload 1
            athrow
      StackMap locals:
      StackMap stack: java.lang.Throwable
        12: astore 2
            aload 1
            ifnonnull 13
            aload 2
            astore 1
            goto 14
      StackMap locals:
      StackMap stack:
        13: aload 1
            aload 2
            if_acmpeq 14
            aload 1
            aload 2
            invokevirtual java.lang.Throwable.addSuppressed:(Ljava/lang/Throwable;)V
      StackMap locals:
      StackMap stack:
        14: aload 1
            athrow
        15: .line 74
      StackMap locals:
      StackMap stack:
            aload 0 /* this */
            getfield org.eclipse.jetty.util.thread.strategy.ProduceExecuteConsume._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
        16: .line 75
            getstatic org.eclipse.jetty.util.thread.strategy.ProduceExecuteConsume.LOG:Lorg/eclipse/jetty/util/log/Logger;
            invokeinterface org.eclipse.jetty.util.log.Logger.isDebugEnabled:()Z
            ifeq 18
        17: .line 76
            getstatic org.eclipse.jetty.util.thread.strategy.ProduceExecuteConsume.LOG:Lorg/eclipse/jetty/util/log/Logger;
            ldc "{} produced {}"
            iconst_2
            anewarray java.lang.Object
            dup
            iconst_0
            aload 0 /* this */
            getfield org.eclipse.jetty.util.thread.strategy.ProduceExecuteConsume._producer:Lorg/eclipse/jetty/util/thread/ExecutionStrategy$Producer;
            aastore
            dup
            iconst_1
            aload 1 /* task */
            aastore
            invokeinterface org.eclipse.jetty.util.log.Logger.debug:(Ljava/lang/String;[Ljava/lang/Object;)V
        18: .line 78
      StackMap locals: java.lang.Runnable
      StackMap stack:
            aload 1 /* task */
            ifnonnull 36
        19: .line 80
            aconst_null
            astore 2
            aconst_null
            astore 3
        20: aload 0 /* this */
            getfield org.eclipse.jetty.util.thread.strategy.ProduceExecuteConsume._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
        21: .line 82
            invokestatic org.eclipse.jetty.util.thread.strategy.ProduceExecuteConsume.$SWITCH_TABLE$org$eclipse$jetty$util$thread$strategy$ProduceExecuteConsume$State:()[I
            aload 0 /* this */
            getfield org.eclipse.jetty.util.thread.strategy.ProduceExecuteConsume._state:Lorg/eclipse/jetty/util/thread/strategy/ProduceExecuteConsume$State;
            invokevirtual org.eclipse.jetty.util.thread.strategy.ProduceExecuteConsume$State.ordinal:()I
            iaload
            tableswitch { // 1 - 3
                    1: 22
                    2: 23
                    3: 26
              default: 29
          }
        22: .line 85
      StackMap locals: java.lang.Throwable java.lang.Throwable org.eclipse.jetty.util.thread.Locker$Lock
      StackMap stack:
            new java.lang.IllegalStateException
            dup
            invokespecial java.lang.IllegalStateException.<init>:()V
            athrow
        23: .line 87
      StackMap locals:
      StackMap stack:
            aload 0 /* this */
            getstatic org.eclipse.jetty.util.thread.strategy.ProduceExecuteConsume$State.IDLE:Lorg/eclipse/jetty/util/thread/strategy/ProduceExecuteConsume$State;
            putfield org.eclipse.jetty.util.thread.strategy.ProduceExecuteConsume._state:Lorg/eclipse/jetty/util/thread/strategy/ProduceExecuteConsume$State;
        24: .line 95
            aload 4 /* locked */
            ifnull 25
            aload 4 /* locked */
            invokevirtual org.eclipse.jetty.util.thread.Locker$Lock.close:()V
        25: .line 88
      StackMap locals:
      StackMap stack:
            return
        26: .line 90
      StackMap locals:
      StackMap stack:
            aload 0 /* this */
            getstatic org.eclipse.jetty.util.thread.strategy.ProduceExecuteConsume$State.PRODUCE:Lorg/eclipse/jetty/util/thread/strategy/ProduceExecuteConsume$State;
            putfield org.eclipse.jetty.util.thread.strategy.ProduceExecuteConsume._state:Lorg/eclipse/jetty/util/thread/strategy/ProduceExecuteConsume$State;
        27: .line 95
            aload 4 /* locked */
            ifnull 15
            aload 4 /* locked */
            invokevirtual org.eclipse.jetty.util.thread.Locker$Lock.close:()V
        28: .line 91
            goto 15
        29: .line 93
      StackMap locals:
      StackMap stack:
            new java.lang.IllegalStateException
            dup
            aload 0 /* this */
            getfield org.eclipse.jetty.util.thread.strategy.ProduceExecuteConsume._state:Lorg/eclipse/jetty/util/thread/strategy/ProduceExecuteConsume$State;
            invokevirtual org.eclipse.jetty.util.thread.strategy.ProduceExecuteConsume$State.toString:()Ljava/lang/String;
            invokespecial java.lang.IllegalStateException.<init>:(Ljava/lang/String;)V
            athrow
      StackMap locals:
      StackMap stack: java.lang.Throwable
        30: astore 2
        31: .line 95
            aload 4 /* locked */
            ifnull 32
            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:
        32: aload 2
            athrow
      StackMap locals:
      StackMap stack: java.lang.Throwable
        33: astore 3
            aload 2
            ifnonnull 34
            aload 3
            astore 2
            goto 35
      StackMap locals:
      StackMap stack:
        34: aload 2
            aload 3
            if_acmpeq 35
            aload 2
            aload 3
            invokevirtual java.lang.Throwable.addSuppressed:(Ljava/lang/Throwable;)V
      StackMap locals:
      StackMap stack:
        35: aload 2
            athrow
        36: .line 99
      StackMap locals:
      StackMap stack:
            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_acmpne 38
        37: .line 100
            aload 1 /* task */
            invokeinterface java.lang.Runnable.run:()V
            goto 15
        38: .line 102
      StackMap locals:
      StackMap stack:
            aload 0 /* this */
            getfield org.eclipse.jetty.util.thread.strategy.ProduceExecuteConsume._executor:Ljava/util/concurrent/Executor;
            aload 1 /* task */
            invokeinterface java.util.concurrent.Executor.execute:(Ljava/lang/Runnable;)V
        end local 1 // java.lang.Runnable task
        39: .line 71
            goto 15
        end local 0 // org.eclipse.jetty.util.thread.strategy.ProduceExecuteConsume this
      LocalVariableTable:
        Start  End  Slot    Name  Signature
            0   40     0    this  Lorg/eclipse/jetty/util/thread/strategy/ProduceExecuteConsume;
            2   11     3  locked  Lorg/eclipse/jetty/util/thread/Locker$Lock;
           16   39     1    task  Ljava/lang/Runnable;
           21   32     4  locked  Lorg/eclipse/jetty/util/thread/Locker$Lock;
      Exception table:
        from    to  target  type
           2     6      10  any
           8     9      10  any
           1     7      12  any
           8    12      12  any
          21    24      30  any
          26    27      30  any
          29    30      30  any
          20    25      33  any
          26    28      33  any
          29    33      33  any

  public void dispatch();
    descriptor: ()V
    flags: (0x0001) ACC_PUBLIC
    Code:
      stack=2, locals=1, args_size=1
        start local 0 // org.eclipse.jetty.util.thread.strategy.ProduceExecuteConsume this
         0: .line 109
            aload 0 /* this */
            getfield org.eclipse.jetty.util.thread.strategy.ProduceExecuteConsume._executor:Ljava/util/concurrent/Executor;
            aload 0 /* this */
            invokedynamic run(Lorg/eclipse/jetty/util/thread/strategy/ProduceExecuteConsume;)Ljava/lang/Runnable;
              Bootstrap: invokestatic java.lang.invoke.LambdaMetafactory.metafactory:(Ljava/lang/invoke/MethodHandles$Lookup;Ljava/lang/String;Ljava/lang/invoke/MethodType;Ljava/lang/invoke/MethodType;Ljava/lang/invoke/MethodHandle;Ljava/lang/invoke/MethodType;)Ljava/lang/invoke/CallSite;
                Method arguments:
                  ()V
                  org/eclipse/jetty/util/thread/strategy/ProduceExecuteConsume.lambda$0()V (7)
                  ()V
            invokeinterface java.util.concurrent.Executor.execute:(Ljava/lang/Runnable;)V
         1: .line 110
            return
        end local 0 // org.eclipse.jetty.util.thread.strategy.ProduceExecuteConsume this
      LocalVariableTable:
        Start  End  Slot  Name  Signature
            0    2     0  this  Lorg/eclipse/jetty/util/thread/strategy/ProduceExecuteConsume;

  static int[] $SWITCH_TABLE$org$eclipse$jetty$util$thread$strategy$ProduceExecuteConsume$State();
    descriptor: ()[I
    flags: (0x1008) ACC_STATIC, ACC_SYNTHETIC
    Code:
      stack=3, locals=1, args_size=0
         0: .line 35
            getstatic org.eclipse.jetty.util.thread.strategy.ProduceExecuteConsume.$SWITCH_TABLE$org$eclipse$jetty$util$thread$strategy$ProduceExecuteConsume$State:[I
            dup
            ifnull 1
            areturn
      StackMap locals:
      StackMap stack: int[]
         1: pop
            invokestatic org.eclipse.jetty.util.thread.strategy.ProduceExecuteConsume$State.values:()[Lorg/eclipse/jetty/util/thread/strategy/ProduceExecuteConsume$State;
            arraylength
            newarray 10
            astore 0
         2: aload 0
            getstatic org.eclipse.jetty.util.thread.strategy.ProduceExecuteConsume$State.EXECUTE:Lorg/eclipse/jetty/util/thread/strategy/ProduceExecuteConsume$State;
            invokevirtual org.eclipse.jetty.util.thread.strategy.ProduceExecuteConsume$State.ordinal:()I
            iconst_3
            iastore
         3: goto 5
      StackMap locals: int[]
      StackMap stack: java.lang.NoSuchFieldError
         4: pop
      StackMap locals:
      StackMap stack:
         5: aload 0
            getstatic org.eclipse.jetty.util.thread.strategy.ProduceExecuteConsume$State.IDLE:Lorg/eclipse/jetty/util/thread/strategy/ProduceExecuteConsume$State;
            invokevirtual org.eclipse.jetty.util.thread.strategy.ProduceExecuteConsume$State.ordinal:()I
            iconst_1
            iastore
         6: goto 8
      StackMap locals:
      StackMap stack: java.lang.NoSuchFieldError
         7: pop
      StackMap locals:
      StackMap stack:
         8: aload 0
            getstatic org.eclipse.jetty.util.thread.strategy.ProduceExecuteConsume$State.PRODUCE:Lorg/eclipse/jetty/util/thread/strategy/ProduceExecuteConsume$State;
            invokevirtual org.eclipse.jetty.util.thread.strategy.ProduceExecuteConsume$State.ordinal:()I
            iconst_2
            iastore
         9: goto 11
      StackMap locals:
      StackMap stack: java.lang.NoSuchFieldError
        10: pop
      StackMap locals:
      StackMap stack:
        11: aload 0
            dup
            putstatic org.eclipse.jetty.util.thread.strategy.ProduceExecuteConsume.$SWITCH_TABLE$org$eclipse$jetty$util$thread$strategy$ProduceExecuteConsume$State:[I
            areturn
      LocalVariableTable:
        Start  End  Slot  Name  Signature
      Exception table:
        from    to  target  type
           2     3       4  Class java.lang.NoSuchFieldError
           5     6       7  Class java.lang.NoSuchFieldError
           8     9      10  Class java.lang.NoSuchFieldError

  private void lambda$0();
    descriptor: ()V
    flags: (0x1002) ACC_PRIVATE, ACC_SYNTHETIC
    Code:
      stack=1, locals=1, args_size=1
        start local 0 // org.eclipse.jetty.util.thread.strategy.ProduceExecuteConsume this
         0: .line 109
            aload 0 /* this */
            invokevirtual org.eclipse.jetty.util.thread.strategy.ProduceExecuteConsume.produce:()V
            return
        end local 0 // org.eclipse.jetty.util.thread.strategy.ProduceExecuteConsume this
      LocalVariableTable:
        Start  End  Slot  Name  Signature
            0    1     0  this  Lorg/eclipse/jetty/util/thread/strategy/ProduceExecuteConsume;
}
SourceFile: "ProduceExecuteConsume.java"
NestMembers:
  org.eclipse.jetty.util.thread.strategy.ProduceExecuteConsume$State
InnerClasses:
  public final Lookup = java.lang.invoke.MethodHandles$Lookup of java.lang.invoke.MethodHandles
  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 final State = org.eclipse.jetty.util.thread.strategy.ProduceExecuteConsume$State of org.eclipse.jetty.util.thread.strategy.ProduceExecuteConsume
/

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