a.smali

.class public final Lio/reactivex/internal/schedulers/a;
.super Lio/reactivex/s;
.source "ComputationScheduler.java"


# static fields
.field private static bSh:Lio/reactivex/internal/schedulers/c;

.field private static bSi:Lio/reactivex/internal/schedulers/RxThreadFactory;

.field private static bSj:I

.field static final bSk:Lio/reactivex/internal/schedulers/d;


# instance fields
.field private bMi:Ljava/util/concurrent/ThreadFactory;

.field private bSl:Ljava/util/concurrent/atomic/AtomicReference;
    .annotation system Ldalvik/annotation/Signature;
        value = {
            "Ljava/util/concurrent/atomic/AtomicReference",
            "<",
            "Lio/reactivex/internal/schedulers/c;",
            ">;"
        }
    .end annotation
.end field


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

    .prologue
    const/4 v4, 0x1

    const/4 v3, 0x0

    .line 53
    invoke-static {}, Ljava/lang/Runtime;->getRuntime()Ljava/lang/Runtime;

    move-result-object v0

    invoke-virtual {v0}, Ljava/lang/Runtime;->availableProcessors()I

    move-result v1

    const-string v0, "rx2.computation-threads"

    invoke-static {v0, v3}, Ljava/lang/Integer;->getInteger(Ljava/lang/String;I)Ljava/lang/Integer;

    move-result-object v0

    invoke-virtual {v0}, Ljava/lang/Integer;->intValue()I

    move-result v0

    .line 1068
    if-lez v0, :cond_18

    if-le v0, v1, :cond_19

    :cond_18
    move v0, v1

    .line 53
    :cond_19
    sput v0, Lio/reactivex/internal/schedulers/a;->bSj:I

    .line 55
    new-instance v0, Lio/reactivex/internal/schedulers/d;

    new-instance v1, Lio/reactivex/internal/schedulers/RxThreadFactory;

    const-string v2, "RxComputationShutdown"

    invoke-direct {v1, v2}, Lio/reactivex/internal/schedulers/RxThreadFactory;-><init>(Ljava/lang/String;)V

    invoke-direct {v0, v1}, Lio/reactivex/internal/schedulers/d;-><init>(Ljava/util/concurrent/ThreadFactory;)V

    .line 56
    sput-object v0, Lio/reactivex/internal/schedulers/a;->bSk:Lio/reactivex/internal/schedulers/d;

    invoke-virtual {v0}, Lio/reactivex/internal/schedulers/d;->dispose()V

    .line 58
    const/16 v0, 0xa

    const-string v1, "rx2.computation-priority"

    const/4 v2, 0x5

    .line 59
    invoke-static {v1, v2}, Ljava/lang/Integer;->getInteger(Ljava/lang/String;I)Ljava/lang/Integer;

    move-result-object v1

    invoke-virtual {v1}, Ljava/lang/Integer;->intValue()I

    move-result v1

    .line 58
    invoke-static {v0, v1}, Ljava/lang/Math;->min(II)I

    move-result v0

    invoke-static {v4, v0}, Ljava/lang/Math;->max(II)I

    move-result v0

    .line 61
    new-instance v1, Lio/reactivex/internal/schedulers/RxThreadFactory;

    const-string v2, "RxComputationThreadPool"

    invoke-direct {v1, v2, v0, v4}, Lio/reactivex/internal/schedulers/RxThreadFactory;-><init>(Ljava/lang/String;IZ)V

    sput-object v1, Lio/reactivex/internal/schedulers/a;->bSi:Lio/reactivex/internal/schedulers/RxThreadFactory;

    .line 63
    new-instance v0, Lio/reactivex/internal/schedulers/c;

    sget-object v1, Lio/reactivex/internal/schedulers/a;->bSi:Lio/reactivex/internal/schedulers/RxThreadFactory;

    invoke-direct {v0, v3, v1}, Lio/reactivex/internal/schedulers/c;-><init>(ILjava/util/concurrent/ThreadFactory;)V

    .line 64
    sput-object v0, Lio/reactivex/internal/schedulers/a;->bSh:Lio/reactivex/internal/schedulers/c;

    invoke-virtual {v0}, Lio/reactivex/internal/schedulers/c;->shutdown()V

    .line 65
    return-void
.end method

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

    .prologue
    .line 126
    sget-object v0, Lio/reactivex/internal/schedulers/a;->bSi:Lio/reactivex/internal/schedulers/RxThreadFactory;

    invoke-direct {p0, v0}, Lio/reactivex/internal/schedulers/a;-><init>(Ljava/util/concurrent/ThreadFactory;)V

    .line 127
    return-void
