133 lines
4.6 KiB
Java
133 lines
4.6 KiB
Java
package f0;
|
|
|
|
import androidx.core.app.NotificationCompat;
|
|
import com.discord.models.domain.ModelAuditLogEntry;
|
|
import d0.z.d.m;
|
|
import f0.e0.b;
|
|
import f0.e0.c;
|
|
import f0.e0.g.e;
|
|
import java.io.InterruptedIOException;
|
|
import java.util.ArrayDeque;
|
|
import java.util.ArrayList;
|
|
import java.util.Deque;
|
|
import java.util.Iterator;
|
|
import java.util.Objects;
|
|
import java.util.concurrent.ExecutorService;
|
|
import java.util.concurrent.RejectedExecutionException;
|
|
import java.util.concurrent.SynchronousQueue;
|
|
import java.util.concurrent.ThreadPoolExecutor;
|
|
import java.util.concurrent.TimeUnit;
|
|
/* compiled from: Dispatcher.kt */
|
|
/* loaded from: classes3.dex */
|
|
public final class q {
|
|
public ExecutorService a;
|
|
|
|
/* renamed from: b reason: collision with root package name */
|
|
public final ArrayDeque<e.a> f3650b = new ArrayDeque<>();
|
|
public final ArrayDeque<e.a> c = new ArrayDeque<>();
|
|
public final ArrayDeque<e> d = new ArrayDeque<>();
|
|
|
|
public final synchronized void a() {
|
|
Iterator<e.a> it = this.f3650b.iterator();
|
|
while (it.hasNext()) {
|
|
it.next().l.cancel();
|
|
}
|
|
Iterator<e.a> it2 = this.c.iterator();
|
|
while (it2.hasNext()) {
|
|
it2.next().l.cancel();
|
|
}
|
|
Iterator<e> it3 = this.d.iterator();
|
|
while (it3.hasNext()) {
|
|
it3.next().cancel();
|
|
}
|
|
}
|
|
|
|
public final <T> void b(Deque<T> deque, T t) {
|
|
synchronized (this) {
|
|
if (!deque.remove(t)) {
|
|
throw new AssertionError("Call wasn't in-flight!");
|
|
}
|
|
}
|
|
d();
|
|
}
|
|
|
|
public final void c(e.a aVar) {
|
|
m.checkParameterIsNotNull(aVar, NotificationCompat.CATEGORY_CALL);
|
|
aVar.j.decrementAndGet();
|
|
b(this.c, aVar);
|
|
}
|
|
|
|
/* JADX WARN: Removed duplicated region for block: B:25:0x0067 */
|
|
/*
|
|
Code decompiled incorrectly, please refer to instructions dump.
|
|
*/
|
|
public final boolean d() {
|
|
int size;
|
|
int size2;
|
|
int i;
|
|
ExecutorService executorService;
|
|
byte[] bArr = c.a;
|
|
ArrayList arrayList = new ArrayList();
|
|
synchronized (this) {
|
|
Iterator<e.a> it = this.f3650b.iterator();
|
|
m.checkExpressionValueIsNotNull(it, "readyAsyncCalls.iterator()");
|
|
while (it.hasNext()) {
|
|
e.a next = it.next();
|
|
if (this.c.size() >= 64) {
|
|
break;
|
|
} else if (next.j.get() < 5) {
|
|
it.remove();
|
|
next.j.incrementAndGet();
|
|
m.checkExpressionValueIsNotNull(next, "asyncCall");
|
|
arrayList.add(next);
|
|
this.c.add(next);
|
|
}
|
|
}
|
|
synchronized (this) {
|
|
size = this.c.size() + this.d.size();
|
|
}
|
|
size2 = arrayList.size();
|
|
for (i = 0; i < size2; i++) {
|
|
e.a aVar = (e.a) arrayList.get(i);
|
|
synchronized (this) {
|
|
if (this.a == null) {
|
|
TimeUnit timeUnit = TimeUnit.SECONDS;
|
|
SynchronousQueue synchronousQueue = new SynchronousQueue();
|
|
String str = c.g + " Dispatcher";
|
|
m.checkParameterIsNotNull(str, ModelAuditLogEntry.CHANGE_KEY_NAME);
|
|
this.a = new ThreadPoolExecutor(0, Integer.MAX_VALUE, 60L, timeUnit, synchronousQueue, new b(str, false));
|
|
}
|
|
executorService = this.a;
|
|
if (executorService == null) {
|
|
m.throwNpe();
|
|
}
|
|
}
|
|
Objects.requireNonNull(aVar);
|
|
m.checkParameterIsNotNull(executorService, "executorService");
|
|
q qVar = aVar.l.f3591y.m;
|
|
byte[] bArr2 = c.a;
|
|
try {
|
|
try {
|
|
executorService.execute(aVar);
|
|
} catch (RejectedExecutionException e) {
|
|
InterruptedIOException interruptedIOException = new InterruptedIOException("executor rejected");
|
|
interruptedIOException.initCause(e);
|
|
aVar.l.l(interruptedIOException);
|
|
aVar.k.b(aVar.l, interruptedIOException);
|
|
aVar.l.f3591y.m.c(aVar);
|
|
}
|
|
} catch (Throwable th) {
|
|
aVar.l.f3591y.m.c(aVar);
|
|
throw th;
|
|
}
|
|
}
|
|
return r1;
|
|
}
|
|
boolean z2 = size > 0;
|
|
size2 = arrayList.size();
|
|
while (i < size2) {
|
|
}
|
|
return z2;
|
|
}
|
|
}
|