package d.a.s.e.c;

import java.util.concurrent.atomic.AtomicInteger;

/* JADX INFO: loaded from: classes.dex */
public final class l<T> extends AtomicInteger implements d.a.s.c.a<T>, Runnable {

    /* JADX INFO: renamed from: b, reason: collision with root package name */
    public final d.a.l<? super T> f5763b;

    /* JADX INFO: renamed from: c, reason: collision with root package name */
    public final T f5764c;

    public l(d.a.l<? super T> lVar, T t) {
        this.f5763b = lVar;
        this.f5764c = t;
    }

    @Override // d.a.s.c.d
    public void clear() {
        lazySet(3);
    }

    @Override // d.a.p.b
    public void dispose() {
        set(3);
    }

    @Override // d.a.p.b
    public boolean isDisposed() {
        return get() == 3;
    }

    @Override // d.a.s.c.d
    public boolean isEmpty() {
        return get() != 1;
    }

    @Override // d.a.s.c.d
    public boolean offer(T t) {
        throw new UnsupportedOperationException("Should not be called!");
    }

    @Override // d.a.s.c.d
    public T poll() {
        if (get() != 1) {
            return null;
        }
        lazySet(3);
        return this.f5764c;
    }

    @Override // d.a.s.c.a
    public int requestFusion(int i2) {
        if ((i2 & 1) == 0) {
            return 0;
        }
        lazySet(1);
        return 1;
    }

    @Override // java.lang.Runnable
    public void run() {
        if (get() == 0 && compareAndSet(0, 2)) {
            this.f5763b.d(this.f5764c);
            if (get() == 2) {
                lazySet(3);
                this.f5763b.b();
            }
        }
    }
}