package com.google.common.util.concurrent;

import com.google.common.collect.ImmutableList;
import com.google.common.collect.v1;
import java.util.Objects;

/* JADX INFO: loaded from: classes2.dex */
public final class q extends m {
    public CombinedFuture$CombinedFutureInterruptibleTask R;

    public q(ImmutableList immutableList, boolean z10, o0.d dVar) {
        super(immutableList, z10);
        this.R = new CombinedFuture$CallableInterruptibleTask(this, dVar);
        Objects.requireNonNull(this.f23801l);
        if (this.f23801l.isEmpty()) {
            CombinedFuture$CombinedFutureInterruptibleTask combinedFuture$CombinedFutureInterruptibleTask = this.R;
            if (combinedFuture$CombinedFutureInterruptibleTask != null) {
                combinedFuture$CombinedFutureInterruptibleTask.h();
                return;
            }
            return;
        }
        boolean z11 = this.f23802m;
        DirectExecutor directExecutor = DirectExecutor.f23761a;
        if (!z11) {
            e.t tVar = new e.t(this, null, 19);
            v1 it = this.f23801l.iterator();
            while (it.hasNext()) {
                w wVar = (w) it.next();
                if (wVar.isDone()) {
                    q(null);
                } else {
                    wVar.g(tVar, directExecutor);
                }
            }
            return;
        }
        v1 it2 = this.f23801l.iterator();
        int i10 = 0;
        while (it2.hasNext()) {
            w wVar2 = (w) it2.next();
            int i11 = i10 + 1;
            if (wVar2.isDone()) {
                s(i10, wVar2);
            } else {
                wVar2.g(new androidx.activity.n(this, i10, wVar2, 6), directExecutor);
            }
            i10 = i11;
        }
    }

    @Override // com.google.common.util.concurrent.l
    public final void k() {
        CombinedFuture$CombinedFutureInterruptibleTask combinedFuture$CombinedFutureInterruptibleTask = this.R;
        if (combinedFuture$CombinedFutureInterruptibleTask != null) {
            combinedFuture$CombinedFutureInterruptibleTask.c();
        }
    }
}