package androidx.compose.runtime;

import androidx.compose.runtime.internal.AtomicBoolean;
import androidx.compose.runtime.internal.AtomicInt;
import androidx.compose.runtime.internal.AwaiterQueue;
import androidx.compose.runtime.internal.StabilityInferred;
import java.util.concurrent.CancellationException;
import w4.C3137A;

/* JADX INFO: loaded from: classes.dex */
@StabilityInferred(parameters = 0)
public final class NextFrameEndCallbackQueue {
    public static final int $stable = 8;
    private final J4.a onNewAwaiters;
    private final AtomicInt isFrameOngoing = AtomicBoolean.m217constructorimpl(false);
    private final AwaiterQueue<NextFrameEndAwaiter> frameEndQueue = new AwaiterQueue<>();

    public NextFrameEndCallbackQueue(J4.a aVar) {
        this.onNewAwaiters = new B2.j(26, this, aVar);
    }

    public static /* synthetic */ void cancel$default(NextFrameEndCallbackQueue nextFrameEndCallbackQueue, CancellationException cancellationException, int i6, Object obj) {
        if ((i6 & 1) != 0) {
            cancellationException = new CancellationException("scheduler cancelled");
        }
        nextFrameEndCallbackQueue.cancel(cancellationException);
    }

    /* JADX INFO: Access modifiers changed from: private */
    public static final C3137A markFrameComplete$lambda$0(NextFrameEndAwaiter nextFrameEndAwaiter) {
        nextFrameEndAwaiter.resume();
        return C3137A.f25453a;
    }

    /* JADX INFO: Access modifiers changed from: private */
    public static final C3137A onNewAwaiters$lambda$0(NextFrameEndCallbackQueue nextFrameEndCallbackQueue, J4.a aVar) {
        if (!AtomicBoolean.m221getimpl(nextFrameEndCallbackQueue.isFrameOngoing)) {
            aVar.invoke();
        }
        return C3137A.f25453a;
    }

    public final void cancel(CancellationException cancellationException) {
        this.frameEndQueue.fail(cancellationException);
    }

    public final boolean getHasAwaiters() {
        return this.frameEndQueue.getHasAwaiters();
    }

    public final void markFrameComplete() {
        AtomicBoolean.m224setimpl(this.isFrameOngoing, false);
        this.frameEndQueue.flushAndDispatchAwaiters(new q());
    }

    public final void markFrameStarted() {
        AtomicBoolean.m224setimpl(this.isFrameOngoing, true);
    }

    public final CancellationHandle scheduleFrameEndCallback(J4.a aVar) {
        return this.frameEndQueue.addAwaiter(new NextFrameEndAwaiter(aVar), this.onNewAwaiters);
    }

    public static final class NextFrameEndAwaiter extends AwaiterQueue.Awaiter {
        private J4.a onNextFrameEnd;

        public NextFrameEndAwaiter(J4.a aVar) {
            this.onNextFrameEnd = aVar;
        }

        @Override // androidx.compose.runtime.internal.AwaiterQueue.Awaiter
        public void cancel() {
            this.onNextFrameEnd = null;
        }

        public final void resume() {
            J4.a aVar = this.onNextFrameEnd;
            if (aVar != null) {
                aVar.invoke();
            }
        }

        @Override // androidx.compose.runtime.internal.AwaiterQueue.Awaiter
        public void resumeWithException(Throwable th) throws Throwable {
            throw th;
        }
    }
}