package yc;

import java.util.concurrent.ConcurrentLinkedQueue;
import java.util.concurrent.ExecutorService;
import java.util.concurrent.atomic.AtomicBoolean;

/* JADX INFO: loaded from: classes.dex */
public final class l implements h {

    /* JADX INFO: renamed from: a, reason: collision with root package name */
    public final ExecutorService f36959a;

    /* JADX INFO: renamed from: b, reason: collision with root package name */
    public final ConcurrentLinkedQueue f36960b = new ConcurrentLinkedQueue();

    /* JADX INFO: renamed from: c, reason: collision with root package name */
    public final AtomicBoolean f36961c = new AtomicBoolean(false);

    public l(ExecutorService executorService) {
        this.f36959a = executorService;
    }

    @Override // yc.h
    public final void a(e eVar) {
        this.f36960b.add(eVar);
        this.f36959a.execute(new k(this, 0));
    }

    public final void b() {
        ExecutorService executorService = this.f36959a;
        ConcurrentLinkedQueue concurrentLinkedQueue = this.f36960b;
        AtomicBoolean atomicBoolean = this.f36961c;
        if (atomicBoolean.compareAndSet(false, true)) {
            try {
                Runnable runnable = (Runnable) concurrentLinkedQueue.poll();
                if (runnable != null) {
                    runnable.run();
                }
                atomicBoolean.set(false);
                if (concurrentLinkedQueue.isEmpty()) {
                    return;
                }
                executorService.execute(new k(this, 1));
            } catch (Throwable th) {
                atomicBoolean.set(false);
                if (!concurrentLinkedQueue.isEmpty()) {
                    executorService.execute(new k(this, 2));
                }
                throw th;
            }
        }
    }
}