.end method

.method private constructor <init>(Ljava/util/concurrent/ThreadFactory;)V
    .registers 4

    .prologue
    .line 136
    invoke-direct {p0}, Lio/reactivex/s;-><init>()V

    .line 137
    iput-object p1, p0, Lio/reactivex/internal/schedulers/a;->bMi:Ljava/util/concurrent/ThreadFactory;

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

    sget-object v1, Lio/reactivex/internal/schedulers/a;->bSh:Lio/reactivex/internal/schedulers/c;

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

    iput-object v0, p0, Lio/reactivex/internal/schedulers/a;->bSl:Ljava/util/concurrent/atomic/AtomicReference;

    .line 139
    invoke-virtual {p0}, Lio/reactivex/internal/schedulers/a;->start()V

    .line 140
    return-void
.end method


# virtual methods
.method public final Pv()Lio/reactivex/v;
    .registers 3

    .prologue
    .line 145
    new-instance v1, Lio/reactivex/internal/schedulers/b;

    iget-object v0, p0, Lio/reactivex/internal/schedulers/a;->bSl:Ljava/util/concurrent/atomic/AtomicReference;

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

    move-result-object v0

    check-cast v0, Lio/reactivex/internal/schedulers/c;

    invoke-virtual {v0}, Lio/reactivex/internal/schedulers/c;->PZ()Lio/reactivex/internal/schedulers/d;

    move-result-object v0

    invoke-direct {v1, v0}, Lio/reactivex/internal/schedulers/b;-><init>(Lio/reactivex/internal/schedulers/d;)V

    return-object v1
.end method

.method public final b(Ljava/lang/Runnable;JJLjava/util/concurrent/TimeUnit;)Lio/reactivex/disposables/b;
    .registers 15

    .prologue
    .line 164
    iget-object v0, p0, Lio/reactivex/internal/schedulers/a;->bSl:Ljava/util/concurrent/atomic/AtomicReference;

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

    move-result-object v0

    check-cast v0, Lio/reactivex/internal/schedulers/c;

    invoke-virtual {v0}, Lio/reactivex/internal/schedulers/c;->PZ()Lio/reactivex/internal/schedulers/d;

    move-result-object v0

    move-object v1, p1

    move-wide v2, p2

    move-wide v4, p4

    move-object v6, p6

    .line 165
    invoke-virtual/range {v0 .. v6}, Lio/reactivex/internal/schedulers/d;->b(Ljava/lang/Runnable;JJLjava/util/concurrent/TimeUnit;)Lio/reactivex/disposables/b;

    move-result-object v0

    return-object v0
.end method

.method public final b(Ljava/lang/Runnable;JLjava/util/concurrent/TimeUnit;)Lio/reactivex/disposables/b;
    .registers 7

    .prologue
    .line 157
    iget-object v0, p0, Lio/reactivex/internal/schedulers/a;->bSl:Ljava/util/concurrent/atomic/AtomicReference;

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

    move-result-object v0

    check-cast v0, Lio/reactivex/internal/schedulers/c;

    invoke-virtual {v0}, Lio/reactivex/internal/schedulers/c;->PZ()Lio/reactivex/internal/schedulers/d;

    move-result-object v0

    .line 158
    invoke-virtual {v0, p1, p2, p3, p4}, Lio/reactivex/internal/schedulers/d;->b(Ljava/lang/Runnable;JLjava/util/concurrent/TimeUnit;)Lio/reactivex/disposables/b;

    move-result-object v0

    return-object v0
.end method

.method public final start()V
    .registers 4

    .prologue
    .line 170
    new-instance v0, Lio/reactivex/internal/schedulers/c;

    sget v1, Lio/reactivex/internal/schedulers/a;->bSj:I

    iget-object v2, p0, Lio/reactivex/internal/schedulers/a;->bMi:Ljava/util/concurrent/ThreadFactory;

    invoke-direct {v0, v1, v2}, Lio/reactivex/internal/schedulers/c;-><init>(ILjava/util/concurrent/ThreadFactory;)V

    .line 171
    iget-object v1, p0, Lio/reactivex/internal/schedulers/a;->bSl:Ljava/util/concurrent/atomic/AtomicReference;

    sget-object v2, Lio/reactivex/internal/schedulers/a;->bSh:Lio/reactivex/internal/schedulers/c;

    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_16

    .line 172
    invoke-virtual {v0}, Lio/reactivex/internal/schedulers/c;->shutdown()V

    .line 174
    :cond_16
    return-void
.end method