a.smali

.class public final Lrx/e/a;
.super Ljava/lang/Object;
.source "Schedulers.java"


# static fields
.field private static final cal:Ljava/util/concurrent/atomic/AtomicReference;
    .annotation system Ldalvik/annotation/Signature;
        value = {
            "Ljava/util/concurrent/atomic/AtomicReference",
            "<",
            "Lrx/e/a;",
            ">;"
        }
    .end annotation
.end field


# instance fields
.field private final cdh:Lrx/j;

.field private final cdi:Lrx/j;

.field private final cdj:Lrx/j;


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

    .prologue
    .line 58
    new-instance v0, Ljava/util/concurrent/atomic/AtomicReference;

    invoke-direct {v0}, Ljava/util/concurrent/atomic/AtomicReference;-><init>()V

    sput-object v0, Lrx/e/a;->cal:Ljava/util/concurrent/atomic/AtomicReference;

    return-void
.end method

.method private constructor <init>()V
    .registers 2

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

    .line 77
    invoke-static {}, Lrx/d/f;->Ti()Lrx/d/f;

    move-result-object v0

    invoke-virtual {v0}, Lrx/d/f;->Tn()Lrx/d/g;

    .line 79
    invoke-static {}, Lrx/d/g;->Tr()Lrx/j;

    .line 83
    invoke-static {}, Lrx/d/g;->To()Lrx/j;

    move-result-object v0

    iput-object v0, p0, Lrx/e/a;->cdh:Lrx/j;

    .line 86
    invoke-static {}, Lrx/d/g;->Ts()Lrx/j;

    .line 90
    invoke-static {}, Lrx/d/g;->Tp()Lrx/j;

    move-result-object v0

    iput-object v0, p0, Lrx/e/a;->cdi:Lrx/j;

    .line 93
    invoke-static {}, Lrx/d/g;->Tt()Lrx/j;

    .line 97
    invoke-static {}, Lrx/d/g;->Tq()Lrx/j;

    move-result-object v0

    iput-object v0, p0, Lrx/e/a;->cdj:Lrx/j;

    .line 99
    return-void
.end method

.method public static Tw()Lrx/j;
    .registers 3

    .prologue
    .line 1062
    :goto_0
    sget-object v0, Lrx/e/a;->cal:Ljava/util/concurrent/atomic/AtomicReference;

    invoke-virtual {v0}, Ljava/util/concurrent/atomic/AtomicReference;->get()Ljava/lang/Object;

    move-result-object v0

    check-cast v0, Lrx/e/a;

    .line 1063
    if-eqz v0, :cond_11

    .line 160
    :cond_a
    iget-object v0, v0, Lrx/e/a;->cdi:Lrx/j;

    invoke-static {v0}, Lrx/d/c;->f(Lrx/j;)Lrx/j;

    move-result-object v0

    return-object v0

    .line 1066
    :cond_11
    new-instance v0, Lrx/e/a;

    invoke-direct {v0}, Lrx/e/a;-><init>()V

    .line 1067
    sget-object v1, Lrx/e/a;->cal:Ljava/util/concurrent/atomic/AtomicReference;

    const/4 v2, 0x0

    invoke-virtual {v1, v2, v0}, Ljava/util/concurrent/atomic/AtomicReference;->compareAndSet(Ljava/lang/Object;Ljava/lang/Object;)Z

    move-result v1

    if-nez v1, :cond_a

    .line 1070
    invoke-direct {v0}, Lrx/e/a;->Tx()V

    goto :goto_0
.end method

.method private declared-synchronized Tx()V
    .registers 2

    .prologue
    .line 242
    monitor-enter p0

    :try_start_1
    iget-object v0, p0, Lrx/e/a;->cdh:Lrx/j;

    instance-of v0, v0, Lrx/internal/schedulers/o;

    if-eqz v0, :cond_e

    .line 243
    iget-object v0, p0, Lrx/e/a;->cdh:Lrx/j;

    check-cast v0, Lrx/internal/schedulers/o;

    invoke-interface {v0}, Lrx/internal/schedulers/o;->shutdown()V

    .line 245
    :cond_e
    iget-object v0, p0, Lrx/e/a;->cdi:Lrx/j;

    instance-of v0, v0, Lrx/internal/schedulers/o;

    if-eqz v0, :cond_1b

    .line 246
    iget-object v0, p0, Lrx/e/a;->cdi:Lrx/j;

    check-cast v0, Lrx/internal/schedulers/o;

    invoke-interface {v0}, Lrx/internal/schedulers/o;->shutdown()V

    .line 248
    :cond_1b
    iget-object v0, p0, Lrx/e/a;->cdj:Lrx/j;

    instance-of v0, v0, Lrx/internal/schedulers/o;

    if-eqz v0, :cond_28

    .line 249
    iget-object v0, p0, Lrx/e/a;->cdj:Lrx/j;

    check-cast v0, Lrx/internal/schedulers/o;

    invoke-interface {v0}, Lrx/internal/schedulers/o;->shutdown()V
    :try_end_28
    .catchall {:try_start_1 .. :try_end_28} :catchall_2a

    .line 251
    :cond_28
    monitor-exit p0

    return-void

    .line 242
    :catchall_2a
    move-exception v0

    monitor-exit p0

    throw v0
.end method

.method public static b(Ljava/util/concurrent/Executor;)Lrx/j;
    .registers 2

    .prologue
    .line 181
    new-instance v0, Lrx/internal/schedulers/i;

    invoke-direct {v0, p0}, Lrx/internal/schedulers/i;-><init>(Ljava/util/concurrent/Executor;)V

    return-object v0
.end method