2 *                ()VCodeLineNumberTableLocalVariableTablethis"Lcom/google/common/collect/Queues;newArrayBlockingQueue,(I)Ljava/util/concurrent/ArrayBlockingQueue;capacityI SignatureG(I)Ljava/util/concurrent/ArrayBlockingQueue; 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;)IRuntimeInvisibleAnnotations$Lcom/google/common/annotations/Beta;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 +,'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 , I > 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.3/  4567 89- Y.>6: 8;-#*Y*YL+* W+.HIKL!M/#<=>?@#<A>BC6D EF-  Y .V6G EH-#* Y* Y L+* W+._`bc!d/#<=IJ@#<AIKC6L MN-  Y.o6O MP-3 Y.y/  456Q MR-#* Y* YL+* W+.!/#<=>S@#<A>TC6U VW- Y.6X VY-3 Y./  456Z V[-#*Y*YL+* W+.!/#<=I\@#<AI]C6^ _`- Y.6a _b-#*Y*YL+* W+.!/#<=Ic@#<AIdC6e fg- Y.6h fi-#*Y*YL+* W+.!/#<=Ij@#<AIkC6l mn- Y.6o pq-7 [+W!a76A*+d `6*e!":  + #W.6  *0AFIRUX /RArs [tu[vw[x5[yz[{|J}zG~5@ Ar [t[vC4$6 q- +W!a766 L*+d `6*e!": : 6  + #W %&:  %& 3DG$fttvt.Z789:<?-@3DDEGFIGLHOJTKWM`NcOfRkStR{SV/f I Drs tuvwx5yz{|v}zs~5p @ Dr tvC& SM 6 -B*'.u/ I@ I6 -B*(./ >@ >6