final class io.netty.util.ThreadDeathWatcher$Watcher implements java.lang.Runnable
  minor version: 0
  major version: 59
  flags: flags: (0x0030) ACC_FINAL, ACC_SUPER
  this_class: io.netty.util.ThreadDeathWatcher$Watcher
  super_class: java.lang.Object
{
  private final java.util.List<io.netty.util.ThreadDeathWatcher$Entry> watchees;
    descriptor: Ljava/util/List;
    flags: (0x0012) ACC_PRIVATE, ACC_FINAL
    Signature: Ljava/util/List<Lio/netty/util/ThreadDeathWatcher$Entry;>;

  static final boolean $assertionsDisabled;
    descriptor: Z
    flags: (0x1018) ACC_STATIC, ACC_FINAL, ACC_SYNTHETIC

  static void <clinit>();
    descriptor: ()V
    flags: (0x0008) ACC_STATIC
    Code:
      stack=1, locals=0, args_size=0
         0: .line 155
            ldc Lio/netty/util/ThreadDeathWatcher;
            invokevirtual java.lang.Class.desiredAssertionStatus:()Z
            ifne 1
            iconst_1
            goto 2
      StackMap locals:
      StackMap stack:
         1: iconst_0
      StackMap locals:
      StackMap stack: int
         2: putstatic io.netty.util.ThreadDeathWatcher$Watcher.$assertionsDisabled:Z
            return
      LocalVariableTable:
        Start  End  Slot  Name  Signature

  private void <init>();
    descriptor: ()V
    flags: (0x0002) ACC_PRIVATE
    Code:
      stack=3, locals=1, args_size=1
        start local 0 // io.netty.util.ThreadDeathWatcher$Watcher this
         0: .line 155
            aload 0 /* this */
            invokespecial java.lang.Object.<init>:()V
         1: .line 157
            aload 0 /* this */
            new java.util.ArrayList
            dup
            invokespecial java.util.ArrayList.<init>:()V
            putfield io.netty.util.ThreadDeathWatcher$Watcher.watchees:Ljava/util/List;
         2: .line 155
            return
        end local 0 // io.netty.util.ThreadDeathWatcher$Watcher this
      LocalVariableTable:
        Start  End  Slot  Name  Signature
            0    3     0  this  Lio/netty/util/ThreadDeathWatcher$Watcher;

  public void run();
    descriptor: ()V
    flags: (0x0001) ACC_PUBLIC
    Code:
      stack=3, locals=2, args_size=1
        start local 0 // io.netty.util.ThreadDeathWatcher$Watcher this
         0: .line 162
      StackMap locals:
      StackMap stack:
            aload 0 /* this */
            invokevirtual io.netty.util.ThreadDeathWatcher$Watcher.fetchWatchees:()V
         1: .line 163
            aload 0 /* this */
            invokevirtual io.netty.util.ThreadDeathWatcher$Watcher.notifyWatchees:()V
         2: .line 166
            aload 0 /* this */
            invokevirtual io.netty.util.ThreadDeathWatcher$Watcher.fetchWatchees:()V
         3: .line 167
            aload 0 /* this */
            invokevirtual io.netty.util.ThreadDeathWatcher$Watcher.notifyWatchees:()V
         4: .line 170
            ldc 1000
            invokestatic java.lang.Thread.sleep:(J)V
         5: .line 171
            goto 7
      StackMap locals:
      StackMap stack: java.lang.InterruptedException
         6: pop
         7: .line 175
      StackMap locals:
      StackMap stack:
            aload 0 /* this */
            getfield io.netty.util.ThreadDeathWatcher$Watcher.watchees:Ljava/util/List;
            invokeinterface java.util.List.isEmpty:()Z
            ifeq 0
            getstatic io.netty.util.ThreadDeathWatcher.pendingEntries:Ljava/util/Queue;
            invokeinterface java.util.Queue.isEmpty:()Z
            ifeq 0
         8: .line 180
            getstatic io.netty.util.ThreadDeathWatcher.started:Ljava/util/concurrent/atomic/AtomicBoolean;
            iconst_1
            iconst_0
            invokevirtual java.util.concurrent.atomic.AtomicBoolean.compareAndSet:(ZZ)Z
            istore 1 /* stopped */
        start local 1 // boolean stopped
         9: .line 181
            getstatic io.netty.util.ThreadDeathWatcher$Watcher.$assertionsDisabled:Z
            ifne 10
            iload 1 /* stopped */
            ifne 10
            new java.lang.AssertionError
            dup
            invokespecial java.lang.AssertionError.<init>:()V
            athrow
        10: .line 184
      StackMap locals: int
      StackMap stack:
            getstatic io.netty.util.ThreadDeathWatcher.pendingEntries:Ljava/util/Queue;
            invokeinterface java.util.Queue.isEmpty:()Z
            ifeq 12
        11: .line 189
            goto 13
        12: .line 193
      StackMap locals:
      StackMap stack:
            getstatic io.netty.util.ThreadDeathWatcher.started:Ljava/util/concurrent/atomic/AtomicBoolean;
            iconst_0
            iconst_1
            invokevirtual java.util.concurrent.atomic.AtomicBoolean.compareAndSet:(ZZ)Z
            ifne 0
        end local 1 // boolean stopped
        13: .line 204
      StackMap locals:
      StackMap stack:
            return
        end local 0 // io.netty.util.ThreadDeathWatcher$Watcher this
      LocalVariableTable:
        Start  End  Slot     Name  Signature
            0   14     0     this  Lio/netty/util/ThreadDeathWatcher$Watcher;
            9   13     1  stopped  Z
      Exception table:
        from    to  target  type
           4     5       6  Class java.lang.InterruptedException

  private void fetchWatchees();
    descriptor: ()V
    flags: (0x0002) ACC_PRIVATE
    Code:
      stack=2, locals=2, args_size=1
        start local 0 // io.netty.util.ThreadDeathWatcher$Watcher this
         0: .line 208
      StackMap locals:
      StackMap stack:
            getstatic io.netty.util.ThreadDeathWatcher.pendingEntries:Ljava/util/Queue;
            invokeinterface java.util.Queue.poll:()Ljava/lang/Object;
            checkcast io.netty.util.ThreadDeathWatcher$Entry
            astore 1 /* e */
        start local 1 // io.netty.util.ThreadDeathWatcher$Entry e
         1: .line 209
            aload 1 /* e */
            ifnonnull 3
         2: .line 210
            goto 8
         3: .line 213
      StackMap locals: io.netty.util.ThreadDeathWatcher$Entry
      StackMap stack:
            aload 1 /* e */
            getfield io.netty.util.ThreadDeathWatcher$Entry.isWatch:Z
            ifeq 6
         4: .line 214
            aload 0 /* this */
            getfield io.netty.util.ThreadDeathWatcher$Watcher.watchees:Ljava/util/List;
            aload 1 /* e */
            invokeinterface java.util.List.add:(Ljava/lang/Object;)Z
            pop
         5: .line 215
            goto 0
         6: .line 216
      StackMap locals:
      StackMap stack:
            aload 0 /* this */
            getfield io.netty.util.ThreadDeathWatcher$Watcher.watchees:Ljava/util/List;
            aload 1 /* e */
            invokeinterface java.util.List.remove:(Ljava/lang/Object;)Z
            pop
        end local 1 // io.netty.util.ThreadDeathWatcher$Entry e
         7: .line 207
            goto 0
         8: .line 219
      StackMap locals:
      StackMap stack:
            return
        end local 0 // io.netty.util.ThreadDeathWatcher$Watcher this
      LocalVariableTable:
        Start  End  Slot  Name  Signature
            0    9     0  this  Lio/netty/util/ThreadDeathWatcher$Watcher;
            1    7     1     e  Lio/netty/util/ThreadDeathWatcher$Entry;

  private void notifyWatchees();
    descriptor: ()V
    flags: (0x0002) ACC_PRIVATE
    Code:
      stack=3, locals=5, args_size=1
        start local 0 // io.netty.util.ThreadDeathWatcher$Watcher this
         0: .line 222
            aload 0 /* this */
            getfield io.netty.util.ThreadDeathWatcher$Watcher.watchees:Ljava/util/List;
            astore 1 /* watchees */
        start local 1 // java.util.List watchees
         1: .line 223
            iconst_0
            istore 2 /* i */
        start local 2 // int i
         2: goto 12
         3: .line 224
      StackMap locals: java.util.List int
      StackMap stack:
            aload 1 /* watchees */
            iload 2 /* i */
            invokeinterface java.util.List.get:(I)Ljava/lang/Object;
            checkcast io.netty.util.ThreadDeathWatcher$Entry
            astore 3 /* e */
        start local 3 // io.netty.util.ThreadDeathWatcher$Entry e
         4: .line 225
            aload 3 /* e */
            getfield io.netty.util.ThreadDeathWatcher$Entry.thread:Ljava/lang/Thread;
            invokevirtual java.lang.Thread.isAlive:()Z
            ifne 11
         5: .line 226
            aload 1 /* watchees */
            iload 2 /* i */
            invokeinterface java.util.List.remove:(I)Ljava/lang/Object;
            pop
         6: .line 228
            aload 3 /* e */
            getfield io.netty.util.ThreadDeathWatcher$Entry.task:Ljava/lang/Runnable;
            invokeinterface java.lang.Runnable.run:()V
         7: .line 229
            goto 12
      StackMap locals: io.netty.util.ThreadDeathWatcher$Watcher java.util.List int io.netty.util.ThreadDeathWatcher$Entry
      StackMap stack: java.lang.Throwable
         8: astore 4 /* t */
        start local 4 // java.lang.Throwable t
         9: .line 230
            getstatic io.netty.util.ThreadDeathWatcher.logger:Lio/netty/util/internal/logging/InternalLogger;
            ldc "Thread death watcher task raised an exception:"
            aload 4 /* t */
            invokeinterface io.netty.util.internal.logging.InternalLogger.warn:(Ljava/lang/String;Ljava/lang/Throwable;)V
        end local 4 // java.lang.Throwable t
        10: .line 232
            goto 12
        11: .line 233
      StackMap locals:
      StackMap stack:
            iinc 2 /* i */ 1
        end local 3 // io.netty.util.ThreadDeathWatcher$Entry e
        12: .line 223
      StackMap locals:
      StackMap stack:
            iload 2 /* i */
            aload 1 /* watchees */
            invokeinterface java.util.List.size:()I
            if_icmplt 3
        end local 2 // int i
        13: .line 236
            return
        end local 1 // java.util.List watchees
        end local 0 // io.netty.util.ThreadDeathWatcher$Watcher this
      LocalVariableTable:
        Start  End  Slot      Name  Signature
            0   14     0      this  Lio/netty/util/ThreadDeathWatcher$Watcher;
            1   14     1  watchees  Ljava/util/List<Lio/netty/util/ThreadDeathWatcher$Entry;>;
            2   13     2         i  I
            4   12     3         e  Lio/netty/util/ThreadDeathWatcher$Entry;
            9   10     4         t  Ljava/lang/Throwable;
      Exception table:
        from    to  target  type
           6     7       8  Class java.lang.Throwable
}
SourceFile: "ThreadDeathWatcher.java"
NestHost: io.netty.util.ThreadDeathWatcher
InnerClasses:
  private final Entry = io.netty.util.ThreadDeathWatcher$Entry of io.netty.util.ThreadDeathWatcher
  private final Watcher = io.netty.util.ThreadDeathWatcher$Watcher of io.netty.util.ThreadDeathWatcher