package b0;

import a.AbstractC0212a;
import com.google.firebase.messaging.w;
import java.util.concurrent.ThreadPoolExecutor;

/* JADX INFO: loaded from: classes.dex */
public final class l extends AbstractC0212a {

    /* JADX INFO: renamed from: d, reason: collision with root package name */
    public final /* synthetic */ AbstractC0212a f4645d;

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

    public l(AbstractC0212a abstractC0212a, ThreadPoolExecutor threadPoolExecutor) {
        this.f4645d = abstractC0212a;
        this.f4646e = threadPoolExecutor;
    }

    @Override // a.AbstractC0212a
    public final void B(Throwable th) {
        ThreadPoolExecutor threadPoolExecutor = this.f4646e;
        try {
            this.f4645d.B(th);
        } finally {
            threadPoolExecutor.shutdown();
        }
    }

    @Override // a.AbstractC0212a
    public final void E(w wVar) {
        ThreadPoolExecutor threadPoolExecutor = this.f4646e;
        try {
            this.f4645d.E(wVar);
        } finally {
            threadPoolExecutor.shutdown();
        }
    }
}