4 *                ()VCodeLineNumberTableLocalVariableTablethis"Lcom/google/common/collect/Queues;newArrayBlockingQueue,(I)Ljava/util/concurrent/ArrayBlockingQueue;capacityI SignatureG(I)Ljava/util/concurrent/ArrayBlockingQueue;RuntimeInvisibleAnnotations/Lcom/google/common/annotations/GwtIncompatible; newArrayDeque()Ljava/util/ArrayDeque;3()Ljava/util/ArrayDeque;,(Ljava/lang/Iterable;)Ljava/util/ArrayDeque;elementsLjava/lang/Iterable;dequeLjava/util/ArrayDeque;LocalVariableTypeTableLjava/lang/Iterable<+TE;>;Ljava/util/ArrayDeque; StackMapTableM(Ljava/lang/Iterable<+TE;>;)Ljava/util/ArrayDeque;newConcurrentLinkedQueue.()Ljava/util/concurrent/ConcurrentLinkedQueue;I()Ljava/util/concurrent/ConcurrentLinkedQueue;B(Ljava/lang/Iterable;)Ljava/util/concurrent/ConcurrentLinkedQueue;queue,Ljava/util/concurrent/ConcurrentLinkedQueue;1Ljava/util/concurrent/ConcurrentLinkedQueue;c(Ljava/lang/Iterable<+TE;>;)Ljava/util/concurrent/ConcurrentLinkedQueue;newLinkedBlockingDeque,()Ljava/util/concurrent/LinkedBlockingDeque;G()Ljava/util/concurrent/LinkedBlockingDeque;-(I)Ljava/util/concurrent/LinkedBlockingDeque;H(I)Ljava/util/concurrent/LinkedBlockingDeque;@(Ljava/lang/Iterable;)Ljava/util/concurrent/LinkedBlockingDeque;*Ljava/util/concurrent/LinkedBlockingDeque;/Ljava/util/concurrent/LinkedBlockingDeque;a(Ljava/lang/Iterable<+TE;>;)Ljava/util/concurrent/LinkedBlockingDeque;newLinkedBlockingQueue,()Ljava/util/concurrent/LinkedBlockingQueue;G()Ljava/util/concurrent/LinkedBlockingQueue;-(I)Ljava/util/concurrent/LinkedBlockingQueue;H(I)Ljava/util/concurrent/LinkedBlockingQueue;@(Ljava/lang/Iterable;)Ljava/util/concurrent/LinkedBlockingQueue;*Ljava/util/concurrent/LinkedBlockingQueue;/Ljava/util/concurrent/LinkedBlockingQueue;a(Ljava/lang/Iterable<+TE;>;)Ljava/util/concurrent/LinkedBlockingQueue;newPriorityBlockingQueue.()Ljava/util/concurrent/PriorityBlockingQueue;N()Ljava/util/concurrent/PriorityBlockingQueue;B(Ljava/lang/Iterable;)Ljava/util/concurrent/PriorityBlockingQueue;,Ljava/util/concurrent/PriorityBlockingQueue;1Ljava/util/concurrent/PriorityBlockingQueue;h(Ljava/lang/Iterable<+TE;>;)Ljava/util/concurrent/PriorityBlockingQueue;newPriorityQueue()Ljava/util/PriorityQueue;;()Ljava/util/PriorityQueue;/(Ljava/lang/Iterable;)Ljava/util/PriorityQueue;Ljava/util/PriorityQueue;Ljava/util/PriorityQueue;U(Ljava/lang/Iterable<+TE;>;)Ljava/util/PriorityQueue;newSynchronousQueue)()Ljava/util/concurrent/SynchronousQueue;D()Ljava/util/concurrent/SynchronousQueue;drain^(Ljava/util/concurrent/BlockingQueue;Ljava/util/Collection;IJLjava/util/concurrent/TimeUnit;)IeLjava/lang/Object;q$Ljava/util/concurrent/BlockingQueue;bufferLjava/util/Collection; numElementstimeoutJunitLjava/util/concurrent/TimeUnit;deadlineaddedTE;)Ljava/util/concurrent/BlockingQueue;Ljava/util/Collection<-TE;>; Exceptions(Ljava/util/concurrent/BlockingQueue;Ljava/util/Collection<-TE;>;IJLjava/util/concurrent/TimeUnit;)I$Lcom/google/common/annotations/Beta;8Lcom/google/errorprone/annotations/CanIgnoreReturnValue;drainUninterruptiblyex Ljava/lang/InterruptedException; interruptedZsynchronizedQueue$(Ljava/util/Queue;)Ljava/util/Queue;Ljava/util/Queue;Ljava/util/Queue;D(Ljava/util/Queue;)Ljava/util/Queue;synchronizedDeque$(Ljava/util/Deque;)Ljava/util/Deque;Ljava/util/Deque;Ljava/util/Deque;D(Ljava/util/Deque;)Ljava/util/Deque; SourceFile Queues.java-Lcom/google/common/annotations/GwtCompatible;emulated +,'java/util/concurrent/ArrayBlockingQueue +java/util/ArrayDequejava/util/Collection + *java/util/concurrent/ConcurrentLinkedQueue(java/util/concurrent/LinkedBlockingDeque(java/util/concurrent/LinkedBlockingQueue*java/util/concurrent/PriorityBlockingQueuejava/util/PriorityQueue%java/util/concurrent/SynchronousQueue    ~ java/lang/InterruptedException , K @ com/google/common/collect/Queuesjava/lang/Objectjava/lang/Throwable(I)V&com/google/common/collect/Collections2cast,(Ljava/lang/Iterable;)Ljava/util/Collection;(Ljava/util/Collection;)V#com/google/common/collect/IterablesaddAll-(Ljava/util/Collection;Ljava/lang/Iterable;)Z$com/google/common/base/Preconditions checkNotNull&(Ljava/lang/Object;)Ljava/lang/Object;java/lang/SystemnanoTime()Jjava/util/concurrent/TimeUnittoNanos(J)J"java/util/concurrent/BlockingQueuedrainTo(Ljava/util/Collection;I)I NANOSECONDSpoll4(JLjava/util/concurrent/TimeUnit;)Ljava/lang/Object;add(Ljava/lang/Object;)Zjava/lang/Thread currentThread()Ljava/lang/Thread; interrupt&com/google/common/collect/Synchronized6(Ljava/util/Queue;Ljava/lang/Object;)Ljava/util/Queue;6(Ljava/util/Deque;Ljava/lang/Object;)Ljava/util/Deque;1)*+,-/*.-/ 01 23-3 Y.7/  456789 :;- Y.B6< :=-#*Y*YL+* W+.LMOP!Q/#>?@AB#>C@DE6F GH-  Y .[6I89 GJ-#* Y* Y L+* W+.efhi!j/#>?KLB#>CKME6N89 OP-  Y.v6Q89 OR-3 Y./  456S89 OT-#* Y* YL+* W+.!/#>?@UB#>C@VE6W89 XY- Y.6Z89 X[-3 Y./  456\89 X]-#*Y*YL+* W+.!/#>?K^B#>CK_E6`89 ab- Y.6c89 ad-#*Y*YL+* W+.!/#>?KeB#>CKfE6g89 hi- Y.6j hk-#*Y*YL+* W+.!/#>?KlB#>CKmE6n op- Y.6q89 rs-7 [+W!a76A*+d `6*e!":  + #W.6 "#$'*(0)A*F+I-R.U/X1/RAtu [vw[xy[z5[{|[}~J|G5B At [v[xE4$689 s- +W!a766 L*+d `6*e!": : 6  + #W %&:  %& 3DG$fttvt.ZJKLMOR-S3WDXGYIZL[O]T^W``acbfekfte{fi/p Dtu I Otu vwxyz5{|}~v|s5p B*Dt Ot vxE& SM 689 -B*'./ KB K6 -B*(./ @B @68 Z