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;drainR(Ljava/util/concurrent/BlockingQueue;Ljava/util/Collection;ILjava/time/Duration;)Iq$Ljava/util/concurrent/BlockingQueue;bufferLjava/util/Collection; numElementstimeoutLjava/time/Duration;)Ljava/util/concurrent/BlockingQueue;Ljava/util/Collection<-TE;>; Exceptionss(Ljava/util/concurrent/BlockingQueue;Ljava/util/Collection<-TE;>;ILjava/time/Duration;)I$Lcom/google/common/annotations/Beta;8Lcom/google/errorprone/annotations/CanIgnoreReturnValue;^(Ljava/util/concurrent/BlockingQueue;Ljava/util/Collection;IJLjava/util/concurrent/TimeUnit;)IeLjava/lang/Object;JunitLjava/util/concurrent/TimeUnit;deadlineaddedTE;(Ljava/util/concurrent/BlockingQueue;Ljava/util/Collection<-TE;>;IJLjava/util/concurrent/TimeUnit;)IdrainUninterruptiblyex 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  t   java/lang/InterruptedException . M B com/google/common/collect/Queuesjava/lang/Objectjava/lang/Throwable(I)V(Ljava/util/Collection;)V#com/google/common/collect/IterablesaddAll-(Ljava/util/Collection;Ljava/lang/Iterable;)Zjava/time/DurationtoNanos()Jjava/util/concurrent/TimeUnit NANOSECONDS$com/google/common/base/Preconditions checkNotNull&(Ljava/lang/Object;)Ljava/lang/Object;java/lang/SystemnanoTime(J)J"java/util/concurrent/BlockingQueuedrainTo(Ljava/util/Collection;I)Ipoll4(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+,-.//*0-1 23 45/3 Y071  6789:; <=/ Y0B8> <?/#*Y*YL+*W+0LMOP!Q1#@ABCD#@EBFG8H IJ/  Y 0Y8K:; IL/#* Y* Y L+*W+0cdfg!h1#@AMND#@EMOG8P:; QR/  Y 0t8S:; QT/3 Y01  678U:; QV/#* Y* Y L+*W+0!1#@ABWD#@EBXG8Y:; Z[/ Y08\:; Z]/3 Y01  678^:; Z_/#*Y*YL+*W+0!1#@AM`D#@EMaG8b:; cd/ Y08e:; cf/#*Y*YL+*W+0!1#@AMgD#@EMhG8i:; jk/ Y08l jm/#*Y*YL+*W+0!1#@AMnD#@EMoG8p qr/ Y08s:; tu/r*+-01*vwxyz7{|Dv}x~&8:; t/7 [+W !!a76A*+d"`6* e#:  + $W06 ,2347*809A:F;I=R>U?XA1RA [vw[xy[z7[{[JG7D A [v}[x~G4,&8:; u/r*+-%0Z1*vwxyz7{|Dv}x~8:; / +W !!a766 L*+d"`6* e#: : 6  + $W '(:  '( 3DG&fttvt0^tuvwy|-}3DGILOTW`cfkt{1p D I O vwxyz7{vs7p D*D O v}x~G& S&,M 8:; /B*)01 MD M8 /B**01 BD B8: Z