Weather/smali_classes3/com/moji/tool/thread/MJThreadManager.smali
2021-05-10 10:13:34 +02:00

680 lines
18 KiB
Smali

.class public Lcom/moji/tool/thread/MJThreadManager;
.super Ljava/lang/Object;
.source "MJThreadManager.java"
# annotations
.annotation system Ldalvik/annotation/MemberClasses;
value = {
Lcom/moji/tool/thread/MJThreadManager$InstanceHolder;
}
.end annotation
# static fields
.field private static final a:Ljava/lang/Object;
.field private static b:Ljava/util/concurrent/atomic/AtomicBoolean;
# instance fields
.field private c:Lcom/moji/tool/thread/executor/SerialExecutor;
.field private d:Ljava/util/concurrent/atomic/AtomicInteger;
.field private e:Landroid/support/v4/util/ArrayMap;
.annotation system Ldalvik/annotation/Signature;
value = {
"Landroid/support/v4/util/ArrayMap<",
"Ljava/lang/Integer;",
"Ljava/util/concurrent/Future;",
">;"
}
.end annotation
.end field
# direct methods
.method static constructor <clinit>()V
.locals 2
.line 23
new-instance v0, Ljava/lang/Object;
invoke-direct {v0}, Ljava/lang/Object;-><init>()V
sput-object v0, Lcom/moji/tool/thread/MJThreadManager;->a:Ljava/lang/Object;
.line 24
new-instance v0, Ljava/util/concurrent/atomic/AtomicBoolean;
const/4 v1, 0x0
invoke-direct {v0, v1}, Ljava/util/concurrent/atomic/AtomicBoolean;-><init>(Z)V
sput-object v0, Lcom/moji/tool/thread/MJThreadManager;->b:Ljava/util/concurrent/atomic/AtomicBoolean;
return-void
.end method
.method private constructor <init>()V
.locals 2
.line 30
invoke-direct {p0}, Ljava/lang/Object;-><init>()V
.line 31
sget-object v0, Lcom/moji/tool/thread/MJThreadManager;->b:Ljava/util/concurrent/atomic/AtomicBoolean;
const/4 v1, 0x0
invoke-virtual {v0, v1}, Ljava/util/concurrent/atomic/AtomicBoolean;->set(Z)V
.line 32
invoke-virtual {p0}, Lcom/moji/tool/thread/MJThreadManager;->b()V
return-void
.end method
.method synthetic constructor <init>(Lcom/moji/tool/thread/MJThreadManager$1;)V
.locals 0
.line 21
invoke-direct {p0}, Lcom/moji/tool/thread/MJThreadManager;-><init>()V
return-void
.end method
.method public static a()Lcom/moji/tool/thread/MJThreadManager;
.locals 1
.line 36
invoke-static {}, Lcom/moji/tool/thread/MJThreadManager$InstanceHolder;->a()Lcom/moji/tool/thread/MJThreadManager;
move-result-object v0
return-object v0
.end method
.method private a(Ljava/util/concurrent/FutureTask;Lcom/moji/tool/thread/ThreadType;)Ljava/util/concurrent/Future;
.locals 0
.annotation system Ldalvik/annotation/Signature;
value = {
"(",
"Ljava/util/concurrent/FutureTask<",
"*>;",
"Lcom/moji/tool/thread/ThreadType;",
")",
"Ljava/util/concurrent/Future<",
"*>;"
}
.end annotation
.line 196
invoke-static {p2}, Lcom/moji/tool/thread/executor/ExecutorFactory;->a(Lcom/moji/tool/thread/ThreadType;)Lcom/moji/tool/thread/executor/BaseExecutor;
move-result-object p2
if-nez p2, :cond_0
const/4 p1, 0x0
return-object p1
.line 200
:cond_0
invoke-interface {p2, p1}, Ljava/util/concurrent/ExecutorService;->submit(Ljava/lang/Runnable;)Ljava/util/concurrent/Future;
move-result-object p1
return-object p1
.end method
.method private a(Lcom/moji/tool/thread/wrapper/MJFutureTask;)V
.locals 2
.annotation system Ldalvik/annotation/Signature;
value = {
"(",
"Lcom/moji/tool/thread/wrapper/MJFutureTask<",
"*>;)V"
}
.end annotation
.line 224
iget-object v0, p0, Lcom/moji/tool/thread/MJThreadManager;->c:Lcom/moji/tool/thread/executor/SerialExecutor;
invoke-virtual {p1}, Lcom/moji/tool/thread/wrapper/MJFutureTask;->a()Lcom/moji/tool/thread/ThreadPriority;
move-result-object v1
invoke-virtual {v0, p1, v1}, Lcom/moji/tool/thread/executor/SerialExecutor;->a(Ljava/lang/Runnable;Lcom/moji/tool/thread/ThreadPriority;)V
return-void
.end method
.method private a(Lcom/moji/tool/thread/wrapper/MJRunnable;)V
.locals 2
.line 228
iget-object v0, p0, Lcom/moji/tool/thread/MJThreadManager;->c:Lcom/moji/tool/thread/executor/SerialExecutor;
invoke-virtual {p1}, Lcom/moji/tool/thread/wrapper/MJRunnable;->a()Lcom/moji/tool/thread/ThreadPriority;
move-result-object v1
invoke-virtual {v0, p1, v1}, Lcom/moji/tool/thread/executor/SerialExecutor;->a(Ljava/lang/Runnable;Lcom/moji/tool/thread/ThreadPriority;)V
return-void
.end method
.method private a(Lcom/moji/tool/thread/wrapper/MJThread;)V
.locals 2
.line 220
iget-object v0, p0, Lcom/moji/tool/thread/MJThreadManager;->c:Lcom/moji/tool/thread/executor/SerialExecutor;
invoke-virtual {p1}, Lcom/moji/tool/thread/wrapper/MJThread;->a()Lcom/moji/tool/thread/ThreadPriority;
move-result-object v1
invoke-virtual {v0, p1, v1}, Lcom/moji/tool/thread/executor/SerialExecutor;->a(Ljava/lang/Runnable;Lcom/moji/tool/thread/ThreadPriority;)V
return-void
.end method
.method private b(Lcom/moji/tool/thread/wrapper/MJRunnable;Lcom/moji/tool/thread/ThreadType;)V
.locals 0
.line 212
invoke-static {p2}, Lcom/moji/tool/thread/executor/ExecutorFactory;->a(Lcom/moji/tool/thread/ThreadType;)Lcom/moji/tool/thread/executor/BaseExecutor;
move-result-object p2
if-nez p2, :cond_0
return-void
.line 216
:cond_0
invoke-interface {p2, p1}, Ljava/util/concurrent/ExecutorService;->execute(Ljava/lang/Runnable;)V
return-void
.end method
.method private b(Lcom/moji/tool/thread/wrapper/MJThread;Lcom/moji/tool/thread/ThreadType;)V
.locals 0
.line 204
invoke-static {p2}, Lcom/moji/tool/thread/executor/ExecutorFactory;->a(Lcom/moji/tool/thread/ThreadType;)Lcom/moji/tool/thread/executor/BaseExecutor;
move-result-object p2
if-nez p2, :cond_0
return-void
.line 208
:cond_0
invoke-interface {p2, p1}, Ljava/util/concurrent/ExecutorService;->execute(Ljava/lang/Runnable;)V
return-void
.end method
# virtual methods
.method public a(Lcom/moji/tool/thread/wrapper/MJFutureTask;Lcom/moji/tool/thread/ThreadType;)I
.locals 4
.annotation system Ldalvik/annotation/Signature;
value = {
"(",
"Lcom/moji/tool/thread/wrapper/MJFutureTask<",
"*>;",
"Lcom/moji/tool/thread/ThreadType;",
")I"
}
.end annotation
.line 110
sget-object v0, Lcom/moji/tool/thread/MJThreadManager;->b:Ljava/util/concurrent/atomic/AtomicBoolean;
invoke-virtual {v0}, Ljava/util/concurrent/atomic/AtomicBoolean;->get()Z
move-result v0
if-eqz v0, :cond_5
if-eqz p1, :cond_4
if-nez p2, :cond_0
.line 117
sget-object p2, Lcom/moji/tool/thread/ThreadType;->NORMAL_THREAD:Lcom/moji/tool/thread/ThreadType;
.line 120
:cond_0
sget-object v0, Lcom/moji/tool/thread/ThreadType;->REAL_TIME_THREAD:Lcom/moji/tool/thread/ThreadType;
if-ne p2, v0, :cond_1
.line 121
sget-object v0, Lcom/moji/tool/thread/ThreadPriority;->REAL_TIME:Lcom/moji/tool/thread/ThreadPriority;
invoke-virtual {p1, v0}, Lcom/moji/tool/thread/wrapper/MJFutureTask;->a(Lcom/moji/tool/thread/ThreadPriority;)V
.line 124
:cond_1
invoke-virtual {p0, p1, p2}, Lcom/moji/tool/thread/MJThreadManager;->b(Lcom/moji/tool/thread/wrapper/MJFutureTask;Lcom/moji/tool/thread/ThreadType;)Ljava/util/concurrent/Future;
move-result-object p2
const/4 v0, -0x1
if-eqz p2, :cond_3
.line 127
sget-object v1, Lcom/moji/tool/thread/MJThreadManager;->a:Ljava/lang/Object;
monitor-enter v1
.line 128
:try_start_0
iget-object v0, p0, Lcom/moji/tool/thread/MJThreadManager;->d:Ljava/util/concurrent/atomic/AtomicInteger;
invoke-virtual {v0}, Ljava/util/concurrent/atomic/AtomicInteger;->get()I
move-result v0
const v2, 0x7ffffff5
const/4 v3, 0x0
if-ge v0, v2, :cond_2
.line 129
iget-object v0, p0, Lcom/moji/tool/thread/MJThreadManager;->d:Ljava/util/concurrent/atomic/AtomicInteger;
invoke-virtual {v0}, Ljava/util/concurrent/atomic/AtomicInteger;->getAndIncrement()I
move-result v0
goto :goto_0
.line 131
:cond_2
iget-object v0, p0, Lcom/moji/tool/thread/MJThreadManager;->d:Ljava/util/concurrent/atomic/AtomicInteger;
invoke-virtual {v0, v3}, Ljava/util/concurrent/atomic/AtomicInteger;->set(I)V
const/4 v0, 0x0
.line 134
:goto_0
iget-object v2, p0, Lcom/moji/tool/thread/MJThreadManager;->e:Landroid/support/v4/util/ArrayMap;
invoke-static {v0}, Ljava/lang/Integer;->valueOf(I)Ljava/lang/Integer;
move-result-object v3
invoke-virtual {v2, v3, p2}, Landroid/support/v4/util/ArrayMap;->put(Ljava/lang/Object;Ljava/lang/Object;)Ljava/lang/Object;
.line 135
invoke-virtual {p1, v0}, Lcom/moji/tool/thread/wrapper/MJFutureTask;->a(I)V
.line 136
monitor-exit v1
goto :goto_1
:catchall_0
move-exception p1
monitor-exit v1
:try_end_0
.catchall {:try_start_0 .. :try_end_0} :catchall_0
throw p1
:cond_3
:goto_1
return v0
.line 114
:cond_4
new-instance p1, Ljava/lang/NullPointerException;
const-string p2, "MJFutureTask should not be null"
invoke-direct {p1, p2}, Ljava/lang/NullPointerException;-><init>(Ljava/lang/String;)V
throw p1
.line 111
:cond_5
new-instance p1, Ljava/lang/RuntimeException;
const-string p2, "Thread pool has been shutdown"
invoke-direct {p1, p2}, Ljava/lang/RuntimeException;-><init>(Ljava/lang/String;)V
throw p1
.end method
.method public a(Lcom/moji/tool/thread/ThreadType;)Ljava/util/concurrent/ExecutorService;
.locals 0
.line 192
invoke-static {p1}, Lcom/moji/tool/thread/executor/ExecutorFactory;->a(Lcom/moji/tool/thread/ThreadType;)Lcom/moji/tool/thread/executor/BaseExecutor;
move-result-object p1
return-object p1
.end method
.method public a(I)V
.locals 2
.line 183
sget-object v0, Lcom/moji/tool/thread/MJThreadManager;->b:Ljava/util/concurrent/atomic/AtomicBoolean;
invoke-virtual {v0}, Ljava/util/concurrent/atomic/AtomicBoolean;->get()Z
move-result v0
if-eqz v0, :cond_1
if-gez p1, :cond_0
goto :goto_0
.line 186
:cond_0
sget-object v0, Lcom/moji/tool/thread/MJThreadManager;->a:Ljava/lang/Object;
monitor-enter v0
.line 187
:try_start_0
iget-object v1, p0, Lcom/moji/tool/thread/MJThreadManager;->e:Landroid/support/v4/util/ArrayMap;
invoke-static {p1}, Ljava/lang/Integer;->valueOf(I)Ljava/lang/Integer;
move-result-object p1
invoke-virtual {v1, p1}, Landroid/support/v4/util/ArrayMap;->remove(Ljava/lang/Object;)Ljava/lang/Object;
.line 188
monitor-exit v0
return-void
:catchall_0
move-exception p1
monitor-exit v0
:try_end_0
.catchall {:try_start_0 .. :try_end_0} :catchall_0
throw p1
:cond_1
:goto_0
return-void
.end method
.method public a(Lcom/moji/tool/thread/wrapper/MJRunnable;Lcom/moji/tool/thread/ThreadType;)V
.locals 1
.line 88
sget-object v0, Lcom/moji/tool/thread/MJThreadManager;->b:Ljava/util/concurrent/atomic/AtomicBoolean;
invoke-virtual {v0}, Ljava/util/concurrent/atomic/AtomicBoolean;->get()Z
move-result v0
if-eqz v0, :cond_4
if-eqz p1, :cond_3
if-nez p2, :cond_0
.line 95
sget-object p2, Lcom/moji/tool/thread/ThreadType;->NORMAL_THREAD:Lcom/moji/tool/thread/ThreadType;
.line 98
:cond_0
sget-object v0, Lcom/moji/tool/thread/ThreadType;->REAL_TIME_THREAD:Lcom/moji/tool/thread/ThreadType;
if-ne p2, v0, :cond_1
.line 99
sget-object v0, Lcom/moji/tool/thread/ThreadPriority;->REAL_TIME:Lcom/moji/tool/thread/ThreadPriority;
invoke-virtual {p1, v0}, Lcom/moji/tool/thread/wrapper/MJRunnable;->a(Lcom/moji/tool/thread/ThreadPriority;)V
.line 102
:cond_1
sget-object v0, Lcom/moji/tool/thread/ThreadType;->SERIAL_THREAD:Lcom/moji/tool/thread/ThreadType;
if-eq p2, v0, :cond_2
.line 103
invoke-direct {p0, p1, p2}, Lcom/moji/tool/thread/MJThreadManager;->b(Lcom/moji/tool/thread/wrapper/MJRunnable;Lcom/moji/tool/thread/ThreadType;)V
goto :goto_0
.line 105
:cond_2
invoke-direct {p0, p1}, Lcom/moji/tool/thread/MJThreadManager;->a(Lcom/moji/tool/thread/wrapper/MJRunnable;)V
:goto_0
return-void
.line 92
:cond_3
new-instance p1, Ljava/lang/NullPointerException;
const-string p2, "MJRunnable should not be null"
invoke-direct {p1, p2}, Ljava/lang/NullPointerException;-><init>(Ljava/lang/String;)V
throw p1
.line 89
:cond_4
new-instance p1, Ljava/lang/RuntimeException;
const-string p2, "Thread pool has been shutdown"
invoke-direct {p1, p2}, Ljava/lang/RuntimeException;-><init>(Ljava/lang/String;)V
throw p1
.end method
.method public a(Lcom/moji/tool/thread/wrapper/MJThread;Lcom/moji/tool/thread/ThreadType;)V
.locals 1
.line 66
sget-object v0, Lcom/moji/tool/thread/MJThreadManager;->b:Ljava/util/concurrent/atomic/AtomicBoolean;
invoke-virtual {v0}, Ljava/util/concurrent/atomic/AtomicBoolean;->get()Z
move-result v0
if-eqz v0, :cond_4
if-eqz p1, :cond_3
if-nez p2, :cond_0
.line 73
sget-object p2, Lcom/moji/tool/thread/ThreadType;->NORMAL_THREAD:Lcom/moji/tool/thread/ThreadType;
.line 76
:cond_0
sget-object v0, Lcom/moji/tool/thread/ThreadType;->REAL_TIME_THREAD:Lcom/moji/tool/thread/ThreadType;
if-ne p2, v0, :cond_1
.line 77
sget-object v0, Lcom/moji/tool/thread/ThreadPriority;->REAL_TIME:Lcom/moji/tool/thread/ThreadPriority;
invoke-virtual {p1, v0}, Lcom/moji/tool/thread/wrapper/MJThread;->a(Lcom/moji/tool/thread/ThreadPriority;)V
.line 80
:cond_1
sget-object v0, Lcom/moji/tool/thread/ThreadType;->SERIAL_THREAD:Lcom/moji/tool/thread/ThreadType;
if-eq p2, v0, :cond_2
.line 81
invoke-direct {p0, p1, p2}, Lcom/moji/tool/thread/MJThreadManager;->b(Lcom/moji/tool/thread/wrapper/MJThread;Lcom/moji/tool/thread/ThreadType;)V
goto :goto_0
.line 83
:cond_2
invoke-direct {p0, p1}, Lcom/moji/tool/thread/MJThreadManager;->a(Lcom/moji/tool/thread/wrapper/MJThread;)V
:goto_0
return-void
.line 70
:cond_3
new-instance p1, Ljava/lang/NullPointerException;
const-string p2, "MJThread should not be null"
invoke-direct {p1, p2}, Ljava/lang/NullPointerException;-><init>(Ljava/lang/String;)V
throw p1
.line 67
:cond_4
new-instance p1, Ljava/lang/RuntimeException;
const-string p2, "Thread pool has been shutdown"
invoke-direct {p1, p2}, Ljava/lang/RuntimeException;-><init>(Ljava/lang/String;)V
throw p1
.end method
.method public b(Lcom/moji/tool/thread/wrapper/MJFutureTask;Lcom/moji/tool/thread/ThreadType;)Ljava/util/concurrent/Future;
.locals 1
.annotation system Ldalvik/annotation/Signature;
value = {
"(",
"Lcom/moji/tool/thread/wrapper/MJFutureTask<",
"*>;",
"Lcom/moji/tool/thread/ThreadType;",
")",
"Ljava/util/concurrent/Future<",
"*>;"
}
.end annotation
.line 142
sget-object v0, Lcom/moji/tool/thread/MJThreadManager;->b:Ljava/util/concurrent/atomic/AtomicBoolean;
invoke-virtual {v0}, Ljava/util/concurrent/atomic/AtomicBoolean;->get()Z
move-result v0
if-eqz v0, :cond_4
if-eqz p1, :cond_3
if-nez p2, :cond_0
.line 149
sget-object p2, Lcom/moji/tool/thread/ThreadType;->NORMAL_THREAD:Lcom/moji/tool/thread/ThreadType;
.line 152
:cond_0
sget-object v0, Lcom/moji/tool/thread/ThreadType;->REAL_TIME_THREAD:Lcom/moji/tool/thread/ThreadType;
if-ne p2, v0, :cond_1
.line 153
sget-object v0, Lcom/moji/tool/thread/ThreadPriority;->REAL_TIME:Lcom/moji/tool/thread/ThreadPriority;
invoke-virtual {p1, v0}, Lcom/moji/tool/thread/wrapper/MJFutureTask;->a(Lcom/moji/tool/thread/ThreadPriority;)V
.line 156
:cond_1
sget-object v0, Lcom/moji/tool/thread/ThreadType;->SERIAL_THREAD:Lcom/moji/tool/thread/ThreadType;
if-ne p2, v0, :cond_2
.line 157
invoke-direct {p0, p1}, Lcom/moji/tool/thread/MJThreadManager;->a(Lcom/moji/tool/thread/wrapper/MJFutureTask;)V
const/4 p1, 0x0
return-object p1
.line 160
:cond_2
invoke-direct {p0, p1, p2}, Lcom/moji/tool/thread/MJThreadManager;->a(Ljava/util/concurrent/FutureTask;Lcom/moji/tool/thread/ThreadType;)Ljava/util/concurrent/Future;
move-result-object p1
return-object p1
.line 146
:cond_3
new-instance p1, Ljava/lang/NullPointerException;
const-string p2, "FutureTask should not be null"
invoke-direct {p1, p2}, Ljava/lang/NullPointerException;-><init>(Ljava/lang/String;)V
throw p1
.line 143
:cond_4
new-instance p1, Ljava/lang/RuntimeException;
const-string p2, "Thread pool has been shutdown"
invoke-direct {p1, p2}, Ljava/lang/RuntimeException;-><init>(Ljava/lang/String;)V
throw p1
.end method
.method public b()V
.locals 2
.line 44
new-instance v0, Lcom/moji/tool/thread/executor/SerialExecutor;
invoke-direct {v0}, Lcom/moji/tool/thread/executor/SerialExecutor;-><init>()V
iput-object v0, p0, Lcom/moji/tool/thread/MJThreadManager;->c:Lcom/moji/tool/thread/executor/SerialExecutor;
.line 45
new-instance v0, Ljava/util/concurrent/atomic/AtomicInteger;
const/4 v1, 0x0
invoke-direct {v0, v1}, Ljava/util/concurrent/atomic/AtomicInteger;-><init>(I)V
iput-object v0, p0, Lcom/moji/tool/thread/MJThreadManager;->d:Ljava/util/concurrent/atomic/AtomicInteger;
.line 46
new-instance v0, Landroid/support/v4/util/ArrayMap;
invoke-direct {v0}, Landroid/support/v4/util/ArrayMap;-><init>()V
iput-object v0, p0, Lcom/moji/tool/thread/MJThreadManager;->e:Landroid/support/v4/util/ArrayMap;
.line 47
sget-object v0, Lcom/moji/tool/thread/MJThreadManager;->b:Ljava/util/concurrent/atomic/AtomicBoolean;
const/4 v1, 0x1
invoke-virtual {v0, v1}, Ljava/util/concurrent/atomic/AtomicBoolean;->set(Z)V
return-void
.end method