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

Sweeper
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.Sweeper extends org.eclipse.jetty.util.component.AbstractLifeCycle implements java.lang.Runnable
  minor version: 0
  major version: 59
  flags: flags: (0x0021) ACC_PUBLIC, ACC_SUPER
  this_class: org.eclipse.jetty.util.thread.Sweeper
  super_class: org.eclipse.jetty.util.component.AbstractLifeCycle
{
  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 java.util.concurrent.atomic.AtomicReference<java.util.List<org.eclipse.jetty.util.thread.Sweeper$Sweepable>> items;
    descriptor: Ljava/util/concurrent/atomic/AtomicReference;
    flags: (0x0012) ACC_PRIVATE, ACC_FINAL
    Signature: Ljava/util/concurrent/atomic/AtomicReference<Ljava/util/List<Lorg/eclipse/jetty/util/thread/Sweeper$Sweepable;>;>;

  private final java.util.concurrent.atomic.AtomicReference<org.eclipse.jetty.util.thread.Scheduler$Task> task;
    descriptor: Ljava/util/concurrent/atomic/AtomicReference;
    flags: (0x0012) ACC_PRIVATE, ACC_FINAL
    Signature: Ljava/util/concurrent/atomic/AtomicReference<Lorg/eclipse/jetty/util/thread/Scheduler$Task;>;

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

  private final long period;
    descriptor: J
    flags: (0x0012) ACC_PRIVATE, ACC_FINAL

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

  public void <init>(org.eclipse.jetty.util.thread.Scheduler, long);
    descriptor: (Lorg/eclipse/jetty/util/thread/Scheduler;J)V
    flags: (0x0001) ACC_PUBLIC
    Code:
      stack=3, locals=4, args_size=3
        start local 0 // org.eclipse.jetty.util.thread.Sweeper this
        start local 1 // org.eclipse.jetty.util.thread.Scheduler scheduler
        start local 2 // long period
         0: .line 82
            aload 0 /* this */
            invokespecial org.eclipse.jetty.util.component.AbstractLifeCycle.<init>:()V
         1: .line 77
            aload 0 /* this */
            new java.util.concurrent.atomic.AtomicReference
            dup
            invokespecial java.util.concurrent.atomic.AtomicReference.<init>:()V
            putfield org.eclipse.jetty.util.thread.Sweeper.items:Ljava/util/concurrent/atomic/AtomicReference;
         2: .line 78
            aload 0 /* this */
            new java.util.concurrent.atomic.AtomicReference
            dup
            invokespecial java.util.concurrent.atomic.AtomicReference.<init>:()V
            putfield org.eclipse.jetty.util.thread.Sweeper.task:Ljava/util/concurrent/atomic/AtomicReference;
         3: .line 84
            aload 0 /* this */
            aload 1 /* scheduler */
            putfield org.eclipse.jetty.util.thread.Sweeper.scheduler:Lorg/eclipse/jetty/util/thread/Scheduler;
         4: .line 85
            aload 0 /* this */
            lload 2 /* period */
            putfield org.eclipse.jetty.util.thread.Sweeper.period:J
         5: .line 86
            return
        end local 2 // long period
        end local 1 // org.eclipse.jetty.util.thread.Scheduler scheduler
        end local 0 // org.eclipse.jetty.util.thread.Sweeper this
      LocalVariableTable:
        Start  End  Slot       Name  Signature
            0    6     0       this  Lorg/eclipse/jetty/util/thread/Sweeper;
            0    6     1  scheduler  Lorg/eclipse/jetty/util/thread/Scheduler;
            0    6     2     period  J
    MethodParameters:
           Name  Flags
      scheduler  
      period     

  protected void doStart();
    descriptor: ()V
    flags: (0x0004) ACC_PROTECTED
    Code:
      stack=3, locals=1, args_size=1
        start local 0 // org.eclipse.jetty.util.thread.Sweeper this
         0: .line 91
            aload 0 /* this */
            invokespecial org.eclipse.jetty.util.component.AbstractLifeCycle.doStart:()V
         1: .line 92
            aload 0 /* this */
            getfield org.eclipse.jetty.util.thread.Sweeper.items:Ljava/util/concurrent/atomic/AtomicReference;
            new java.util.concurrent.CopyOnWriteArrayList
            dup
            invokespecial java.util.concurrent.CopyOnWriteArrayList.<init>:()V
            invokevirtual java.util.concurrent.atomic.AtomicReference.set:(Ljava/lang/Object;)V
         2: .line 93
            aload 0 /* this */
            invokevirtual org.eclipse.jetty.util.thread.Sweeper.activate:()V
         3: .line 94
            return
        end local 0 // org.eclipse.jetty.util.thread.Sweeper this
      LocalVariableTable:
        Start  End  Slot  Name  Signature
            0    4     0  this  Lorg/eclipse/jetty/util/thread/Sweeper;
    Exceptions:
      throws java.lang.Exception

  protected void doStop();
    descriptor: ()V
    flags: (0x0004) ACC_PROTECTED
    Code:
      stack=2, locals=1, args_size=1
        start local 0 // org.eclipse.jetty.util.thread.Sweeper this
         0: .line 99
            aload 0 /* this */
            invokevirtual org.eclipse.jetty.util.thread.Sweeper.deactivate:()V
         1: .line 100
            aload 0 /* this */
            getfield org.eclipse.jetty.util.thread.Sweeper.items:Ljava/util/concurrent/atomic/AtomicReference;
            aconst_null
            invokevirtual java.util.concurrent.atomic.AtomicReference.set:(Ljava/lang/Object;)V
         2: .line 101
            aload 0 /* this */
            invokespecial org.eclipse.jetty.util.component.AbstractLifeCycle.doStop:()V
         3: .line 102
            return
        end local 0 // org.eclipse.jetty.util.thread.Sweeper this
      LocalVariableTable:
        Start  End  Slot  Name  Signature
            0    4     0  this  Lorg/eclipse/jetty/util/thread/Sweeper;
    Exceptions:
      throws java.lang.Exception

  public int getSize();
    descriptor: ()I
    flags: (0x0001) ACC_PUBLIC
    Code:
      stack=1, locals=2, args_size=1
        start local 0 // org.eclipse.jetty.util.thread.Sweeper this
         0: .line 106
            aload 0 /* this */
            getfield org.eclipse.jetty.util.thread.Sweeper.items:Ljava/util/concurrent/atomic/AtomicReference;
            invokevirtual java.util.concurrent.atomic.AtomicReference.get:()Ljava/lang/Object;
            checkcast java.util.List
            astore 1 /* refs */
        start local 1 // java.util.List refs
         1: .line 107
            aload 1 /* refs */
            ifnonnull 2
            iconst_0
            goto 3
      StackMap locals: java.util.List
      StackMap stack:
         2: aload 1 /* refs */
            invokeinterface java.util.List.size:()I
      StackMap locals:
      StackMap stack: int
         3: ireturn
        end local 1 // java.util.List refs
        end local 0 // org.eclipse.jetty.util.thread.Sweeper this
      LocalVariableTable:
        Start  End  Slot  Name  Signature
            0    4     0  this  Lorg/eclipse/jetty/util/thread/Sweeper;
            1    4     1  refs  Ljava/util/List<Lorg/eclipse/jetty/util/thread/Sweeper$Sweepable;>;

  public boolean offer(org.eclipse.jetty.util.thread.Sweeper$Sweepable);
    descriptor: (Lorg/eclipse/jetty/util/thread/Sweeper$Sweepable;)Z
    flags: (0x0001) ACC_PUBLIC
    Code:
      stack=6, locals=3, args_size=2
        start local 0 // org.eclipse.jetty.util.thread.Sweeper this
        start local 1 // org.eclipse.jetty.util.thread.Sweeper$Sweepable sweepable
         0: .line 112
            aload 0 /* this */
            getfield org.eclipse.jetty.util.thread.Sweeper.items:Ljava/util/concurrent/atomic/AtomicReference;
            invokevirtual java.util.concurrent.atomic.AtomicReference.get:()Ljava/lang/Object;
            checkcast java.util.List
            astore 2 /* refs */
        start local 2 // java.util.List refs
         1: .line 113
            aload 2 /* refs */
            ifnonnull 3
         2: .line 114
            iconst_0
            ireturn
         3: .line 115
      StackMap locals: java.util.List
      StackMap stack:
            aload 2 /* refs */
            aload 1 /* sweepable */
            invokeinterface java.util.List.add:(Ljava/lang/Object;)Z
            pop
         4: .line 116
            getstatic org.eclipse.jetty.util.thread.Sweeper.LOG:Lorg/eclipse/jetty/util/log/Logger;
            invokeinterface org.eclipse.jetty.util.log.Logger.isDebugEnabled:()Z
            ifeq 6
         5: .line 117
            getstatic org.eclipse.jetty.util.thread.Sweeper.LOG:Lorg/eclipse/jetty/util/log/Logger;
            ldc "Resource offered {}"
            iconst_1
            anewarray java.lang.Object
            dup
            iconst_0
            aload 1 /* sweepable */
            aastore
            invokeinterface org.eclipse.jetty.util.log.Logger.debug:(Ljava/lang/String;[Ljava/lang/Object;)V
         6: .line 118
      StackMap locals:
      StackMap stack:
            iconst_1
            ireturn
        end local 2 // java.util.List refs
        end local 1 // org.eclipse.jetty.util.thread.Sweeper$Sweepable sweepable
        end local 0 // org.eclipse.jetty.util.thread.Sweeper this
      LocalVariableTable:
        Start  End  Slot       Name  Signature
            0    7     0       this  Lorg/eclipse/jetty/util/thread/Sweeper;
            0    7     1  sweepable  Lorg/eclipse/jetty/util/thread/Sweeper$Sweepable;
            1    7     2       refs  Ljava/util/List<Lorg/eclipse/jetty/util/thread/Sweeper$Sweepable;>;
    MethodParameters:
           Name  Flags
      sweepable  

  public boolean remove(org.eclipse.jetty.util.thread.Sweeper$Sweepable);
    descriptor: (Lorg/eclipse/jetty/util/thread/Sweeper$Sweepable;)Z
    flags: (0x0001) ACC_PUBLIC
    Code:
      stack=2, locals=3, args_size=2
        start local 0 // org.eclipse.jetty.util.thread.Sweeper this
        start local 1 // org.eclipse.jetty.util.thread.Sweeper$Sweepable sweepable
         0: .line 123
            aload 0 /* this */
            getfield org.eclipse.jetty.util.thread.Sweeper.items:Ljava/util/concurrent/atomic/AtomicReference;
            invokevirtual java.util.concurrent.atomic.AtomicReference.get:()Ljava/lang/Object;
            checkcast java.util.List
            astore 2 /* refs */
        start local 2 // java.util.List refs
         1: .line 124
            aload 2 /* refs */
            ifnull 2
            aload 2 /* refs */
            aload 1 /* sweepable */
            invokeinterface java.util.List.remove:(Ljava/lang/Object;)Z
            ifeq 2
            iconst_1
            ireturn
      StackMap locals: java.util.List
      StackMap stack:
         2: iconst_0
            ireturn
        end local 2 // java.util.List refs
        end local 1 // org.eclipse.jetty.util.thread.Sweeper$Sweepable sweepable
        end local 0 // org.eclipse.jetty.util.thread.Sweeper this
      LocalVariableTable:
        Start  End  Slot       Name  Signature
            0    3     0       this  Lorg/eclipse/jetty/util/thread/Sweeper;
            0    3     1  sweepable  Lorg/eclipse/jetty/util/thread/Sweeper$Sweepable;
            1    3     2       refs  Ljava/util/List<Lorg/eclipse/jetty/util/thread/Sweeper$Sweepable;>;
    MethodParameters:
           Name  Flags
      sweepable  

  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.Sweeper this
         0: .line 130
            aload 0 /* this */
            getfield org.eclipse.jetty.util.thread.Sweeper.items:Ljava/util/concurrent/atomic/AtomicReference;
            invokevirtual java.util.concurrent.atomic.AtomicReference.get:()Ljava/lang/Object;
            checkcast java.util.List
            astore 1 /* refs */
        start local 1 // java.util.List refs
         1: .line 131
            aload 1 /* refs */
            ifnonnull 3
         2: .line 132
            return
         3: .line 133
      StackMap locals: java.util.List
      StackMap stack:
            aload 1 /* refs */
            invokeinterface java.util.List.iterator:()Ljava/util/Iterator;
            astore 3
            goto 12
      StackMap locals: org.eclipse.jetty.util.thread.Sweeper java.util.List top java.util.Iterator
      StackMap stack:
         4: aload 3
            invokeinterface java.util.Iterator.next:()Ljava/lang/Object;
            checkcast org.eclipse.jetty.util.thread.Sweeper$Sweepable
            astore 2 /* sweepable */
        start local 2 // org.eclipse.jetty.util.thread.Sweeper$Sweepable sweepable
         5: .line 137
            aload 2 /* sweepable */
            invokeinterface org.eclipse.jetty.util.thread.Sweeper$Sweepable.sweep:()Z
            ifeq 12
         6: .line 139
            aload 1 /* refs */
            aload 2 /* sweepable */
            invokeinterface java.util.List.remove:(Ljava/lang/Object;)Z
            pop
         7: .line 140
            getstatic org.eclipse.jetty.util.thread.Sweeper.LOG:Lorg/eclipse/jetty/util/log/Logger;
            invokeinterface org.eclipse.jetty.util.log.Logger.isDebugEnabled:()Z
            ifeq 12
         8: .line 141
            getstatic org.eclipse.jetty.util.thread.Sweeper.LOG:Lorg/eclipse/jetty/util/log/Logger;
            ldc "Resource swept {}"
            iconst_1
            anewarray java.lang.Object
            dup
            iconst_0
            aload 2 /* sweepable */
            aastore
            invokeinterface org.eclipse.jetty.util.log.Logger.debug:(Ljava/lang/String;[Ljava/lang/Object;)V
         9: .line 143
            goto 12
        10: .line 144
      StackMap locals: org.eclipse.jetty.util.thread.Sweeper java.util.List org.eclipse.jetty.util.thread.Sweeper$Sweepable java.util.Iterator
      StackMap stack: java.lang.Throwable
            astore 4 /* x */
        start local 4 // java.lang.Throwable x
        11: .line 146
            getstatic org.eclipse.jetty.util.thread.Sweeper.LOG:Lorg/eclipse/jetty/util/log/Logger;
            new java.lang.StringBuilder
            dup
            ldc "Exception while sweeping "
            invokespecial java.lang.StringBuilder.<init>:(Ljava/lang/String;)V
            aload 2 /* sweepable */
            invokevirtual java.lang.StringBuilder.append:(Ljava/lang/Object;)Ljava/lang/StringBuilder;
            invokevirtual java.lang.StringBuilder.toString:()Ljava/lang/String;
            aload 4 /* x */
            invokeinterface org.eclipse.jetty.util.log.Logger.info:(Ljava/lang/String;Ljava/lang/Throwable;)V
        end local 4 // java.lang.Throwable x
        end local 2 // org.eclipse.jetty.util.thread.Sweeper$Sweepable sweepable
        12: .line 133
      StackMap locals: org.eclipse.jetty.util.thread.Sweeper java.util.List top java.util.Iterator
      StackMap stack:
            aload 3
            invokeinterface java.util.Iterator.hasNext:()Z
            ifne 4
        13: .line 149
            aload 0 /* this */
            invokevirtual org.eclipse.jetty.util.thread.Sweeper.activate:()V
        14: .line 150
            return
        end local 1 // java.util.List refs
        end local 0 // org.eclipse.jetty.util.thread.Sweeper this
      LocalVariableTable:
        Start  End  Slot       Name  Signature
            0   15     0       this  Lorg/eclipse/jetty/util/thread/Sweeper;
            1   15     1       refs  Ljava/util/List<Lorg/eclipse/jetty/util/thread/Sweeper$Sweepable;>;
            5   12     2  sweepable  Lorg/eclipse/jetty/util/thread/Sweeper$Sweepable;
           11   12     4          x  Ljava/lang/Throwable;
      Exception table:
        from    to  target  type
           5     9      10  Class java.lang.Throwable

  private void activate();
    descriptor: ()V
    flags: (0x0002) ACC_PRIVATE
    Code:
      stack=7, locals=2, args_size=1
        start local 0 // org.eclipse.jetty.util.thread.Sweeper this
         0: .line 154
            aload 0 /* this */
            invokevirtual org.eclipse.jetty.util.thread.Sweeper.isRunning:()Z
            ifeq 6
         1: .line 156
            aload 0 /* this */
            getfield org.eclipse.jetty.util.thread.Sweeper.scheduler:Lorg/eclipse/jetty/util/thread/Scheduler;
            aload 0 /* this */
            aload 0 /* this */
            getfield org.eclipse.jetty.util.thread.Sweeper.period:J
            getstatic java.util.concurrent.TimeUnit.MILLISECONDS:Ljava/util/concurrent/TimeUnit;
            invokeinterface org.eclipse.jetty.util.thread.Scheduler.schedule:(Ljava/lang/Runnable;JLjava/util/concurrent/TimeUnit;)Lorg/eclipse/jetty/util/thread/Scheduler$Task;
            astore 1 /* t */
        start local 1 // org.eclipse.jetty.util.thread.Scheduler$Task t
         2: .line 157
            getstatic org.eclipse.jetty.util.thread.Sweeper.LOG:Lorg/eclipse/jetty/util/log/Logger;
            invokeinterface org.eclipse.jetty.util.log.Logger.isDebugEnabled:()Z
            ifeq 4
         3: .line 158
            getstatic org.eclipse.jetty.util.thread.Sweeper.LOG:Lorg/eclipse/jetty/util/log/Logger;
            ldc "Scheduled in {} ms sweep task {}"
            iconst_2
            anewarray java.lang.Object
            dup
            iconst_0
            aload 0 /* this */
            getfield org.eclipse.jetty.util.thread.Sweeper.period:J
            invokestatic java.lang.Long.valueOf:(J)Ljava/lang/Long;
            aastore
            dup
            iconst_1
            aload 1 /* t */
            aastore
            invokeinterface org.eclipse.jetty.util.log.Logger.debug:(Ljava/lang/String;[Ljava/lang/Object;)V
         4: .line 159
      StackMap locals: org.eclipse.jetty.util.thread.Scheduler$Task
      StackMap stack:
            aload 0 /* this */
            getfield org.eclipse.jetty.util.thread.Sweeper.task:Ljava/util/concurrent/atomic/AtomicReference;
            aload 1 /* t */
            invokevirtual java.util.concurrent.atomic.AtomicReference.set:(Ljava/lang/Object;)V
        end local 1 // org.eclipse.jetty.util.thread.Scheduler$Task t
         5: .line 160
            goto 8
         6: .line 163
      StackMap locals:
      StackMap stack:
            getstatic org.eclipse.jetty.util.thread.Sweeper.LOG:Lorg/eclipse/jetty/util/log/Logger;
            invokeinterface org.eclipse.jetty.util.log.Logger.isDebugEnabled:()Z
            ifeq 8
         7: .line 164
            getstatic org.eclipse.jetty.util.thread.Sweeper.LOG:Lorg/eclipse/jetty/util/log/Logger;
            ldc "Skipping sweep task scheduling"
            iconst_0
            anewarray java.lang.Object
            invokeinterface org.eclipse.jetty.util.log.Logger.debug:(Ljava/lang/String;[Ljava/lang/Object;)V
         8: .line 166
      StackMap locals:
      StackMap stack:
            return
        end local 0 // org.eclipse.jetty.util.thread.Sweeper this
      LocalVariableTable:
        Start  End  Slot  Name  Signature
            0    9     0  this  Lorg/eclipse/jetty/util/thread/Sweeper;
            2    5     1     t  Lorg/eclipse/jetty/util/thread/Scheduler$Task;

  private void deactivate();
    descriptor: ()V
    flags: (0x0002) ACC_PRIVATE
    Code:
      stack=6, locals=3, args_size=1
        start local 0 // org.eclipse.jetty.util.thread.Sweeper this
         0: .line 170
            aload 0 /* this */
            getfield org.eclipse.jetty.util.thread.Sweeper.task:Ljava/util/concurrent/atomic/AtomicReference;
            aconst_null
            invokevirtual java.util.concurrent.atomic.AtomicReference.getAndSet:(Ljava/lang/Object;)Ljava/lang/Object;
            checkcast org.eclipse.jetty.util.thread.Scheduler$Task
            astore 1 /* t */
        start local 1 // org.eclipse.jetty.util.thread.Scheduler$Task t
         1: .line 171
            aload 1 /* t */
            ifnull 5
         2: .line 173
            aload 1 /* t */
            invokeinterface org.eclipse.jetty.util.thread.Scheduler$Task.cancel:()Z
            istore 2 /* cancelled */
        start local 2 // boolean cancelled
         3: .line 174
            getstatic org.eclipse.jetty.util.thread.Sweeper.LOG:Lorg/eclipse/jetty/util/log/Logger;
            invokeinterface org.eclipse.jetty.util.log.Logger.isDebugEnabled:()Z
            ifeq 5
         4: .line 175
            getstatic org.eclipse.jetty.util.thread.Sweeper.LOG:Lorg/eclipse/jetty/util/log/Logger;
            ldc "Cancelled ({}) sweep task {}"
            iconst_2
            anewarray java.lang.Object
            dup
            iconst_0
            iload 2 /* cancelled */
            invokestatic java.lang.Boolean.valueOf:(Z)Ljava/lang/Boolean;
            aastore
            dup
            iconst_1
            aload 1 /* t */
            aastore
            invokeinterface org.eclipse.jetty.util.log.Logger.debug:(Ljava/lang/String;[Ljava/lang/Object;)V
        end local 2 // boolean cancelled
         5: .line 177
      StackMap locals: org.eclipse.jetty.util.thread.Scheduler$Task
      StackMap stack:
            return
        end local 1 // org.eclipse.jetty.util.thread.Scheduler$Task t
        end local 0 // org.eclipse.jetty.util.thread.Sweeper this
      LocalVariableTable:
        Start  End  Slot       Name  Signature
            0    6     0       this  Lorg/eclipse/jetty/util/thread/Sweeper;
            1    6     1          t  Lorg/eclipse/jetty/util/thread/Scheduler$Task;
            3    5     2  cancelled  Z
}
SourceFile: "Sweeper.java"
NestMembers:
  org.eclipse.jetty.util.thread.Sweeper$Sweepable
InnerClasses:
  public abstract Task = org.eclipse.jetty.util.thread.Scheduler$Task of org.eclipse.jetty.util.thread.Scheduler
  public abstract Sweepable = org.eclipse.jetty.util.thread.Sweeper$Sweepable of org.eclipse.jetty.util.thread.Sweeper
/

org.eclipse.jetty/ jetty-util/ 10.0.0-alpha0/ org/eclipse/jetty/util/thread/Sweeper.class
