package O1;

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

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

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

    /* JADX INFO: renamed from: s, reason: collision with root package name */
    public Runnable f4941s;

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

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

    public F(Executor executor) {
        this.f4939q = executor;
    }

    public final void a() {
        synchronized (this.f4942t) {
            Object objPoll = this.f4940r.poll();
            Runnable runnable = (Runnable) objPoll;
            this.f4941s = runnable;
            if (objPoll != null) {
                this.f4939q.execute(runnable);
            }
        }
    }

    @Override // java.util.concurrent.Executor
    public final void execute(Runnable runnable) {
        P6.g.e(runnable, "command");
        synchronized (this.f4942t) {
            this.f4940r.offer(new B0.A(runnable, 16, this));
            if (this.f4941s == null) {
                a();
            }
        }
    }
}