E  java/lang/Object()V+java/util/concurrent/atomic/AtomicReference  Lnet/minecraft/util/thread/AbstractConsecutiveExecutor$Status;  (Ljava/lang/Object;)V  5net/minecraft/util/thread/AbstractConsecutiveExecutorstatus-Ljava/util/concurrent/atomic/AtomicReference;  executorLjava/util/concurrent/Executor;  queue'Lnet/minecraft/util/thread/StrictQueue; ! "#nameLjava/lang/String; %&' ()4net/minecraft/util/profiling/metrics/MetricsRegistryINSTANCE6Lnet/minecraft/util/profiling/metrics/MetricsRegistry; %+ ,-add:(Lnet/minecraft/util/profiling/metrics/ProfilerMeasured;)V / 01isClosed()Z 345 61%net/minecraft/util/thread/StrictQueueisEmpty 8 9CLOSED ; <set > ?1 isRunning 3A BCpop()Ljava/lang/Runnable; EFG HInet/minecraft/util/UtilrunNamed)(Ljava/lang/Runnable;Ljava/lang/String;)V K L1pollTask N O setSleeping Q RregisterForExecution 3T UVpush(Ljava/lang/Runnable;)Z X Y1canBeScheduled [ \1 setRunning ^_` abjava/util/concurrent/Executorexecute(Ljava/lang/Runnable;)Vd/java/util/concurrent/RejectedExecutionException f ghLOGGERLorg/slf4j/Logger;j&Could not schedule ConsecutiveExecutor lmn oporg/slf4j/Loggererror*(Ljava/lang/String;Ljava/lang/Throwable;)V 3r stsize()I v wxget()Ljava/lang/Object; z{| }~java/lang/StringvalueOf&(Ljava/lang/Object;)Ljava/lang/String; makeConcatWithConstants9(Ljava/lang/String;Ljava/lang/String;Z)Ljava/lang/String; &(Ljava/lang/String;)Ljava/lang/String;  3net/minecraft/util/profiling/metrics/MetricCategoryCONSECUTIVE_EXECUTORS5Lnet/minecraft/util/profiling/metrics/MetricCategory;  getAsDouble\(Lnet/minecraft/util/thread/AbstractConsecutiveExecutor;)Ljava/util/function/DoubleSupplier;  2net/minecraft/util/profiling/metrics/MetricSamplercreate(Ljava/lang/String;Lnet/minecraft/util/profiling/metrics/MetricCategory;Ljava/util/function/DoubleSupplier;)Lnet/minecraft/util/profiling/metrics/MetricSampler;  'com/google/common/collect/ImmutableListof=(Ljava/lang/Object;)Lcom/google/common/collect/ImmutableList; RUNNING   compareAndSet'(Ljava/lang/Object;Ljava/lang/Object;)Z  com/mojang/logging/LogUtils getLogger()Lorg/slf4j/Logger;java/lang/Runnable'net/minecraft/util/thread/TaskScheduler5net/minecraft/util/profiling/metrics/ProfilerMeasured SignaturemLjava/util/concurrent/atomic/AtomicReference;,Lnet/minecraft/util/thread/StrictQueue;[(Lnet/minecraft/util/thread/StrictQueue;Ljava/util/concurrent/Executor;Ljava/lang/String;)VCodeLineNumberTableLocalVariableTablethis7Lnet/minecraft/util/thread/AbstractConsecutiveExecutor;LocalVariableTypeTable;MethodParameters`(Lnet/minecraft/util/thread/StrictQueue;Ljava/util/concurrent/Executor;Ljava/lang/String;)V StackMapTablecloserunnableLjava/lang/Runnable;runjava/lang/ThrowablerunAllscheduletaskTT;(TT;)Ve21Ljava/util/concurrent/RejectedExecutionException;ehasWorktoString()Ljava/lang/String;profiledMetrics()Ljava/util/List;H()Ljava/util/List;Ljava/lang/Object;Ljava/lang/Runnable;Lnet/minecraft/util/thread/TaskScheduler;Lnet/minecraft/util/profiling/metrics/ProfilerMeasured; SourceFile AbstractConsecutiveExecutor.java NestMembersBootstrapMethods   -queue-size()D r  $java/lang/invoke/StringConcatFactory(Ljava/lang/invoke/MethodHandles$Lookup;Ljava/lang/String;Ljava/lang/invoke/MethodType;Ljava/lang/String;[Ljava/lang/Object;)Ljava/lang/invoke/CallSite;  "java/lang/invoke/LambdaMetafactory metafactory(Ljava/lang/invoke/MethodHandles$Lookup;Ljava/lang/String;Ljava/lang/invoke/MethodType;Ljava/lang/invoke/MethodType;Ljava/lang/invoke/MethodHandle;Ljava/lang/invoke/MethodType;)Ljava/lang/invoke/CallSite; InnerClassesStatus%java/lang/invoke/MethodHandles$Lookupjava/lang/invoke/MethodHandlesLookup!gh"#)**Y *,*+*- $**!(*))))"#)) "Y1`*.*2  @K *7: % &   L1#*=*@L++* D)* -./2!4# #  *JW*M*PL*M*P+"<> ? @>?@A  P !*J*M*PL*M*P+ "H KLMKLM N ! !  J bh*+SW*PR STR6*W1*Z***]L**]Mei,kc&)c* WXZb[^&a)_*`5e * 6 6[c cc stF *qh   1`*=*2l  @Y* *uy*2q  "A* v  ]* *{|{  \1J*   OO* W   ?1Z*u  @01Z*u7  @e  @