package com.google.common.util.concurrent;

import java.util.concurrent.CancellationException;
import java.util.concurrent.ExecutionException;
import java.util.concurrent.Executor;
import java.util.concurrent.RejectedExecutionException;

/* JADX INFO: loaded from: classes2.dex */
abstract class CombinedFuture$CombinedFutureInterruptibleTask<T> extends InterruptibleTask<T> {
    private final Executor listenerExecutor;
    final /* synthetic */ q this$0;

    public CombinedFuture$CombinedFutureInterruptibleTask(q qVar) {
        DirectExecutor directExecutor = DirectExecutor.f23761a;
        this.this$0 = qVar;
        this.listenerExecutor = directExecutor;
    }

    @Override // com.google.common.util.concurrent.InterruptibleTask
    public final void a(Throwable th) {
        q qVar = this.this$0;
        qVar.R = null;
        if (th instanceof ExecutionException) {
            qVar.o(((ExecutionException) th).getCause());
        } else if (th instanceof CancellationException) {
            qVar.cancel(false);
        } else {
            qVar.o(th);
        }
    }

    @Override // com.google.common.util.concurrent.InterruptibleTask
    public final void b(Object obj) {
        this.this$0.R = null;
        ((CombinedFuture$CallableInterruptibleTask) this).this$0.n(obj);
    }

    @Override // com.google.common.util.concurrent.InterruptibleTask
    public final boolean d() {
        return this.this$0.isDone();
    }

    public final void h() {
        try {
            this.listenerExecutor.execute(this);
        } catch (RejectedExecutionException e10) {
            this.this$0.o(e10);
        }
    }
}