You can not select more than 25 topics
Topics must start with a letter or number, can include dashes ('-') and can be up to 35 characters long.
126 lines
3.1 KiB
126 lines
3.1 KiB
.class public Lcom/a/g$a; |
|
.super Ljava/lang/Object; |
|
|
|
|
|
# annotations |
|
.annotation system Ldalvik/annotation/EnclosingClass; |
|
value = Lcom/a/g; |
|
.end annotation |
|
|
|
.annotation system Ldalvik/annotation/InnerClass; |
|
accessFlags = 0x9 |
|
name = "a" |
|
.end annotation |
|
|
|
|
|
# instance fields |
|
.field private final a:I |
|
|
|
.field private final b:I |
|
|
|
.field private final c:J |
|
|
|
.field private d:Ljava/util/concurrent/ThreadPoolExecutor; |
|
|
|
|
|
# direct methods |
|
.method public constructor <init>(IIJ)V |
|
.locals 1 |
|
|
|
invoke-direct {p0}, Ljava/lang/Object;-><init>()V |
|
|
|
iput p1, p0, Lcom/a/g$a;->a:I |
|
|
|
iput p2, p0, Lcom/a/g$a;->b:I |
|
|
|
iput-wide p3, p0, Lcom/a/g$a;->c:J |
|
|
|
return-void |
|
.end method |
|
|
|
.method private b()V |
|
.locals 10 |
|
|
|
iget-object v0, p0, Lcom/a/g$a;->d:Ljava/util/concurrent/ThreadPoolExecutor; |
|
|
|
if-eqz v0, :cond_0 |
|
|
|
iget-object v0, p0, Lcom/a/g$a;->d:Ljava/util/concurrent/ThreadPoolExecutor; |
|
|
|
invoke-virtual {v0}, Ljava/util/concurrent/ThreadPoolExecutor;->isShutdown()Z |
|
|
|
move-result v0 |
|
|
|
if-eqz v0, :cond_1 |
|
|
|
:cond_0 |
|
sget-object v6, Ljava/util/concurrent/TimeUnit;->MILLISECONDS:Ljava/util/concurrent/TimeUnit; |
|
|
|
new-instance v7, Ljava/util/concurrent/LinkedBlockingQueue; |
|
|
|
invoke-direct {v7}, Ljava/util/concurrent/LinkedBlockingQueue;-><init>()V |
|
|
|
invoke-static {}, Ljava/util/concurrent/Executors;->defaultThreadFactory()Ljava/util/concurrent/ThreadFactory; |
|
|
|
move-result-object v8 |
|
|
|
new-instance v9, Ljava/util/concurrent/ThreadPoolExecutor$DiscardPolicy; |
|
|
|
invoke-direct {v9}, Ljava/util/concurrent/ThreadPoolExecutor$DiscardPolicy;-><init>()V |
|
|
|
new-instance v1, Ljava/util/concurrent/ThreadPoolExecutor; |
|
|
|
iget v2, p0, Lcom/a/g$a;->a:I |
|
|
|
iget v3, p0, Lcom/a/g$a;->b:I |
|
|
|
iget-wide v4, p0, Lcom/a/g$a;->c:J |
|
|
|
invoke-direct/range {v1 .. v9}, Ljava/util/concurrent/ThreadPoolExecutor;-><init>(IIJLjava/util/concurrent/TimeUnit;Ljava/util/concurrent/BlockingQueue;Ljava/util/concurrent/ThreadFactory;Ljava/util/concurrent/RejectedExecutionHandler;)V |
|
|
|
iput-object v1, p0, Lcom/a/g$a;->d:Ljava/util/concurrent/ThreadPoolExecutor; |
|
|
|
:cond_1 |
|
return-void |
|
.end method |
|
|
|
|
|
# virtual methods |
|
.method public a()V |
|
.locals 1 |
|
|
|
iget-object v0, p0, Lcom/a/g$a;->d:Ljava/util/concurrent/ThreadPoolExecutor; |
|
|
|
if-eqz v0, :cond_0 |
|
|
|
iget-object v0, p0, Lcom/a/g$a;->d:Ljava/util/concurrent/ThreadPoolExecutor; |
|
|
|
invoke-virtual {v0}, Ljava/util/concurrent/ThreadPoolExecutor;->isShutdown()Z |
|
|
|
move-result v0 |
|
|
|
if-nez v0, :cond_0 |
|
|
|
iget-object v0, p0, Lcom/a/g$a;->d:Ljava/util/concurrent/ThreadPoolExecutor; |
|
|
|
invoke-virtual {v0}, Ljava/util/concurrent/ThreadPoolExecutor;->getQueue()Ljava/util/concurrent/BlockingQueue; |
|
|
|
move-result-object v0 |
|
|
|
invoke-interface {v0}, Ljava/util/concurrent/BlockingQueue;->clear()V |
|
|
|
:cond_0 |
|
return-void |
|
.end method |
|
|
|
.method public a(Ljava/lang/Runnable;)V |
|
.locals 1 |
|
|
|
invoke-direct {p0}, Lcom/a/g$a;->b()V |
|
|
|
iget-object v0, p0, Lcom/a/g$a;->d:Ljava/util/concurrent/ThreadPoolExecutor; |
|
|
|
invoke-virtual {v0, p1}, Ljava/util/concurrent/ThreadPoolExecutor;->execute(Ljava/lang/Runnable;)V |
|
|
|
return-void |
|
.end method
|
|
|