Currency Plus v2.10.8版本的 MD5 值为：8586f74edd9ace5aa261a19c9da51484

以下内容为反编译后的 b.java 源代码，内容仅作参考

package v5;

import android.os.Handler;
import android.os.Looper;
import android.os.SystemClock;
import fi.a0;
import java.util.concurrent.Executor;
import java.util.concurrent.TimeUnit;
public final class b {
    public b6.d f32687a;
    public final Handler f32688b;
    public Runnable f32689c;
    public final Object f32690d;
    public final long f32691e;
    public final Executor f32692f;
    public int f32693g;
    public final long f32694h;
    public b6.c f32695i;
    public boolean f32696j;
    public final v5.a f32697k;
    public final v5.a f32698l;

    public static final class a {
        public a(ti.g gVar) {
        }
    }

    static {
        new a(null);
    }

    public b(long j10, TimeUnit timeUnit, Executor executor) {
        ti.l.f(timeUnit, "autoCloseTimeUnit");
        ti.l.f(executor, "autoCloseExecutor");
        this.f32688b = new Handler(Looper.getMainLooper());
        this.f32690d = new Object();
        this.f32691e = timeUnit.toMillis(j10);
        this.f32692f = executor;
        this.f32694h = SystemClock.uptimeMillis();
        this.f32697k = new Runnable(this) {
            public final b f32686b;

            {
                this.f32686b = this;
            }

            @Override
            public final void run() {
                a0 a0Var;
                switch (r2) {
                    case 0:
                        b bVar = this.f32686b;
                        ti.l.f(bVar, "this$0");
                        bVar.f32692f.execute(bVar.f32698l);
                        return;
                    default:
                        b bVar2 = this.f32686b;
                        ti.l.f(bVar2, "this$0");
                        synchronized (bVar2.f32690d) {
                            try {
                                if (SystemClock.uptimeMillis() - bVar2.f32694h < bVar2.f32691e) {
                                    return;
                                }
                                if (bVar2.f32693g != 0) {
                                    return;
                                }
                                Runnable runnable = bVar2.f32689c;
                                if (runnable != null) {
                                    runnable.run();
                                    a0Var = a0.f17744a;
                                } else {
                                    a0Var = null;
                                }
                                if (a0Var == null) {
                                    throw new IllegalStateException("onAutoCloseCallback is null but it should have been set before use. Please file a bug against Room at: https://issuetracker.google.com/issues/new?component=413107&template=1096568".toString());
                                }
                                b6.c cVar = bVar2.f32695i;
                                if (cVar != null && cVar.isOpen()) {
                                    cVar.close();
                                }
                                bVar2.f32695i = null;
                                a0 a0Var2 = a0.f17744a;
                                return;
                            } catch (Throwable th2) {
                                throw th2;
                            }
                        }
                }
            }
        };
        this.f32698l = new Runnable(this) {
            public final b f32686b;

            {
                this.f32686b = this;
            }

            @Override
            public final void run() {
                a0 a0Var;
                switch (r2) {
                    case 0:
                        b bVar = this.f32686b;
                        ti.l.f(bVar, "this$0");
                        bVar.f32692f.execute(bVar.f32698l);
                        return;
                    default:
                        b bVar2 = this.f32686b;
                        ti.l.f(bVar2, "this$0");
                        synchronized (bVar2.f32690d) {
                            try {
                                if (SystemClock.uptimeMillis() - bVar2.f32694h < bVar2.f32691e) {
                                    return;
                                }
                                if (bVar2.f32693g != 0) {
                                    return;
                                }
                                Runnable runnable = bVar2.f32689c;
                                if (runnable != null) {
                                    runnable.run();
                                    a0Var = a0.f17744a;
                                } else {
                                    a0Var = null;
                                }
                                if (a0Var == null) {
                                    throw new IllegalStateException("onAutoCloseCallback is null but it should have been set before use. Please file a bug against Room at: https://issuetracker.google.com/issues/new?component=413107&template=1096568".toString());
                                }
                                b6.c cVar = bVar2.f32695i;
                                if (cVar != null && cVar.isOpen()) {
                                    cVar.close();
                                }
                                bVar2.f32695i = null;
                                a0 a0Var2 = a0.f17744a;
                                return;
                            } catch (Throwable th2) {
                                throw th2;
                            }
                        }
                }
            }
        };
    }

    public final void a() {
        synchronized (this.f32690d) {
            try {
                int i10 = this.f32693g;
                if (i10 <= 0) {
                    throw new IllegalStateException("ref count is 0 or lower but we're supposed to decrement".toString());
                }
                int i11 = i10 - 1;
                this.f32693g = i11;
                if (i11 == 0) {
                    if (this.f32695i == null) {
                        return;
                    }
                    this.f32688b.postDelayed(this.f32697k, this.f32691e);
                }
                a0 a0Var = a0.f17744a;
            } catch (Throwable th2) {
                throw th2;
            }
        }
    }

    public final <V> V b(si.l<? super b6.c, ? extends V> lVar) {
        ti.l.f(lVar, "block");
        try {
            return lVar.invoke(c());
        } finally {
            a();
        }
    }

    public final b6.c c() {
        synchronized (this.f32690d) {
            this.f32688b.removeCallbacks(this.f32697k);
            this.f32693g++;
            if (!this.f32696j) {
                b6.c cVar = this.f32695i;
                if (cVar == null || !cVar.isOpen()) {
                    b6.d dVar = this.f32687a;
                    if (dVar == null) {
                        ti.l.l("delegateOpenHelper");
                        throw null;
                    }
                    b6.c t02 = dVar.t0();
                    this.f32695i = t02;
                    return t02;
                }
                return cVar;
            }
            throw new IllegalStateException("Attempting to open already closed database.".toString());
        }
    }
}