package com.ubt.jimu.video; import java.util.List; import java.util.concurrent.Callable; import java.util.concurrent.ExecutorService; /* loaded from: classes2.dex */ public class StartCompressMonitor implements Runnable { private ExecutorService a; private List> b; private OnCompressListener c; public StartCompressMonitor(ExecutorService executorService, List> list, OnCompressListener onCompressListener) { this.b = list; this.a = executorService; this.c = onCompressListener; } /* JADX WARN: Code restructure failed: missing block: B:30:0x0068, code lost: com.ubt.jimu.utils.LogUtils.c("任务被取消~~~~~~~~~~~~"); */ /* JADX WARN: Removed duplicated region for block: B:44:0x00bc */ @Override // java.lang.Runnable /* Code decompiled incorrectly, please refer to instructions dump. To view partially-correct code enable 'Show inconsistent code' option in preferences */ public void run() { /* r7 = this; java.lang.StringBuilder r0 = new java.lang.StringBuilder r0.() java.lang.String r1 = "33333333333333:" r0.append(r1) java.util.concurrent.ExecutorService r1 = r7.a r0.append(r1) java.lang.String r1 = " mCallables:" r0.append(r1) java.util.List> r1 = r7.b r0.append(r1) java.lang.String r1 = " size:" r0.append(r1) java.util.List> r1 = r7.b int r1 = r1.size() r0.append(r1) java.lang.String r0 = r0.toString() com.ubt.jimu.utils.LogUtils.c(r0) java.util.concurrent.ExecutorService r0 = r7.a r1 = 0 if (r0 == 0) goto Lc0 java.util.List> r0 = r7.b if (r0 == 0) goto Lc0 int r0 = r0.size() if (r0 != 0) goto L3f goto Lc0 L3f: java.lang.String r0 = "4444444444" com.ubt.jimu.utils.LogUtils.c(r0) r0 = 1 java.util.concurrent.ExecutorService r2 = r7.a // Catch: java.lang.Throwable -> L8b java.util.concurrent.ExecutionException -> L8d java.lang.InterruptedException -> L99 java.util.List> r3 = r7.b // Catch: java.lang.Throwable -> L8b java.util.concurrent.ExecutionException -> L8d java.lang.InterruptedException -> L99 r4 = 60000(0xea60, double:2.9644E-319) java.util.concurrent.TimeUnit r6 = java.util.concurrent.TimeUnit.MILLISECONDS // Catch: java.lang.Throwable -> L8b java.util.concurrent.ExecutionException -> L8d java.lang.InterruptedException -> L99 java.util.List r2 = r2.invokeAll(r3, r4, r6) // Catch: java.lang.Throwable -> L8b java.util.concurrent.ExecutionException -> L8d java.lang.InterruptedException -> L99 java.util.Iterator r2 = r2.iterator() // Catch: java.lang.Throwable -> L8b java.util.concurrent.ExecutionException -> L8d java.lang.InterruptedException -> L99 L56: boolean r3 = r2.hasNext() // Catch: java.lang.Throwable -> L8b java.util.concurrent.ExecutionException -> L8d java.lang.InterruptedException -> L99 if (r3 == 0) goto L7b java.lang.Object r3 = r2.next() // Catch: java.lang.Throwable -> L8b java.util.concurrent.ExecutionException -> L8d java.lang.InterruptedException -> L99 java.util.concurrent.Future r3 = (java.util.concurrent.Future) r3 // Catch: java.lang.Throwable -> L8b java.util.concurrent.ExecutionException -> L8d java.lang.InterruptedException -> L99 boolean r4 = r3.isCancelled() // Catch: java.lang.Throwable -> L8b java.util.concurrent.ExecutionException -> L8d java.lang.InterruptedException -> L99 if (r4 == 0) goto L6e java.lang.String r0 = "任务被取消~~~~~~~~~~~~" com.ubt.jimu.utils.LogUtils.c(r0) // Catch: java.util.concurrent.ExecutionException -> L8d java.lang.InterruptedException -> L99 java.lang.Throwable -> Laa goto L7c L6e: java.lang.Object r3 = r3.get() // Catch: java.lang.Throwable -> L8b java.util.concurrent.ExecutionException -> L8d java.lang.InterruptedException -> L99 com.ubt.jimu.video.Configuration r3 = (com.ubt.jimu.video.Configuration) r3 // Catch: java.lang.Throwable -> L8b java.util.concurrent.ExecutionException -> L8d java.lang.InterruptedException -> L99 com.ubt.jimu.video.Configuration$CompressState r3 = r3.d // Catch: java.lang.Throwable -> L8b java.util.concurrent.ExecutionException -> L8d java.lang.InterruptedException -> L99 com.ubt.jimu.video.Configuration$CompressState r4 = com.ubt.jimu.video.Configuration.CompressState.FAIL // Catch: java.lang.Throwable -> L8b java.util.concurrent.ExecutionException -> L8d java.lang.InterruptedException -> L99 if (r3 != r4) goto L56 goto L7c L7b: r1 = 1 L7c: if (r1 == 0) goto L86 com.ubt.jimu.video.OnCompressListener r0 = r7.c if (r0 == 0) goto L86 r0.onAllCompressSuccess() goto La9 L86: com.ubt.jimu.video.OnCompressListener r0 = r7.c if (r0 == 0) goto La9 goto L95 L8b: r1 = move-exception goto Lad L8d: r0 = move-exception r0.printStackTrace() // Catch: java.lang.Throwable -> Laa com.ubt.jimu.video.OnCompressListener r0 = r7.c if (r0 == 0) goto La9 L95: r0.onAllCompressFail() goto La9 L99: r0 = move-exception r0.printStackTrace() // Catch: java.lang.Throwable -> Laa java.lang.Thread r0 = java.lang.Thread.currentThread() // Catch: java.lang.Throwable -> Laa r0.interrupt() // Catch: java.lang.Throwable -> Laa com.ubt.jimu.video.OnCompressListener r0 = r7.c if (r0 == 0) goto La9 goto L95 La9: return Laa: r0 = move-exception r1 = r0 r0 = 0 Lad: if (r0 == 0) goto Lb8 com.ubt.jimu.video.OnCompressListener r0 = r7.c if (r0 != 0) goto Lb4 goto Lb8 Lb4: r0.onAllCompressSuccess() goto Lbf Lb8: com.ubt.jimu.video.OnCompressListener r0 = r7.c if (r0 == 0) goto Lbf r0.onAllCompressFail() Lbf: throw r1 Lc0: com.ubt.jimu.video.OnCompressListener r0 = r7.c if (r0 == 0) goto Lcf com.ubt.jimu.video.Configuration r0 = new com.ubt.jimu.video.Configuration r0.() com.ubt.jimu.video.OnCompressListener r0 = r7.c r0.onFail(r1) return Lcf: java.lang.NullPointerException r0 = new java.lang.NullPointerException java.lang.String r1 = "mThreadPoolExecutor is null | Callable is null | Callables.size() is 0" r0.(r1) throw r0 */ throw new UnsupportedOperationException("Method not decompiled: com.ubt.jimu.video.StartCompressMonitor.run():void"); } }