q.smali

.class public final Lcom/baidu/techain/y/q;
.super Ljava/lang/Object;


# annotations
.annotation system Ldalvik/annotation/MemberClasses;
    value = {
        Lcom/baidu/techain/y/q$a;
    }
.end annotation


# static fields
.field private static b:Lcom/baidu/techain/y/q;

.field private static c:Lcom/baidu/techain/y/q;


# instance fields
.field private a:Ljava/util/concurrent/ThreadPoolExecutor;


# direct methods
.method static constructor <clinit>()V
    .registers 1

    new-instance v0, Lcom/baidu/techain/y/q;

    invoke-direct {v0}, Lcom/baidu/techain/y/q;-><init>()V

    sput-object v0, Lcom/baidu/techain/y/q;->b:Lcom/baidu/techain/y/q;

    new-instance v0, Lcom/baidu/techain/y/q;

    invoke-direct {v0}, Lcom/baidu/techain/y/q;-><init>()V

    sput-object v0, Lcom/baidu/techain/y/q;->c:Lcom/baidu/techain/y/q;

    return-void
.end method

.method public constructor <init>()V
    .registers 9

    invoke-direct {p0}, Ljava/lang/Object;-><init>()V

    new-instance v7, Ljava/util/concurrent/LinkedBlockingQueue;

    const/16 v0, 0x1388

    invoke-direct {v7, v0}, Ljava/util/concurrent/LinkedBlockingQueue;-><init>(I)V

    new-instance v1, Ljava/util/concurrent/ThreadPoolExecutor;

    const/4 v2, 0x0

    const/4 v3, 0x1

    const-wide/32 v4, 0xea60

    sget-object v6, Ljava/util/concurrent/TimeUnit;->MILLISECONDS:Ljava/util/concurrent/TimeUnit;

    invoke-direct/range {v1 .. v7}, Ljava/util/concurrent/ThreadPoolExecutor;-><init>(IIJLjava/util/concurrent/TimeUnit;Ljava/util/concurrent/BlockingQueue;)V

    iput-object v1, p0, Lcom/baidu/techain/y/q;->a:Ljava/util/concurrent/ThreadPoolExecutor;

    return-void
.end method

.method public static a()Lcom/baidu/techain/y/q;
    .registers 1

    sget-object v0, Lcom/baidu/techain/y/q;->b:Lcom/baidu/techain/y/q;

    return-object v0
.end method

.method public static b()Lcom/baidu/techain/y/q;
    .registers 1

    sget-object v0, Lcom/baidu/techain/y/q;->c:Lcom/baidu/techain/y/q;

    return-object v0
.end method


# virtual methods
.method public final a(Lcom/baidu/techain/y/l;)V
    .registers 4

    :try_start_0
    iget-object v0, p0, Lcom/baidu/techain/y/q;->a:Ljava/util/concurrent/ThreadPoolExecutor;

    new-instance v1, Lcom/baidu/techain/y/q$a;

    invoke-direct {v1, p1}, Lcom/baidu/techain/y/q$a;-><init>(Ljava/lang/Runnable;)V

    invoke-virtual {v0, v1}, Ljava/util/concurrent/ThreadPoolExecutor;->execute(Ljava/lang/Runnable;)V
    :try_end_a
    .catch Ljava/util/concurrent/RejectedExecutionException; {:try_start_0 .. :try_end_a} :catch_b

    :goto_a
    return-void

    :catch_b
    move-exception v0

    const-string v0, "TaskThread"

    const-string v1, "addToQueue(): RejectedExecutionException: queue is full"

    invoke-static {v0, v1}, Lcom/baidu/techain/s/b;->c(Ljava/lang/String;Ljava/lang/String;)V

    goto :goto_a
.end method