NetMirror.apk
Download file
package androidx.concurrent.futures;
import java.util.Locale;
import java.util.concurrent.CancellationException;
import java.util.concurrent.ExecutionException;
import java.util.concurrent.Executor;
import java.util.concurrent.Future;
import java.util.concurrent.ScheduledFuture;
import java.util.concurrent.TimeUnit;
import java.util.concurrent.TimeoutException;
import java.util.concurrent.atomic.AtomicReferenceFieldUpdater;
import java.util.concurrent.locks.LockSupport;
import java.util.logging.Level;
import java.util.logging.Logger;
/* JADX INFO: loaded from: classes.dex */
public abstract class a implements Future {
/* JADX INFO: renamed from: e, reason: collision with root package name */
static final boolean f4345e = Boolean.parseBoolean(System.getProperty("guava.concurrent.generate_cancellation_cause", "false"));
/* JADX INFO: renamed from: f, reason: collision with root package name */
private static final Logger f4346f = Logger.getLogger(a.class.getName());
/* JADX INFO: renamed from: g, reason: collision with root package name */
static final b f4347g;
/* JADX INFO: renamed from: h, reason: collision with root package name */
private static final Object f4348h;
/* JADX INFO: renamed from: b, reason: collision with root package name */
volatile Object f4349b;
/* JADX INFO: renamed from: c, reason: collision with root package name */
volatile e f4350c;
/* JADX INFO: renamed from: d, reason: collision with root package name */
volatile h f4351d;
private static abstract class b {
private b() {
}
abstract boolean a(a aVar, e eVar, e eVar2);
abstract boolean b(a aVar, Object obj, Object obj2);
abstract boolean c(a aVar, h hVar, h hVar2);
abstract void d(h hVar, h hVar2);
abstract void e(h hVar, Thread thread);
}
private static final class c {
/* JADX INFO: renamed from: c, reason: collision with root package name */
static final c f4352c;
/* JADX INFO: renamed from: d, reason: collision with root package name */
static final c f4353d;
/* JADX INFO: renamed from: a, reason: collision with root package name */
final boolean f4354a;
/* JADX INFO: renamed from: b, reason: collision with root package name */
final Throwable f4355b;
static {
if (a.f4345e) {
f4353d = null;
f4352c = null;
} else {
f4353d = new c(false, null);
f4352c = new c(true, null);
}
}
c(boolean z3, Throwable th) {
this.f4354a = z3;
this.f4355b = th;
}
}
private static final class d {
/* JADX INFO: renamed from: a, reason: collision with root package name */
final Throwable f4356a;
}
private static final class e {
/* JADX INFO: renamed from: d, reason: collision with root package name */
static final e f4357d = new e(null, null);
/* JADX INFO: renamed from: a, reason: collision with root package name */
final Runnable f4358a;
/* JADX INFO: renamed from: b, reason: collision with root package name */
final Executor f4359b;
/* JADX INFO: renamed from: c, reason: collision with root package name */
e f4360c;
e(Runnable runnable, Executor executor) {
this.f4358a = runnable;
this.f4359b = executor;
}
}
private static final class f extends b {
/* JADX INFO: renamed from: a, reason: collision with root package name */
final AtomicReferenceFieldUpdater f4361a;
/* JADX INFO: renamed from: b, reason: collision with root package name */
final AtomicReferenceFieldUpdater f4362b;
/* JADX INFO: renamed from: c, reason: collision with root package name */
final AtomicReferenceFieldUpdater f4363c;
/* JADX INFO: renamed from: d, reason: collision with root package name */
final AtomicReferenceFieldUpdater f4364d;
/* JADX INFO: renamed from: e, reason: collision with root package name */
final AtomicReferenceFieldUpdater f4365e;
f(AtomicReferenceFieldUpdater atomicReferenceFieldUpdater, AtomicReferenceFieldUpdater atomicReferenceFieldUpdater2, AtomicReferenceFieldUpdater atomicReferenceFieldUpdater3, AtomicReferenceFieldUpdater atomicReferenceFieldUpdater4, AtomicReferenceFieldUpdater atomicReferenceFieldUpdater5) {
super();
this.f4361a = atomicReferenceFieldUpdater;
this.f4362b = atomicReferenceFieldUpdater2;
this.f4363c = atomicReferenceFieldUpdater3;
this.f4364d = atomicReferenceFieldUpdater4;
this.f4365e = atomicReferenceFieldUpdater5;
}
@Override // androidx.concurrent.futures.a.b
boolean a(a aVar, e eVar, e eVar2) {
return androidx.concurrent.futures.b.a(this.f4364d, aVar, eVar, eVar2);
}
@Override // androidx.concurrent.futures.a.b
boolean b(a aVar, Object obj, Object obj2) {
return androidx.concurrent.futures.b.a(this.f4365e, aVar, obj, obj2);
}
@Override // androidx.concurrent.futures.a.b
boolean c(a aVar, h hVar, h hVar2) {
return androidx.concurrent.futures.b.a(this.f4363c, aVar, hVar, hVar2);
}
@Override // androidx.concurrent.futures.a.b
void d(h hVar, h hVar2) {
this.f4362b.lazySet(hVar, hVar2);
}
@Override // androidx.concurrent.futures.a.b
void e(h hVar, Thread thread) {
this.f4361a.lazySet(hVar, thread);
}
}
private static final class g extends b {
g() {
super();
}
@Override // androidx.concurrent.futures.a.b
boolean a(a aVar, e eVar, e eVar2) {
synchronized (aVar) {
try {
if (aVar.f4350c != eVar) {
return false;
}
aVar.f4350c = eVar2;
return true;
} catch (Throwable th) {
throw th;
}
}
}
@Override // androidx.concurrent.futures.a.b
boolean b(a aVar, Object obj, Object obj2) {
synchronized (aVar) {
try {
if (aVar.f4349b != obj) {
return false;
}
aVar.f4349b = obj2;
return true;
} catch (Throwable th) {
throw th;
}
}
}
@Override // androidx.concurrent.futures.a.b
boolean c(a aVar, h hVar, h hVar2) {
synchronized (aVar) {
try {
if (aVar.f4351d != hVar) {
return false;
}
aVar.f4351d = hVar2;
return true;
} catch (Throwable th) {
throw th;
}
}
}
@Override // androidx.concurrent.futures.a.b
void d(h hVar, h hVar2) {
hVar.f4368b = hVar2;
}
@Override // androidx.concurrent.futures.a.b
void e(h hVar, Thread thread) {
hVar.f4367a = thread;
}
}
private static final class h {
/* JADX INFO: renamed from: c, reason: collision with root package name */
static final h f4366c = new h(false);
/* JADX INFO: renamed from: a, reason: collision with root package name */
volatile Thread f4367a;
/* JADX INFO: renamed from: b, reason: collision with root package name */
volatile h f4368b;
h(boolean z3) {
}
void a(h hVar) {
a.f4347g.d(this, hVar);
}
void b() {
Thread thread = this.f4367a;
if (thread != null) {
this.f4367a = null;
LockSupport.unpark(thread);
}
}
h() {
a.f4347g.e(this, Thread.currentThread());
}
}
static {
b gVar;
try {
gVar = new f(AtomicReferenceFieldUpdater.newUpdater(h.class, Thread.class, "a"), AtomicReferenceFieldUpdater.newUpdater(h.class, h.class, "b"), AtomicReferenceFieldUpdater.newUpdater(a.class, h.class, "d"), AtomicReferenceFieldUpdater.newUpdater(a.class, e.class, "c"), AtomicReferenceFieldUpdater.newUpdater(a.class, Object.class, "b"));
th = null;
} catch (Throwable th) {
th = th;
gVar = new g();
}
f4347g = gVar;
if (th != null) {
f4346f.log(Level.SEVERE, "SafeAtomicHelper is broken!", th);
}
f4348h = new Object();
}
protected a() {
}
private void a(StringBuilder sb) {
try {
Object objH = h(this);
sb.append("SUCCESS, result=[");
sb.append(n(objH));
sb.append("]");
} catch (CancellationException unused) {
sb.append("CANCELLED");
} catch (RuntimeException e4) {
sb.append("UNKNOWN, cause=[");
sb.append(e4.getClass());
sb.append(" thrown from get()]");
} catch (ExecutionException e5) {
sb.append("FAILURE, cause=[");
sb.append(e5.getCause());
sb.append("]");
}
}
private static CancellationException c(String str, Throwable th) {
CancellationException cancellationException = new CancellationException(str);
cancellationException.initCause(th);
return cancellationException;
}
private e d(e eVar) {
e eVar2;
do {
eVar2 = this.f4350c;
} while (!f4347g.a(this, eVar2, e.f4357d));
e eVar3 = eVar;
e eVar4 = eVar2;
while (eVar4 != null) {
e eVar5 = eVar4.f4360c;
eVar4.f4360c = eVar3;
eVar3 = eVar4;
eVar4 = eVar5;
}
return eVar3;
}
static void e(a aVar) {
aVar.k();
aVar.b();
e eVarD = aVar.d(null);
while (eVarD != null) {
e eVar = eVarD.f4360c;
f(eVarD.f4358a, eVarD.f4359b);
eVarD = eVar;
}
}
private static void f(Runnable runnable, Executor executor) {
try {
executor.execute(runnable);
} catch (RuntimeException e4) {
f4346f.log(Level.SEVERE, "RuntimeException while executing runnable " + runnable + " with executor " + executor, (Throwable) e4);
}
}
private Object g(Object obj) throws ExecutionException {
if (obj instanceof c) {
throw c("Task was cancelled.", ((c) obj).f4355b);
}
if (obj instanceof d) {
throw new ExecutionException(((d) obj).f4356a);
}
if (obj == f4348h) {
return null;
}
return obj;
}
static Object h(Future future) {
Object obj;
boolean z3 = false;
while (true) {
try {
obj = future.get();
break;
} catch (InterruptedException unused) {
z3 = true;
} catch (Throwable th) {
if (z3) {
Thread.currentThread().interrupt();
}
throw th;
}
}
if (z3) {
Thread.currentThread().interrupt();
}
return obj;
}
private void k() {
h hVar;
do {
hVar = this.f4351d;
} while (!f4347g.c(this, hVar, h.f4366c));
while (hVar != null) {
hVar.b();
hVar = hVar.f4368b;
}
}
private void l(h hVar) {
hVar.f4367a = null;
while (true) {
h hVar2 = this.f4351d;
if (hVar2 == h.f4366c) {
return;
}
h hVar3 = null;
while (hVar2 != null) {
h hVar4 = hVar2.f4368b;
if (hVar2.f4367a != null) {
hVar3 = hVar2;
} else if (hVar3 != null) {
hVar3.f4368b = hVar4;
if (hVar3.f4367a == null) {
break;
}
} else if (!f4347g.c(this, hVar2, hVar4)) {
break;
}
hVar2 = hVar4;
}
return;
}
}
private String n(Object obj) {
return obj == this ? "this future" : String.valueOf(obj);
}
protected void b() {
}
@Override // java.util.concurrent.Future
public final boolean cancel(boolean z3) {
Object obj = this.f4349b;
if (obj == null) {
if (f4347g.b(this, obj, f4345e ? new c(z3, new CancellationException("Future.cancel() was called.")) : z3 ? c.f4352c : c.f4353d)) {
if (z3) {
i();
}
e(this);
return true;
}
}
return false;
}
@Override // java.util.concurrent.Future
public final Object get(long j3, TimeUnit timeUnit) throws InterruptedException, TimeoutException {
long nanos = timeUnit.toNanos(j3);
if (Thread.interrupted()) {
throw new InterruptedException();
}
Object obj = this.f4349b;
if (obj != null) {
return g(obj);
}
long jNanoTime = nanos > 0 ? System.nanoTime() + nanos : 0L;
if (nanos >= 1000) {
h hVar = this.f4351d;
if (hVar != h.f4366c) {
h hVar2 = new h();
do {
hVar2.a(hVar);
if (f4347g.c(this, hVar, hVar2)) {
do {
LockSupport.parkNanos(this, nanos);
if (Thread.interrupted()) {
l(hVar2);
throw new InterruptedException();
}
Object obj2 = this.f4349b;
if (obj2 != null) {
return g(obj2);
}
nanos = jNanoTime - System.nanoTime();
} while (nanos >= 1000);
l(hVar2);
} else {
hVar = this.f4351d;
}
} while (hVar != h.f4366c);
}
return g(this.f4349b);
}
while (nanos > 0) {
Object obj3 = this.f4349b;
if (obj3 != null) {
return g(obj3);
}
if (Thread.interrupted()) {
throw new InterruptedException();
}
nanos = jNanoTime - System.nanoTime();
}
String string = toString();
String string2 = timeUnit.toString();
Locale locale = Locale.ROOT;
String lowerCase = string2.toLowerCase(locale);
String str = "Waited " + j3 + " " + timeUnit.toString().toLowerCase(locale);
if (nanos + 1000 < 0) {
String str2 = str + " (plus ";
long j4 = -nanos;
long jConvert = timeUnit.convert(j4, TimeUnit.NANOSECONDS);
long nanos2 = j4 - timeUnit.toNanos(jConvert);
boolean z3 = jConvert == 0 || nanos2 > 1000;
if (jConvert > 0) {
String str3 = str2 + jConvert + " " + lowerCase;
if (z3) {
str3 = str3 + ",";
}
str2 = str3 + " ";
}
if (z3) {
str2 = str2 + nanos2 + " nanoseconds ";
}
str = str2 + "delay)";
}
if (isDone()) {
throw new TimeoutException(str + " but future completed as timeout expired");
}
throw new TimeoutException(str + " for " + string);
}
protected void i() {
}
@Override // java.util.concurrent.Future
public final boolean isCancelled() {
return this.f4349b instanceof c;
}
@Override // java.util.concurrent.Future
public final boolean isDone() {
return this.f4349b != null;
}
/* JADX WARN: Multi-variable type inference failed */
protected String j() {
if (!(this instanceof ScheduledFuture)) {
return null;
}
return "remaining delay=[" + ((ScheduledFuture) this).getDelay(TimeUnit.MILLISECONDS) + " ms]";
}
protected boolean m(Object obj) {
if (obj == null) {
obj = f4348h;
}
if (!f4347g.b(this, null, obj)) {
return false;
}
e(this);
return true;
}
public String toString() {
String strJ;
StringBuilder sb = new StringBuilder();
sb.append(super.toString());
sb.append("[status=");
if (isCancelled()) {
sb.append("CANCELLED");
} else if (isDone()) {
a(sb);
} else {
try {
strJ = j();
} catch (RuntimeException e4) {
strJ = "Exception thrown from implementation: " + e4.getClass();
}
if (strJ != null && !strJ.isEmpty()) {
sb.append("PENDING, info=[");
sb.append(strJ);
sb.append("]");
} else if (isDone()) {
a(sb);
} else {
sb.append("PENDING");
}
}
sb.append("]");
return sb.toString();
}
@Override // java.util.concurrent.Future
public final Object get() throws InterruptedException {
Object obj;
if (!Thread.interrupted()) {
Object obj2 = this.f4349b;
if (obj2 != null) {
return g(obj2);
}
h hVar = this.f4351d;
if (hVar != h.f4366c) {
h hVar2 = new h();
do {
hVar2.a(hVar);
if (f4347g.c(this, hVar, hVar2)) {
do {
LockSupport.park(this);
if (!Thread.interrupted()) {
obj = this.f4349b;
} else {
l(hVar2);
throw new InterruptedException();
}
} while (!(obj != null));
return g(obj);
}
hVar = this.f4351d;
} while (hVar != h.f4366c);
}
return g(this.f4349b);
}
throw new InterruptedException();
}
}
⚠️ This content was hidden by an advertisement filtering extension in your browser. Please disable it and reload the page to access the decompiled content.
We only display one small text ad to keep this service free. Here's what it looks like:
Read the Docs for Business: You write the docs. We do the rest.
Try it today!Ad by EthicalAds