Eb  java/lang/Object()V1net/minecraft/server/level/ChunkTaskPriorityQueue  'net/minecraft/util/thread/TaskSchedulername()Ljava/lang/String; makeConcatWithConstants&(Ljava/lang/String;)Ljava/lang/String;  (Ljava/lang/String;)V  .net/minecraft/server/level/ChunkTaskDispatcherqueue3Lnet/minecraft/server/level/ChunkTaskPriorityQueue;  executor)Lnet/minecraft/util/thread/TaskScheduler;!5net/minecraft/util/thread/PriorityConsecutiveExecutor# dispatcher % &5(ILjava/util/concurrent/Executor;Ljava/lang/String;)V ( #)7Lnet/minecraft/util/thread/PriorityConsecutiveExecutor; + ,-sleepingZ / 01hasWork()Z /4:net/minecraft/util/thread/StrictQueue$RunnableWithPriority6 78run(Lnet/minecraft/server/level/ChunkTaskDispatcher;Ljava/util/function/IntSupplier;Lnet/minecraft/world/level/ChunkPos;ILjava/util/function/IntConsumer;)Ljava/lang/Runnable; 3: ;(ILjava/lang/Runnable;)V = >?schedule(Ljava/lang/Runnable;)VA 7B\(Lnet/minecraft/server/level/ChunkTaskDispatcher;JZLjava/lang/Runnable;)Ljava/lang/Runnable;D 7E{(Lnet/minecraft/server/level/ChunkTaskDispatcher;Ljava/util/function/IntSupplier;JLjava/lang/Runnable;)Ljava/lang/Runnable;G 7HF(Lnet/minecraft/server/level/ChunkTaskDispatcher;)Ljava/lang/Runnable; JKL MN?net/minecraft/server/level/ChunkTaskPriorityQueue$TasksForChunktasks()Ljava/util/List; PQR STjava/util/Liststream()Ljava/util/stream/Stream;V WXapplyO(Lnet/minecraft/server/level/ChunkTaskDispatcher;)Ljava/util/function/Function; Z[\ ]^java/util/stream/Streammap8(Ljava/util/function/Function;)Ljava/util/stream/Stream;` Wa"()Ljava/util/function/IntFunction; Zc detoArray5(Ljava/util/function/IntFunction;)[Ljava/lang/Object;g)[Ljava/util/concurrent/CompletableFuture; ijk lm&java/util/concurrent/CompletableFutureallOfS([Ljava/util/concurrent/CompletableFuture;)Ljava/util/concurrent/CompletableFuture;o pqacceptO(Lnet/minecraft/server/level/ChunkTaskDispatcher;)Ljava/util/function/Consumer; is tu thenAcceptG(Ljava/util/function/Consumer;)Ljava/util/concurrent/CompletableFuture; w xypopC()Lnet/minecraft/server/level/ChunkTaskPriorityQueue$TasksForChunk; { |close ~ pollTask p3(Ljava/lang/Runnable;)Ljava/util/function/Consumer; uscheduleWithResult  7java/lang/Runnable  net/minecraft/util/UnitINSTANCELnet/minecraft/util/Unit; i complete(Ljava/lang/Object;)Z  ypopTasks  scheduleForExecutionD(Lnet/minecraft/server/level/ChunkTaskPriorityQueue$TasksForChunk;)V  java/util/function/IntSuppliergetAsInt()I  -net/minecraft/SharedConstantsDEBUG_VERBOSE_SERVER_EVENTS  LOGGERLorg/slf4j/Logger;SUB {} {} {} {}  "net/minecraft/world/level/ChunkPosunpack'(J)Lnet/minecraft/world/level/ChunkPos;  java/lang/IntegervalueOf(I)Ljava/lang/Integer;  org/slf4j/Loggerdebug((Ljava/lang/String;[Ljava/lang/Object;)V  submit(Ljava/lang/Runnable;JI)V  release(JZ)V   onRelease(J)VRES {} {} -> {}  resortChunkTasks)(ILnet/minecraft/world/level/ChunkPos;I)V  pjava/util/function/IntConsumer(I)V  com/mojang/logging/LogUtils getLogger()Lorg/slf4j/Logger;:net/minecraft/server/level/ChunkHolder$LevelChangeListenerjava/lang/AutoCloseableDISPATCHER_PRIORITY_COUNTI ConstantValue Signature?Lnet/minecraft/util/thread/TaskScheduler;K(Lnet/minecraft/util/thread/TaskScheduler;Ljava/util/concurrent/Executor;)VCodeLineNumberTableLocalVariableTablethis0Lnet/minecraft/server/level/ChunkTaskDispatcher;dispatcherExecutorLjava/util/concurrent/Executor;LocalVariableTypeTableMethodParametersa(Lnet/minecraft/util/thread/TaskScheduler;Ljava/util/concurrent/Executor;)V StackMapTable onLevelChangeh(Lnet/minecraft/world/level/ChunkPos;Ljava/util/function/IntSupplier;ILjava/util/function/IntConsumer;)Vpos$Lnet/minecraft/world/level/ChunkPos;oldLevel Ljava/util/function/IntSupplier;newLevel setQueueLevel Ljava/util/function/IntConsumer;(JLjava/lang/Runnable;Z)VJ whenReleasedLjava/lang/Runnable; clearQueue8(Ljava/lang/Runnable;JLjava/util/function/IntSupplier;)Vtasklevel tasksForChunkALnet/minecraft/server/level/ChunkTaskPriorityQueue$TasksForChunk;keyRuntimeVisibleTypeAnnotations#Lorg/jspecify/annotations/Nullable;lambda$scheduleForExecution$3(Ljava/lang/Void;)VrLjava/lang/Void;lambda$scheduleForExecution$2,(I)[Ljava/util/concurrent/CompletableFuture;x$0lambda$scheduleForExecution$0>(Ljava/lang/Runnable;)Ljava/util/concurrent/CompletableFuture;messagelambda$scheduleForExecution$1?(Ljava/lang/Runnable;Ljava/util/concurrent/CompletableFuture;)Vfuture(Ljava/util/concurrent/CompletableFuture;lambda$pollTask$0lambda$submit$08(Ljava/util/function/IntSupplier;JLjava/lang/Runnable;)V ticketLevellambda$release$0(JZLjava/lang/Runnable;)Vlambda$onLevelChange$0h(Ljava/util/function/IntSupplier;Lnet/minecraft/world/level/ChunkPos;ILjava/util/function/IntConsumer;)VoldTicketLevel SourceFileChunkTaskDispatcher.javaBootstrapMethods#_queue& ' ) * , - / 0 2&(Ljava/lang/Object;)Ljava/lang/Object;4 5 8(I)Ljava/lang/Object;: ;    >(Ljava/lang/Object;)V@ A D E G+(Ljava/util/concurrent/CompletableFuture;)VI JKL M$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;O PQR ST"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; InnerClassesW%net/minecraft/util/thread/StrictQueueRunnableWithPriority TasksForChunk[&net/minecraft/server/level/ChunkHolderLevelChangeListener^%java/lang/invoke/MethodHandles$Lookup`java/lang/invoke/MethodHandlesLookup!#),-4**Y+ *+* Y,"$'**.3 444 4 01P*'. *2" @q *'3Y*,+59< '/4f *'3Y*-@9< 2;*- f *'3Y* +C9< >I* D*'3Y*F9< LT s/+IO*UY_bfh*nrWWZ!W*Z.[//5^y2*va |8 *z f g  9*}Z     /iZ  D*+W K*+WXYZj*L+ ***+MN OQS JV+6.Y SYSY*SY*S* ** ***}"?@A9CEDLEQFUH4VVVVN9&**** ***}3 45679%:*&&&-&C+6$Y,SYSYS*,()*/,:-B.>CCCCC;/ճ !X H"N$%$N$($N$+$N$.$N136N79<N=?BN=CFU"3VXJYZ\ ]_a