package T1;

import C0.J;
import java.util.concurrent.ThreadPoolExecutor;

/* JADX INFO: loaded from: classes.dex */
public final class j extends L4.a {

    /* JADX INFO: renamed from: e, reason: collision with root package name */
    public final /* synthetic */ L4.a f6595e;

    /* JADX INFO: renamed from: f, reason: collision with root package name */
    public final /* synthetic */ ThreadPoolExecutor f6596f;

    public j(L4.a aVar, ThreadPoolExecutor threadPoolExecutor) {
        this.f6595e = aVar;
        this.f6596f = threadPoolExecutor;
    }

    @Override // L4.a
    public final void Z(Throwable th) {
        ThreadPoolExecutor threadPoolExecutor = this.f6596f;
        try {
            this.f6595e.Z(th);
        } finally {
            threadPoolExecutor.shutdown();
        }
    }

    @Override // L4.a
    public final void a0(J j4) {
        ThreadPoolExecutor threadPoolExecutor = this.f6596f;
        try {
            this.f6595e.a0(j4);
        } finally {
            threadPoolExecutor.shutdown();
        }
    }
}
