org.eclipse.jetty/jetty-util/11.0.0 : org/eclipse/jetty/util/thread/SerializedExecutor.class

SerializedExecutor
https://eclipse.org/jetty/jetty-util: 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)
Ludovic Orban (Webtide, LLC)
public class org.eclipse.jetty.util.thread.SerializedExecutor implements java.util.concurrent.Executor
  minor version: 0
  major version: 59
  flags: flags: (0x0021) ACC_PUBLIC, ACC_SUPER
  this_class: org.eclipse.jetty.util.thread.SerializedExecutor
  super_class: java.lang.Object
{
  private final java.util.concurrent.atomic.AtomicReference<org.eclipse.jetty.util.thread.SerializedExecutor$Link> _tail;
    descriptor: Ljava/util/concurrent/atomic/AtomicReference;
    flags: (0x0012) ACC_PRIVATE, ACC_FINAL
    Signature: Ljava/util/concurrent/atomic/AtomicReference<Lorg/eclipse/jetty/util/thread/SerializedExecutor$Link;>;

  public void <init>();
    descriptor: ()V
    flags: (0x0001) ACC_PUBLIC
    Code:
      stack=3, locals=1, args_size=1
        start local 0 // org.eclipse.jetty.util.thread.SerializedExecutor this
         0: .line 39
            aload 0 /* this */
            invokespecial java.lang.Object.<init>:()V
         1: .line 41
            aload 0 /* this */
            new java.util.concurrent.atomic.AtomicReference
            dup
            invokespecial java.util.concurrent.atomic.AtomicReference.<init>:()V
            putfield org.eclipse.jetty.util.thread.SerializedExecutor._tail:Ljava/util/concurrent/atomic/AtomicReference;
         2: .line 39
            return
        end local 0 // org.eclipse.jetty.util.thread.SerializedExecutor this
      LocalVariableTable:
        Start  End  Slot  Name  Signature
            0    3     0  this  Lorg/eclipse/jetty/util/thread/SerializedExecutor;

  public void execute(java.lang.Runnable);
    descriptor: (Ljava/lang/Runnable;)V
    flags: (0x0001) ACC_PUBLIC
    Code:
      stack=4, locals=4, args_size=2
        start local 0 // org.eclipse.jetty.util.thread.SerializedExecutor this
        start local 1 // java.lang.Runnable task
         0: .line 46
            new org.eclipse.jetty.util.thread.SerializedExecutor$Link
            dup
            aload 0 /* this */
            aload 1 /* task */
            invokespecial org.eclipse.jetty.util.thread.SerializedExecutor$Link.<init>:(Lorg/eclipse/jetty/util/thread/SerializedExecutor;Ljava/lang/Runnable;)V
            astore 2 /* link */
        start local 2 // org.eclipse.jetty.util.thread.SerializedExecutor$Link link
         1: .line 47
            aload 0 /* this */
            getfield org.eclipse.jetty.util.thread.SerializedExecutor._tail:Ljava/util/concurrent/atomic/AtomicReference;
            aload 2 /* link */
            invokevirtual java.util.concurrent.atomic.AtomicReference.getAndSet:(Ljava/lang/Object;)Ljava/lang/Object;
            checkcast org.eclipse.jetty.util.thread.SerializedExecutor$Link
            astore 3 /* lastButOne */
        start local 3 // org.eclipse.jetty.util.thread.SerializedExecutor$Link lastButOne
         2: .line 48
            aload 3 /* lastButOne */
            ifnonnull 4
         3: .line 49
            aload 0 /* this */
            aload 2 /* link */
            invokevirtual org.eclipse.jetty.util.thread.SerializedExecutor.run:(Lorg/eclipse/jetty/util/thread/SerializedExecutor$Link;)V
            goto 5
         4: .line 51
      StackMap locals: org.eclipse.jetty.util.thread.SerializedExecutor$Link org.eclipse.jetty.util.thread.SerializedExecutor$Link
      StackMap stack:
            aload 3 /* lastButOne */
            getfield org.eclipse.jetty.util.thread.SerializedExecutor$Link._next:Ljava/util/concurrent/atomic/AtomicReference;
            aload 2 /* link */
            invokevirtual java.util.concurrent.atomic.AtomicReference.lazySet:(Ljava/lang/Object;)V
         5: .line 52
      StackMap locals:
      StackMap stack:
            return
        end local 3 // org.eclipse.jetty.util.thread.SerializedExecutor$Link lastButOne
        end local 2 // org.eclipse.jetty.util.thread.SerializedExecutor$Link link
        end local 1 // java.lang.Runnable task
        end local 0 // org.eclipse.jetty.util.thread.SerializedExecutor this
      LocalVariableTable:
        Start  End  Slot        Name  Signature
            0    6     0        this  Lorg/eclipse/jetty/util/thread/SerializedExecutor;
            0    6     1        task  Ljava/lang/Runnable;
            1    6     2        link  Lorg/eclipse/jetty/util/thread/SerializedExecutor$Link;
            2    6     3  lastButOne  Lorg/eclipse/jetty/util/thread/SerializedExecutor$Link;
    MethodParameters:
      Name  Flags
      task  

  protected void onError(java.lang.Runnable, java.lang.Throwable);
    descriptor: (Ljava/lang/Runnable;Ljava/lang/Throwable;)V
    flags: (0x0004) ACC_PROTECTED
    Code:
      stack=3, locals=3, args_size=3
        start local 0 // org.eclipse.jetty.util.thread.SerializedExecutor this
        start local 1 // java.lang.Runnable task
        start local 2 // java.lang.Throwable t
         0: .line 56
            aload 1 /* task */
            instanceof org.eclipse.jetty.util.thread.SerializedExecutor$ErrorHandlingTask
            ifeq 2
         1: .line 57
            aload 1 /* task */
            checkcast org.eclipse.jetty.util.thread.SerializedExecutor$ErrorHandlingTask
            aload 2 /* t */
            invokeinterface org.eclipse.jetty.util.thread.SerializedExecutor$ErrorHandlingTask.accept:(Ljava/lang/Object;)V
         2: .line 58
      StackMap locals:
      StackMap stack:
            aload 1 /* task */
            invokevirtual java.lang.Object.getClass:()Ljava/lang/Class;
            invokestatic org.slf4j.LoggerFactory.getLogger:(Ljava/lang/Class;)Lorg/slf4j/Logger;
            ldc "Error"
            aload 2 /* t */
            invokeinterface org.slf4j.Logger.error:(Ljava/lang/String;Ljava/lang/Throwable;)V
         3: .line 59
            return
        end local 2 // java.lang.Throwable t
        end local 1 // java.lang.Runnable task
        end local 0 // org.eclipse.jetty.util.thread.SerializedExecutor this
      LocalVariableTable:
        Start  End  Slot  Name  Signature
            0    4     0  this  Lorg/eclipse/jetty/util/thread/SerializedExecutor;
            0    4     1  task  Ljava/lang/Runnable;
            0    4     2     t  Ljava/lang/Throwable;
    MethodParameters:
      Name  Flags
      task  
      t     

  private void run(org.eclipse.jetty.util.thread.SerializedExecutor$Link);
    descriptor: (Lorg/eclipse/jetty/util/thread/SerializedExecutor$Link;)V
    flags: (0x0002) ACC_PRIVATE
    Code:
      stack=3, locals=5, args_size=2
        start local 0 // org.eclipse.jetty.util.thread.SerializedExecutor this
        start local 1 // org.eclipse.jetty.util.thread.SerializedExecutor$Link link
         0: .line 63
            goto 32
         1: .line 67
      StackMap locals:
      StackMap stack:
            aload 1 /* link */
            getfield org.eclipse.jetty.util.thread.SerializedExecutor$Link._task:Ljava/lang/Runnable;
            invokeinterface java.lang.Runnable.run:()V
         2: .line 68
            goto 24
         3: .line 69
      StackMap locals:
      StackMap stack: java.lang.Throwable
            astore 2 /* t */
        start local 2 // java.lang.Throwable t
         4: .line 71
            aload 0 /* this */
            aload 1 /* link */
            getfield org.eclipse.jetty.util.thread.SerializedExecutor$Link._task:Ljava/lang/Runnable;
            aload 2 /* t */
            invokevirtual org.eclipse.jetty.util.thread.SerializedExecutor.onError:(Ljava/lang/Runnable;Ljava/lang/Throwable;)V
        end local 2 // java.lang.Throwable t
         5: .line 76
            aload 0 /* this */
            getfield org.eclipse.jetty.util.thread.SerializedExecutor._tail:Ljava/util/concurrent/atomic/AtomicReference;
            aload 1 /* link */
            aconst_null
            invokevirtual java.util.concurrent.atomic.AtomicReference.compareAndSet:(Ljava/lang/Object;Ljava/lang/Object;)Z
            ifeq 7
         6: .line 77
            aconst_null
            astore 1 /* link */
            goto 32
         7: .line 81
      StackMap locals:
      StackMap stack:
            aload 1 /* link */
            getfield org.eclipse.jetty.util.thread.SerializedExecutor$Link._next:Ljava/util/concurrent/atomic/AtomicReference;
            invokevirtual java.util.concurrent.atomic.AtomicReference.get:()Ljava/lang/Object;
            checkcast org.eclipse.jetty.util.thread.SerializedExecutor$Link
            astore 4 /* next */
        start local 4 // org.eclipse.jetty.util.thread.SerializedExecutor$Link next
         8: .line 82
            goto 11
         9: .line 84
      StackMap locals: org.eclipse.jetty.util.thread.SerializedExecutor org.eclipse.jetty.util.thread.SerializedExecutor$Link top top org.eclipse.jetty.util.thread.SerializedExecutor$Link
      StackMap stack:
            invokestatic java.lang.Thread.yield:()V
        10: .line 85
            aload 1 /* link */
            getfield org.eclipse.jetty.util.thread.SerializedExecutor$Link._next:Ljava/util/concurrent/atomic/AtomicReference;
            invokevirtual java.util.concurrent.atomic.AtomicReference.get:()Ljava/lang/Object;
            checkcast org.eclipse.jetty.util.thread.SerializedExecutor$Link
            astore 4 /* next */
        11: .line 82
      StackMap locals:
      StackMap stack:
            aload 4 /* next */
            ifnull 9
        12: .line 87
            aload 4 /* next */
            astore 1 /* link */
        end local 4 // org.eclipse.jetty.util.thread.SerializedExecutor$Link next
        13: goto 32
        14: .line 74
      StackMap locals: org.eclipse.jetty.util.thread.SerializedExecutor org.eclipse.jetty.util.thread.SerializedExecutor$Link
      StackMap stack: java.lang.Throwable
            astore 3
        15: .line 76
            aload 0 /* this */
            getfield org.eclipse.jetty.util.thread.SerializedExecutor._tail:Ljava/util/concurrent/atomic/AtomicReference;
            aload 1 /* link */
            aconst_null
            invokevirtual java.util.concurrent.atomic.AtomicReference.compareAndSet:(Ljava/lang/Object;Ljava/lang/Object;)Z
            ifeq 17
        16: .line 77
            aconst_null
            astore 1 /* link */
            goto 23
        17: .line 81
      StackMap locals: org.eclipse.jetty.util.thread.SerializedExecutor org.eclipse.jetty.util.thread.SerializedExecutor$Link top java.lang.Throwable
      StackMap stack:
            aload 1 /* link */
            getfield org.eclipse.jetty.util.thread.SerializedExecutor$Link._next:Ljava/util/concurrent/atomic/AtomicReference;
            invokevirtual java.util.concurrent.atomic.AtomicReference.get:()Ljava/lang/Object;
            checkcast org.eclipse.jetty.util.thread.SerializedExecutor$Link
            astore 4 /* next */
        start local 4 // org.eclipse.jetty.util.thread.SerializedExecutor$Link next
        18: .line 82
            goto 21
        19: .line 84
      StackMap locals: org.eclipse.jetty.util.thread.SerializedExecutor$Link
      StackMap stack:
            invokestatic java.lang.Thread.yield:()V
        20: .line 85
            aload 1 /* link */
            getfield org.eclipse.jetty.util.thread.SerializedExecutor$Link._next:Ljava/util/concurrent/atomic/AtomicReference;
            invokevirtual java.util.concurrent.atomic.AtomicReference.get:()Ljava/lang/Object;
            checkcast org.eclipse.jetty.util.thread.SerializedExecutor$Link
            astore 4 /* next */
        21: .line 82
      StackMap locals:
      StackMap stack:
            aload 4 /* next */
            ifnull 19
        22: .line 87
            aload 4 /* next */
            astore 1 /* link */
        end local 4 // org.eclipse.jetty.util.thread.SerializedExecutor$Link next
        23: .line 89
      StackMap locals:
      StackMap stack:
            aload 3
            athrow
        24: .line 76
      StackMap locals: org.eclipse.jetty.util.thread.SerializedExecutor org.eclipse.jetty.util.thread.SerializedExecutor$Link
      StackMap stack:
            aload 0 /* this */
            getfield org.eclipse.jetty.util.thread.SerializedExecutor._tail:Ljava/util/concurrent/atomic/AtomicReference;
            aload 1 /* link */
            aconst_null
            invokevirtual java.util.concurrent.atomic.AtomicReference.compareAndSet:(Ljava/lang/Object;Ljava/lang/Object;)Z
            ifeq 26
        25: .line 77
            aconst_null
            astore 1 /* link */
            goto 32
        26: .line 81
      StackMap locals:
      StackMap stack:
            aload 1 /* link */
            getfield org.eclipse.jetty.util.thread.SerializedExecutor$Link._next:Ljava/util/concurrent/atomic/AtomicReference;
            invokevirtual java.util.concurrent.atomic.AtomicReference.get:()Ljava/lang/Object;
            checkcast org.eclipse.jetty.util.thread.SerializedExecutor$Link
            astore 4 /* next */
        start local 4 // org.eclipse.jetty.util.thread.SerializedExecutor$Link next
        27: .line 82
            goto 30
        28: .line 84
      StackMap locals: org.eclipse.jetty.util.thread.SerializedExecutor org.eclipse.jetty.util.thread.SerializedExecutor$Link top top org.eclipse.jetty.util.thread.SerializedExecutor$Link
      StackMap stack:
            invokestatic java.lang.Thread.yield:()V
        29: .line 85
            aload 1 /* link */
            getfield org.eclipse.jetty.util.thread.SerializedExecutor$Link._next:Ljava/util/concurrent/atomic/AtomicReference;
            invokevirtual java.util.concurrent.atomic.AtomicReference.get:()Ljava/lang/Object;
            checkcast org.eclipse.jetty.util.thread.SerializedExecutor$Link
            astore 4 /* next */
        30: .line 82
      StackMap locals:
      StackMap stack:
            aload 4 /* next */
            ifnull 28
        31: .line 87
            aload 4 /* next */
            astore 1 /* link */
        end local 4 // org.eclipse.jetty.util.thread.SerializedExecutor$Link next
        32: .line 63
      StackMap locals: org.eclipse.jetty.util.thread.SerializedExecutor org.eclipse.jetty.util.thread.SerializedExecutor$Link
      StackMap stack:
            aload 1 /* link */
            ifnonnull 1
        33: .line 91
            return
        end local 1 // org.eclipse.jetty.util.thread.SerializedExecutor$Link link
        end local 0 // org.eclipse.jetty.util.thread.SerializedExecutor this
      LocalVariableTable:
        Start  End  Slot  Name  Signature
            0   34     0  this  Lorg/eclipse/jetty/util/thread/SerializedExecutor;
            0   34     1  link  Lorg/eclipse/jetty/util/thread/SerializedExecutor$Link;
            4    5     2     t  Ljava/lang/Throwable;
            8   13     4  next  Lorg/eclipse/jetty/util/thread/SerializedExecutor$Link;
           18   23     4  next  Lorg/eclipse/jetty/util/thread/SerializedExecutor$Link;
           27   32     4  next  Lorg/eclipse/jetty/util/thread/SerializedExecutor$Link;
      Exception table:
        from    to  target  type
           1     2       3  Class java.lang.Throwable
           1     5      14  any
    MethodParameters:
      Name  Flags
      link  
}
SourceFile: "SerializedExecutor.java"
NestMembers:
  org.eclipse.jetty.util.thread.SerializedExecutor$ErrorHandlingTask  org.eclipse.jetty.util.thread.SerializedExecutor$Link
InnerClasses:
  public abstract ErrorHandlingTask = org.eclipse.jetty.util.thread.SerializedExecutor$ErrorHandlingTask of org.eclipse.jetty.util.thread.SerializedExecutor
  private Link = org.eclipse.jetty.util.thread.SerializedExecutor$Link of org.eclipse.jetty.util.thread.SerializedExecutor
/

org.eclipse.jetty/ jetty-util/ 11.0.0/ org/eclipse/jetty/util/thread/SerializedExecutor.class
