package o4;

import java.util.ArrayDeque;
import java.util.concurrent.Executor;
import java.util.concurrent.ExecutorService;

/* JADX INFO: loaded from: classes.dex */
public final class j implements Executor {

    /* JADX INFO: renamed from: b, reason: collision with root package name */
    public final Executor f31390b;

    /* JADX INFO: renamed from: d, reason: collision with root package name */
    public volatile Runnable f31392d;

    /* JADX INFO: renamed from: a, reason: collision with root package name */
    public final ArrayDeque f31389a = new ArrayDeque();

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

    public j(ExecutorService executorService) {
        this.f31390b = executorService;
    }

    public final void a() {
        synchronized (this.f31391c) {
            try {
                Runnable runnable = (Runnable) this.f31389a.poll();
                this.f31392d = runnable;
                if (runnable != null) {
                    this.f31390b.execute(this.f31392d);
                }
            } catch (Throwable th) {
                throw th;
            }
        }
    }

    @Override // java.util.concurrent.Executor
    public final void execute(Runnable runnable) {
        synchronized (this.f31391c) {
            try {
                this.f31389a.add(new l.l(this, runnable, 10, 0));
                if (this.f31392d == null) {
                    a();
                }
            } catch (Throwable th) {
                throw th;
            }
        }
    }
}