E  .net/minecraft/server/level/ChunkTaskDispatcherK(Lnet/minecraft/util/thread/TaskScheduler;Ljava/util/concurrent/Executor;)V+it/unimi/dsi/fastutil/longs/LongOpenHashSet   ()V  8net/minecraft/server/level/ThrottlingChunkTaskDispatcherchunkPositionsInExecution%Lit/unimi/dsi/fastutil/longs/LongSet;  maxChunksInExecutionI  'net/minecraft/util/thread/TaskSchedulername()Ljava/lang/String;  executorSchedulerNameLjava/lang/String; !"# $%#it/unimi/dsi/fastutil/longs/LongSetremove(J)Z !' ()size()I + ,-popTasksC()Lnet/minecraft/server/level/ChunkTaskPriorityQueue$TasksForChunk; /01 23?net/minecraft/server/level/ChunkTaskPriorityQueue$TasksForChunkchunkPos()J !5 6%add 8 9:scheduleForExecutionD(Lnet/minecraft/server/level/ChunkTaskPriorityQueue$TasksForChunk;)V !< => longStream()Ljava/util/stream/LongStream;@ ABapply#()Ljava/util/function/LongFunction; DEF GHjava/util/stream/LongStreammapToObj<(Ljava/util/function/LongFunction;)Ljava/util/stream/Stream;J, LMN OPjava/util/stream/Collectorsjoining6(Ljava/lang/CharSequence;)Ljava/util/stream/Collector; RST UVjava/util/stream/Streamcollect0(Ljava/util/stream/Collector;)Ljava/lang/Object;Xjava/lang/String Z [\sleepingZ^ _`makeConcatWithConstants9(Ljava/lang/String;Ljava/lang/String;Z)Ljava/lang/String; bcd ef"net/minecraft/world/level/ChunkPosunpack'(J)Lnet/minecraft/world/level/ChunkPos; Wh ijvalueOf&(Ljava/lang/Object;)Ljava/lang/String;l _m'(JLjava/lang/String;)Ljava/lang/String;L(Lnet/minecraft/util/thread/TaskScheduler;Ljava/util/concurrent/Executor;I)VCodeLineNumberTableLocalVariableTablethis:Lnet/minecraft/server/level/ThrottlingChunkTaskDispatcher;executor)Lnet/minecraft/util/thread/TaskScheduler;dispatcherExecutorLjava/util/concurrent/Executor;LocalVariableTypeTable?Lnet/minecraft/util/thread/TaskScheduler;MethodParameters Signatureb(Lnet/minecraft/util/thread/TaskScheduler;Ljava/util/concurrent/Executor;I)V onRelease(J)VkeyJ StackMapTableRuntimeVisibleTypeAnnotations#Lorg/jspecify/annotations/Nullable; tasksForChunkALnet/minecraft/server/level/ChunkTaskPriorityQueue$TasksForChunk;getDebugStatusRuntimeInvisibleAnnotations1Lcom/google/common/annotations/VisibleForTesting;lambda$getDebugStatus$0(J)Ljava/lang/String; SourceFile"ThrottlingChunkTaskDispatcher.javaBootstrapMethods(J)Ljava/lang/Object;  =[], s=:  "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;  _$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; InnerClasses1net/minecraft/server/level/ChunkTaskPriorityQueue TasksForChunk%java/lang/invoke/MethodHandles$Lookupjava/lang/invoke/MethodHandlesLookup! no!*+,*Y **+p q*!rs!tu!vw!x !tyz tv{|}~oD *  Wp  q rs z,-oP* &* **pq rs@/9:oP* +.4W*+7p$%&qrszoX.** ;?CIKQW*Y]p*q .rs o8agkp*q /