.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 ()V .locals 2 .line 23 new-instance v0, Ljava/lang/Object; invoke-direct {v0}, Ljava/lang/Object;->()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;->(Z)V sput-object v0, Lcom/moji/tool/thread/MJThreadManager;->b:Ljava/util/concurrent/atomic/AtomicBoolean; return-void .end method .method private constructor ()V .locals 2 .line 30 invoke-direct {p0}, Ljava/lang/Object;->()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 (Lcom/moji/tool/thread/MJThreadManager$1;)V .locals 0 .line 21 invoke-direct {p0}, Lcom/moji/tool/thread/MJThreadManager;->()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;->(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;->(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;->(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;->(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;->(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;->(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;->(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;->(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;->()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;->(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;->()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