package com.google.android.gms.internal.ads;

import androidx.annotation.Nullable;
import java.util.concurrent.Executor;
import java.util.concurrent.atomic.AtomicReference;

/* JADX INFO: loaded from: classes2.dex */
public final class yb0 implements kj {

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

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

    @Nullable
    private final x50 zza;

    public yb0(@Nullable x50 x50Var, Executor executor) {
        this.zza = x50Var;
        this.f18787a = executor;
    }

    @Override // com.google.android.gms.internal.ads.kj
    public final synchronized void p(jj jjVar) {
        x50 x50Var = this.zza;
        if (x50Var != null) {
            if (((Boolean) n7.y.f31093e.f31096c.b(ao.Pd)).booleanValue()) {
                if (jjVar.f12901j) {
                    AtomicReference atomicReference = this.f18788b;
                    Boolean bool = Boolean.TRUE;
                    if (!bool.equals(atomicReference.getAndSet(bool))) {
                        this.f18787a.execute(new i60(x50Var, 3));
                    }
                } else {
                    AtomicReference atomicReference2 = this.f18788b;
                    Boolean bool2 = Boolean.FALSE;
                    if (!bool2.equals(atomicReference2.getAndSet(bool2))) {
                        this.f18787a.execute(new i60(x50Var, 2));
                    }
                }
            }
        }
    }
}