com-dot-app-sancharsaathi-1-5-0.apk

Download file
    package I3;

import D3.F;
import D3.H;
import D3.O;
import D3.Q;
import java.util.concurrent.atomic.AtomicIntegerFieldUpdater;
import l3.i;
import l3.j;

/* renamed from: I3.m  reason: case insensitive filesystem */
public final class C0284m extends F implements Q {

    /* renamed from: l  reason: collision with root package name */
    public static final AtomicIntegerFieldUpdater f1559l = AtomicIntegerFieldUpdater.newUpdater(C0284m.class, "runningWorkers");

    /* renamed from: g  reason: collision with root package name */
    public final F f1560g;

    /* renamed from: h  reason: collision with root package name */
    public final int f1561h;

    /* renamed from: i  reason: collision with root package name */
    public final /* synthetic */ Q f1562i;

    /* renamed from: j  reason: collision with root package name */
    public final r f1563j;

    /* renamed from: k  reason: collision with root package name */
    public final Object f1564k;
    private volatile int runningWorkers;

    /* renamed from: I3.m$a */
    public final class a implements Runnable {

        /* renamed from: e  reason: collision with root package name */
        public Runnable f1565e;

        public a(Runnable runnable) {
            this.f1565e = runnable;
        }

        public void run() {
            int i4 = 0;
            while (true) {
                try {
                    this.f1565e.run();
                } catch (Throwable th) {
                    H.a(j.f11131e, th);
                }
                Runnable O4 = C0284m.this.P();
                if (O4 != null) {
                    this.f1565e = O4;
                    i4++;
                    if (i4 >= 16 && C0284m.this.f1560g.L(C0284m.this)) {
                        C0284m.this.f1560g.K(C0284m.this, this);
                        return;
                    }
                } else {
                    return;
                }
            }
        }
    }

    public C0284m(F f4, int i4) {
        this.f1560g = f4;
        this.f1561h = i4;
        Q q4 = f4 instanceof Q ? (Q) f4 : null;
        this.f1562i = q4 == null ? O.a() : q4;
        this.f1563j = new r(false);
        this.f1564k = new Object();
    }

    public void K(i iVar, Runnable runnable) {
        Runnable P4;
        this.f1563j.a(runnable);
        if (f1559l.get(this) < this.f1561h && Q() && (P4 = P()) != null) {
            this.f1560g.K(this, new a(P4));
        }
    }

    public final Runnable P() {
        while (true) {
            Runnable runnable = (Runnable) this.f1563j.d();
            if (runnable != null) {
                return runnable;
            }
            synchronized (this.f1564k) {
                AtomicIntegerFieldUpdater atomicIntegerFieldUpdater = f1559l;
                atomicIntegerFieldUpdater.decrementAndGet(this);
                if (this.f1563j.c() == 0) {
                    return null;
                }
                atomicIntegerFieldUpdater.incrementAndGet(this);
            }
        }
    }

    public final boolean Q() {
        synchronized (this.f1564k) {
            AtomicIntegerFieldUpdater atomicIntegerFieldUpdater = f1559l;
            if (atomicIntegerFieldUpdater.get(this) >= this.f1561h) {
                return false;
            }
            atomicIntegerFieldUpdater.incrementAndGet(this);
            return true;
        }
    }
}
    
Download file