42 lines
1.4 KiB
Java
42 lines
1.4 KiB
Java
|
package o;
|
||
|
|
|
||
|
|
import com.squareup.picasso.Picasso;
|
||
|
|
import java.util.concurrent.Future;
|
||
|
|
import java.util.concurrent.FutureTask;
|
||
|
|
import java.util.concurrent.PriorityBlockingQueue;
|
||
|
|
import java.util.concurrent.ThreadPoolExecutor;
|
||
|
|
import java.util.concurrent.TimeUnit;
|
||
|
|
import o.C13025fOf;
|
||
|
|
|
||
|
|
/* loaded from: classes.dex */
|
||
|
|
public final class fNU extends ThreadPoolExecutor {
|
||
|
|
public fNU() {
|
||
|
|
super(3, 3, 0L, TimeUnit.MILLISECONDS, new PriorityBlockingQueue(), new C13025fOf.LWm());
|
||
|
|
}
|
||
|
|
|
||
|
|
@Override // java.util.concurrent.AbstractExecutorService, java.util.concurrent.ExecutorService
|
||
|
|
public final Future<?> submit(Runnable runnable) {
|
||
|
|
Sts sts = new Sts((RunnableC13011fNx) runnable);
|
||
|
|
execute(sts);
|
||
|
|
return sts;
|
||
|
|
}
|
||
|
|
|
||
|
|
/* loaded from: classes.dex */
|
||
|
|
static final class Sts extends FutureTask<RunnableC13011fNx> implements Comparable<Sts> {
|
||
|
|
private final RunnableC13011fNx d;
|
||
|
|
|
||
|
|
@Override // java.lang.Comparable
|
||
|
|
public final /* synthetic */ int compareTo(Sts sts) {
|
||
|
|
Sts sts2 = sts;
|
||
|
|
Picasso.LWm lWm = this.d.k;
|
||
|
|
Picasso.LWm lWm2 = sts2.d.k;
|
||
|
|
return lWm == lWm2 ? this.d.f9102o - sts2.d.f9102o : lWm2.ordinal() - lWm.ordinal();
|
||
|
|
}
|
||
|
|
|
||
|
|
Sts(RunnableC13011fNx runnableC13011fNx) {
|
||
|
|
super(runnableC13011fNx, null);
|
||
|
|
this.d = runnableC13011fNx;
|
||
|
|
}
|
||
|
|
}
|
||
|
|
}
|