/*
 * Decompiled with CFR 0.152.
 */
package com.l7tech.server.audit;

import com.l7tech.server.audit.q;
import java.util.TimerTask;

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

    ax(q q2, boolean[] blArray, Thread thread) {
        this.this$0 = q2;
        this.val$wantInterrupt = blArray;
        this.val$readerThread = thread;
    }

    /*
     * WARNING - Removed try catching itself - possible behaviour change.
     */
    @Override
    public void run() {
        q q2 = this.this$0;
        synchronized (q2) {
            if (!this.val$wantInterrupt[0]) {
                this.cancel();
                return;
            }
            this.val$wantInterrupt[0] = false;
            this.val$readerThread.interrupt();
            this.cancel();
        }
    }
}