.class public final Lokhttp3/internal/concurrent/TaskRunner$RealBackend; .super Ljava/lang/Object; .source "TaskRunner.kt" # interfaces .implements Lokhttp3/internal/concurrent/TaskRunner$Backend; # annotations .annotation system Ldalvik/annotation/EnclosingClass; value = Lokhttp3/internal/concurrent/TaskRunner; .end annotation .annotation system Ldalvik/annotation/InnerClass; accessFlags = 0x19 name = "RealBackend" .end annotation .annotation system Ldalvik/annotation/SourceDebugExtension; value = "SMAP\nTaskRunner.kt\nKotlin\n*S Kotlin\n*F\n+ 1 TaskRunner.kt\nokhttp3/internal/concurrent/TaskRunner$RealBackend\n+ 2 Util.kt\nokhttp3/internal/Util\n*L\n1#1,314:1\n560#2:315\n*E\n*S KotlinDebug\n*F\n+ 1 TaskRunner.kt\nokhttp3/internal/concurrent/TaskRunner$RealBackend\n*L\n281#1:315\n*E\n" .end annotation .annotation runtime Lkotlin/Metadata; bv = {} d1 = { "\u00004\n\u0002\u0018\u0002\n\u0002\u0018\u0002\n\u0002\u0018\u0002\n\u0000\n\u0002\u0018\u0002\n\u0000\n\u0002\u0010\t\n\u0002\u0008\u0004\n\u0002\u0018\u0002\n\u0002\u0008\u0003\n\u0002\u0018\u0002\n\u0002\u0008\u0002\n\u0002\u0018\u0002\n\u0002\u0008\u0004\u0018\u00002\u00020\u0001B\u000f\u0012\u0006\u0010\u0013\u001a\u00020\u0012\u00a2\u0006\u0004\u0008\u0014\u0010\u0015J\u0010\u0010\u0005\u001a\u00020\u00042\u0006\u0010\u0003\u001a\u00020\u0002H\u0016J\u0008\u0010\u0007\u001a\u00020\u0006H\u0016J\u0010\u0010\u0008\u001a\u00020\u00042\u0006\u0010\u0003\u001a\u00020\u0002H\u0016J\u0018\u0010\n\u001a\u00020\u00042\u0006\u0010\u0003\u001a\u00020\u00022\u0006\u0010\t\u001a\u00020\u0006H\u0016J\u0010\u0010\r\u001a\u00020\u00042\u0006\u0010\u000c\u001a\u00020\u000bH\u0016J\u0006\u0010\u000e\u001a\u00020\u0004R\u0014\u0010\u0010\u001a\u00020\u000f8\u0002X\u0082\u0004\u00a2\u0006\u0006\n\u0004\u0008\u0010\u0010\u0011\u00a8\u0006\u0016" } d2 = { "Lokhttp3/internal/concurrent/TaskRunner$RealBackend;", "Lokhttp3/internal/concurrent/TaskRunner$Backend;", "Lokhttp3/internal/concurrent/TaskRunner;", "taskRunner", "Lkotlin/d1;", "beforeTask", "", "nanoTime", "coordinatorNotify", "nanos", "coordinatorWait", "Ljava/lang/Runnable;", "runnable", "execute", "shutdown", "Ljava/util/concurrent/ThreadPoolExecutor;", "executor", "Ljava/util/concurrent/ThreadPoolExecutor;", "Ljava/util/concurrent/ThreadFactory;", "threadFactory", "", "(Ljava/util/concurrent/ThreadFactory;)V", "okhttp" } k = 0x1 mv = { 0x1, 0x4, 0x0 } .end annotation # instance fields .field private final executor:Ljava/util/concurrent/ThreadPoolExecutor; # direct methods .method public constructor (Ljava/util/concurrent/ThreadFactory;)V .locals 9 .param p1 # Ljava/util/concurrent/ThreadFactory; .annotation build Lorg/jetbrains/annotations/NotNull; .end annotation .end param const-string v0, "threadFactory" invoke-static {p1, v0}, Lkotlin/jvm/internal/f0;->p(Ljava/lang/Object;Ljava/lang/String;)V .line 1 invoke-direct {p0}, Ljava/lang/Object;->()V .line 2 new-instance v0, Ljava/util/concurrent/ThreadPoolExecutor; .line 3 sget-object v6, Ljava/util/concurrent/TimeUnit;->SECONDS:Ljava/util/concurrent/TimeUnit; .line 4 new-instance v7, Ljava/util/concurrent/SynchronousQueue; invoke-direct {v7}, Ljava/util/concurrent/SynchronousQueue;->()V const/4 v2, 0x0 const v3, 0x7fffffff const-wide/16 v4, 0x3c move-object v1, v0 move-object v8, p1 .line 5 invoke-direct/range {v1 .. v8}, Ljava/util/concurrent/ThreadPoolExecutor;->(IIJLjava/util/concurrent/TimeUnit;Ljava/util/concurrent/BlockingQueue;Ljava/util/concurrent/ThreadFactory;)V iput-object v0, p0, Lokhttp3/internal/concurrent/TaskRunner$RealBackend;->executor:Ljava/util/concurrent/ThreadPoolExecutor; return-void .end method # virtual methods .method public beforeTask(Lokhttp3/internal/concurrent/TaskRunner;)V .locals 1 .param p1 # Lokhttp3/internal/concurrent/TaskRunner; .annotation build Lorg/jetbrains/annotations/NotNull; .end annotation .end param const-string v0, "taskRunner" invoke-static {p1, v0}, Lkotlin/jvm/internal/f0;->p(Ljava/lang/Object;Ljava/lang/String;)V return-void .end method .method public coordinatorNotify(Lokhttp3/internal/concurrent/TaskRunner;)V .locals 1 .param p1 # Lokhttp3/internal/concurrent/TaskRunner; .annotation build Lorg/jetbrains/annotations/NotNull; .end annotation .end param const-string v0, "taskRunner" invoke-static {p1, v0}, Lkotlin/jvm/internal/f0;->p(Ljava/lang/Object;Ljava/lang/String;)V .line 1 invoke-virtual {p1}, Ljava/lang/Object;->notify()V return-void .end method .method public coordinatorWait(Lokhttp3/internal/concurrent/TaskRunner;J)V .locals 7 .param p1 # Lokhttp3/internal/concurrent/TaskRunner; .annotation build Lorg/jetbrains/annotations/NotNull; .end annotation .end param .annotation system Ldalvik/annotation/Throws; value = { Ljava/lang/InterruptedException; } .end annotation const-string v0, "taskRunner" invoke-static {p1, v0}, Lkotlin/jvm/internal/f0;->p(Ljava/lang/Object;Ljava/lang/String;)V const-wide/32 v0, 0xf4240 .line 1 div-long v2, p2, v0 mul-long/2addr v0, v2 sub-long v0, p2, v0 const-wide/16 v4, 0x0 cmp-long v6, v2, v4 if-gtz v6, :cond_0 cmp-long p2, p2, v4 if-lez p2, :cond_1 :cond_0 long-to-int p2, v0 .line 2 invoke-virtual {p1, v2, v3, p2}, Ljava/lang/Object;->wait(JI)V :cond_1 return-void .end method .method public execute(Ljava/lang/Runnable;)V .locals 1 .param p1 # Ljava/lang/Runnable; .annotation build Lorg/jetbrains/annotations/NotNull; .end annotation .end param const-string v0, "runnable" invoke-static {p1, v0}, Lkotlin/jvm/internal/f0;->p(Ljava/lang/Object;Ljava/lang/String;)V .line 1 iget-object v0, p0, Lokhttp3/internal/concurrent/TaskRunner$RealBackend;->executor:Ljava/util/concurrent/ThreadPoolExecutor; invoke-virtual {v0, p1}, Ljava/util/concurrent/ThreadPoolExecutor;->execute(Ljava/lang/Runnable;)V return-void .end method .method public nanoTime()J .locals 2 .line 1 invoke-static {}, Ljava/lang/System;->nanoTime()J move-result-wide v0 return-wide v0 .end method .method public final shutdown()V .locals 1 .line 1 iget-object v0, p0, Lokhttp3/internal/concurrent/TaskRunner$RealBackend;->executor:Ljava/util/concurrent/ThreadPoolExecutor; invoke-virtual {v0}, Ljava/util/concurrent/ThreadPoolExecutor;->shutdown()V return-void .end method