bp.smali
.class public final Lcom/amap/api/services/a/bp;
.super Ljava/lang/Object;
# static fields
.field private static a:Lcom/amap/api/services/a/bp;
# instance fields
.field private b:Ljava/util/concurrent/ExecutorService;
.field private c:Ljava/util/concurrent/ConcurrentHashMap;
.annotation system Ldalvik/annotation/Signature;
value = {
"Ljava/util/concurrent/ConcurrentHashMap",
"<",
"Lcom/amap/api/services/a/bq;",
"Ljava/util/concurrent/Future",
"<*>;>;"
}
.end annotation
.end field
.field private d:Lcom/amap/api/services/a/bq$a;
# direct methods
.method static constructor <clinit>()V
.registers 1
const/4 v0, 0x0
sput-object v0, Lcom/amap/api/services/a/bp;->a:Lcom/amap/api/services/a/bp;
return-void
.end method
.method private constructor <init>(I)V
.registers 5
invoke-direct {p0}, Ljava/lang/Object;-><init>()V
new-instance v0, Ljava/util/concurrent/ConcurrentHashMap;
invoke-direct {v0}, Ljava/util/concurrent/ConcurrentHashMap;-><init>()V
iput-object v0, p0, Lcom/amap/api/services/a/bp;->c:Ljava/util/concurrent/ConcurrentHashMap;
new-instance v0, Lcom/amap/api/services/a/bp$1;
invoke-direct {v0, p0}, Lcom/amap/api/services/a/bp$1;-><init>(Lcom/amap/api/services/a/bp;)V
iput-object v0, p0, Lcom/amap/api/services/a/bp;->d:Lcom/amap/api/services/a/bq$a;
:try_start_11
invoke-static {p1}, Ljava/util/concurrent/Executors;->newFixedThreadPool(I)Ljava/util/concurrent/ExecutorService;
move-result-object v0
iput-object v0, p0, Lcom/amap/api/services/a/bp;->b:Ljava/util/concurrent/ExecutorService;
:try_end_17
.catch Ljava/lang/Throwable; {:try_start_11 .. :try_end_17} :catch_18
:goto_17
return-void
:catch_18
move-exception v0
const-string/jumbo v1, "TPool"
const-string/jumbo v2, "ThreadPool"
invoke-static {v0, v1, v2}, Lcom/amap/api/services/a/t;->b(Ljava/lang/Throwable;Ljava/lang/String;Ljava/lang/String;)V
invoke-virtual {v0}, Ljava/lang/Throwable;->printStackTrace()V
goto :goto_17
.end method
.method public static declared-synchronized a(I)Lcom/amap/api/services/a/bp;
.registers 3
const-class v1, Lcom/amap/api/services/a/bp;
monitor-enter v1
:try_start_3
sget-object v0, Lcom/amap/api/services/a/bp;->a:Lcom/amap/api/services/a/bp;
if-nez v0, :cond_e
new-instance v0, Lcom/amap/api/services/a/bp;
invoke-direct {v0, p0}, Lcom/amap/api/services/a/bp;-><init>(I)V
sput-object v0, Lcom/amap/api/services/a/bp;->a:Lcom/amap/api/services/a/bp;
:cond_e
sget-object v0, Lcom/amap/api/services/a/bp;->a:Lcom/amap/api/services/a/bp;
:try_end_10
.catchall {:try_start_3 .. :try_end_10} :catchall_12
monitor-exit v1
return-object v0
:catchall_12
move-exception v0
monitor-exit v1
throw v0
.end method
.method static synthetic a(Lcom/amap/api/services/a/bp;Lcom/amap/api/services/a/bq;Z)V
.registers 3
invoke-direct {p0, p1, p2}, Lcom/amap/api/services/a/bp;->a(Lcom/amap/api/services/a/bq;Z)V
return-void
.end method
.method private declared-synchronized a(Lcom/amap/api/services/a/bq;Z)V
.registers 6
monitor-enter p0
:try_start_1
iget-object v0, p0, Lcom/amap/api/services/a/bp;->c:Ljava/util/concurrent/ConcurrentHashMap;
invoke-virtual {v0, p1}, Ljava/util/concurrent/ConcurrentHashMap;->remove(Ljava/lang/Object;)Ljava/lang/Object;
move-result-object v0
check-cast v0, Ljava/util/concurrent/Future;
if-eqz p2, :cond_11
if-eqz v0, :cond_11
const/4 v1, 0x1
invoke-interface {v0, v1}, Ljava/util/concurrent/Future;->cancel(Z)Z
:try_end_11
.catch Ljava/lang/Throwable; {:try_start_1 .. :try_end_11} :catch_13
.catchall {:try_start_1 .. :try_end_11} :catchall_21
:cond_11
:goto_11
monitor-exit p0
return-void
:catch_13
move-exception v0
:try_start_14
const-string/jumbo v1, "TPool"
const-string/jumbo v2, "removeQueue"
invoke-static {v0, v1, v2}, Lcom/amap/api/services/a/t;->b(Ljava/lang/Throwable;Ljava/lang/String;Ljava/lang/String;)V
invoke-virtual {v0}, Ljava/lang/Throwable;->printStackTrace()V
:try_end_20
.catchall {:try_start_14 .. :try_end_20} :catchall_21
goto :goto_11
:catchall_21
move-exception v0
monitor-exit p0
throw v0
.end method