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;I()Ljava/util/concurrent/PriorityBlockingQueue;B(Ljava/lang/Iterable;)Ljava/util/concurrent/PriorityBlockingQueue;,Ljava/util/concurrent/PriorityBlockingQueue;1Ljava/util/concurrent/PriorityBlockingQueue;c(Ljava/lang/Iterable<+TE;>;)Ljava/util/concurrent/PriorityBlockingQueue;newPriorityQueue()Ljava/util/PriorityQueue;6()Ljava/util/PriorityQueue;/(Ljava/lang/Iterable;)Ljava/util/PriorityQueue;Ljava/util/PriorityQueue;Ljava/util/PriorityQueue;P(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; 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 + H 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;1()*+,/*-*. /0 12,3 Y-4.  3456 78, Y-@59 7:,#*Y*YL+* W+-KLNO!P.#;<=>?#;@=AB5C DE,  Y -[5F DG,#* Y* Y L+* W+-fgij!k.#;<HI?#;@HJB5K LM,  Y-w5N LO,3 Y-.  345P LQ,#* Y* YL+* W+-!.#;<=R?#;@=SB5T UV, Y-5W UX,3 Y-.  345Y UZ,#*Y*YL+* W+-!.#;<H[?#;@H\B5] ^_, Y-5` ^a,#*Y*YL+* W+-!.#;<Hb?#;@HcB5d ef, Y-5g eh,#*Y*YL+* W+-!.#;<Hi?#;@HjB5k lm, Y-5n op,7 [+W!a76A*+d `6*e!":  + #W-6  *0AFIRU X".RAqr [st[uv[w4[xy[z{J|yG}4? Aq~ [s[uB4$5 p, +W!a766 L*+d `6*e!": : 6  + #W %&:  %& 3DG$fttvt-Z5678:=->3BDCGDIELFOHTIWK`LcMfPkQtP{QT.f I Dqr stuvw4xyz{v|ys}4p ? Dq~ suB& SM 5 ,B*'-t. H? H5