package p037.p065.p075;

import android.os.Handler;
import android.os.HandlerThread;
import android.os.Message;
import java.util.concurrent.Callable;
import java.util.concurrent.TimeUnit;
import java.util.concurrent.atomic.AtomicBoolean;
import java.util.concurrent.atomic.AtomicReference;
import java.util.concurrent.locks.Condition;
import java.util.concurrent.locks.ReentrantLock;

/* JADX INFO: renamed from: މ.ރ.އ.ހ, reason: contains not printable characters */
/* JADX INFO: loaded from: classes.dex */
public class C1892 {

    /* JADX INFO: renamed from: ؠ, reason: contains not printable characters */
    public HandlerThread f6320;

    /* JADX INFO: renamed from: ހ, reason: contains not printable characters */
    public Handler f6321;

    /* JADX INFO: renamed from: ރ, reason: contains not printable characters */
    public final int f6324;

    /* JADX INFO: renamed from: ބ, reason: contains not printable characters */
    public final int f6325;

    /* JADX INFO: renamed from: ޅ, reason: contains not printable characters */
    public final String f6326;

    /* JADX INFO: renamed from: ֏, reason: contains not printable characters */
    public final Object f6319 = new Object();

    /* JADX INFO: renamed from: ނ, reason: contains not printable characters */
    public Handler.Callback f6323 = new C1893();

    /* JADX INFO: renamed from: ށ, reason: contains not printable characters */
    public int f6322 = 0;

    /* JADX INFO: renamed from: މ.ރ.އ.ހ$֏, reason: contains not printable characters */
    public class C1893 implements Handler.Callback {
        public C1893() {
        }

        @Override // android.os.Handler.Callback
        public boolean handleMessage(Message message) {
            int i = message.what;
            if (i == 0) {
                C1892.this.m3711();
                return true;
            }
            if (i != 1) {
                return true;
            }
            C1892.this.m3712((Runnable) message.obj);
            return true;
        }
    }

    /* JADX INFO: renamed from: މ.ރ.އ.ހ$ؠ, reason: contains not printable characters */
    public class RunnableC1894 implements Runnable {

        /* JADX INFO: renamed from: ރ, reason: contains not printable characters */
        public final /* synthetic */ AtomicReference f6328;

        /* JADX INFO: renamed from: ބ, reason: contains not printable characters */
        public final /* synthetic */ Callable f6329;

        /* JADX INFO: renamed from: ޅ, reason: contains not printable characters */
        public final /* synthetic */ ReentrantLock f6330;

        /* JADX INFO: renamed from: ކ, reason: contains not printable characters */
        public final /* synthetic */ AtomicBoolean f6331;

        /* JADX INFO: renamed from: އ, reason: contains not printable characters */
        public final /* synthetic */ Condition f6332;

        public RunnableC1894(C1892 c1892, AtomicReference atomicReference, Callable callable, ReentrantLock reentrantLock, AtomicBoolean atomicBoolean, Condition condition) {
            this.f6328 = atomicReference;
            this.f6329 = callable;
            this.f6330 = reentrantLock;
            this.f6331 = atomicBoolean;
            this.f6332 = condition;
        }

        @Override // java.lang.Runnable
        public void run() {
            try {
                this.f6328.set(this.f6329.call());
            } catch (Exception unused) {
            }
            this.f6330.lock();
            try {
                this.f6331.set(false);
                this.f6332.signal();
            } finally {
                this.f6330.unlock();
            }
        }
    }

    /* JADX INFO: renamed from: މ.ރ.އ.ހ$ހ, reason: contains not printable characters */
    public interface InterfaceC1895<T> {
        /* JADX INFO: renamed from: ֏ */
        void mo3708(T t);
    }

    public C1892(String str, int i, int i2) {
        this.f6326 = str;
        this.f6325 = i;
        this.f6324 = i2;
    }

    /* JADX INFO: renamed from: ֏, reason: contains not printable characters */
    public <T> T m3710(Callable<T> callable, int i) {
        ReentrantLock reentrantLock = new ReentrantLock();
        Condition conditionNewCondition = reentrantLock.newCondition();
        AtomicReference atomicReference = new AtomicReference();
        AtomicBoolean atomicBoolean = new AtomicBoolean(true);
        m3713(new RunnableC1894(this, atomicReference, callable, reentrantLock, atomicBoolean, conditionNewCondition));
        reentrantLock.lock();
        try {
            if (!atomicBoolean.get()) {
                return (T) atomicReference.get();
            }
            long nanos = TimeUnit.MILLISECONDS.toNanos(i);
            do {
                try {
                    nanos = conditionNewCondition.awaitNanos(nanos);
                } catch (InterruptedException unused) {
                }
                if (!atomicBoolean.get()) {
                    return (T) atomicReference.get();
                }
            } while (nanos > 0);
            throw new InterruptedException("timeout");
        } finally {
            reentrantLock.unlock();
        }
    }

    /* JADX INFO: renamed from: ֏, reason: contains not printable characters */
    public void m3711() {
        synchronized (this.f6319) {
            if (this.f6321.hasMessages(1)) {
                return;
            }
            this.f6320.quit();
            this.f6320 = null;
            this.f6321 = null;
        }
    }

    /* JADX INFO: renamed from: ֏, reason: contains not printable characters */
    public void m3712(Runnable runnable) {
        runnable.run();
        synchronized (this.f6319) {
            this.f6321.removeMessages(0);
            this.f6321.sendMessageDelayed(this.f6321.obtainMessage(0), this.f6324);
        }
    }

    /* JADX INFO: renamed from: ؠ, reason: contains not printable characters */
    public final void m3713(Runnable runnable) {
        synchronized (this.f6319) {
            if (this.f6320 == null) {
                HandlerThread handlerThread = new HandlerThread(this.f6326, this.f6325);
                this.f6320 = handlerThread;
                handlerThread.start();
                this.f6321 = new Handler(this.f6320.getLooper(), this.f6323);
                this.f6322++;
            }
            this.f6321.removeMessages(0);
            this.f6321.sendMessage(this.f6321.obtainMessage(1, runnable));
        }
    }
}