package defpackage;

import com.google.common.util.concurrent.ListenableFuture;
import java.util.concurrent.ExecutionException;

/* renamed from: ᵬˏˉ, reason: contains not printable characters */
/* loaded from: classes3.dex */
public abstract class AbstractC4031 {

    /* renamed from: ᵥᵯˎ, reason: contains not printable characters */
    public static final /* synthetic */ int f15132 = 0;

    static {
        ᵼᵫᵧˀ.ˁˑᵰ("WorkerWrapper");
    }

    /* renamed from: ᵥᵯˎ, reason: contains not printable characters */
    public static final Object m8876(ListenableFuture listenableFuture, AbstractC3690 abstractC3690, AbstractC2162 abstractC2162) throws Throwable {
        Object obj;
        try {
            if (!listenableFuture.isDone()) {
                C4385 c4385 = new C4385(1, ᵱᵞᵪ.ᵞʡ(abstractC2162));
                c4385.m9415();
                listenableFuture.mo833(new ﹶᴵ(listenableFuture, 1, c4385), EnumC3215.f12144);
                c4385.m9403(new ᵫʔˈ(abstractC3690, 3, listenableFuture));
                return c4385.m9405();
            }
            boolean z = false;
            while (true) {
                try {
                    obj = listenableFuture.get();
                    break;
                } catch (InterruptedException unused) {
                    z = true;
                } catch (Throwable th) {
                    if (z) {
                        Thread.currentThread().interrupt();
                    }
                    throw th;
                }
            }
            if (z) {
                Thread.currentThread().interrupt();
            }
            return obj;
        } catch (ExecutionException e) {
            throw e.getCause();
        }
    }
}