package com.l7tech.server.audit;

import java.util.TimerTask;

class ax extends TimerTask {
   final boolean[] val$wantInterrupt;
   final Thread val$readerThread;
   final q this$0;

   ax(q var1, boolean[] var2, Thread var3) {
      this.this$0 = var1;
      this.val$wantInterrupt = var2;
      this.val$readerThread = var3;
   }

   @Override
   public void run() {
      synchronized (this.this$0) {
         if (!this.val$wantInterrupt[0]) {
            this.cancel();
         } else {
            this.val$wantInterrupt[0] = false;
            this.val$readerThread.interrupt();
            this.cancel();
         }
      }
   }
}