package o;

import java.util.concurrent.Executor;

/* loaded from: classes2.dex */
public final class qvr<TResult> implements nRk<TResult> {
    final Object c = new Object();
    QNe<TResult> d;
    private Executor e;

    @Override // o.nRk
    public final void b(HiE<TResult> hiE) {
        this.e.execute(new Runnable(this, hiE) { // from class: o.qvr.5
            private HiE a;
            private qvr d;

            @Override // java.lang.Runnable
            public final void run() {
                synchronized (this.d.c) {
                    if (this.d.d != null) {
                        this.d.d.onComplete(this.a);
                    }
                }
            }

            {
                this.d = this;
                this.a = hiE;
            }
        });
    }

    /* JADX INFO: Access modifiers changed from: package-private */
    public qvr(Executor executor, QNe<TResult> qNe) {
        this.d = qNe;
        this.e = executor;
    }
}