Edit C:\Users\Admin\.m2\repository\com\google\guava\guava\14.0.1\com\google\common\collect\Queues.class
???? 2 ? ) ? ? ? ? ? ? ? ? ? ? ? ? ? ? ? ? ? ? ? ? ? ? ? ? ? ? ? ? ? ? ? ? ? ? ? ? ? ? ? ? ? ? ? ? ? ? ? ? ? ? ? ? <init> ()V Code LineNumberTable LocalVariableTable this "Lcom/google/common/collect/Queues; newArrayBlockingQueue ,(I)Ljava/util/concurrent/ArrayBlockingQueue; capacity I Signature G<E:Ljava/lang/Object;>(I)Ljava/util/concurrent/ArrayBlockingQueue<TE;>; newArrayDeque ()Ljava/util/ArrayDeque; 3<E:Ljava/lang/Object;>()Ljava/util/ArrayDeque<TE;>; ,(Ljava/lang/Iterable;)Ljava/util/ArrayDeque; elements Ljava/lang/Iterable; deque Ljava/util/ArrayDeque; LocalVariableTypeTable Ljava/lang/Iterable<+TE;>; Ljava/util/ArrayDeque<TE;>; StackMapTable M<E:Ljava/lang/Object;>(Ljava/lang/Iterable<+TE;>;)Ljava/util/ArrayDeque<TE;>; newConcurrentLinkedQueue .()Ljava/util/concurrent/ConcurrentLinkedQueue; I<E:Ljava/lang/Object;>()Ljava/util/concurrent/ConcurrentLinkedQueue<TE;>; B(Ljava/lang/Iterable;)Ljava/util/concurrent/ConcurrentLinkedQueue; queue ,Ljava/util/concurrent/ConcurrentLinkedQueue; 1Ljava/util/concurrent/ConcurrentLinkedQueue<TE;>; c<E:Ljava/lang/Object;>(Ljava/lang/Iterable<+TE;>;)Ljava/util/concurrent/ConcurrentLinkedQueue<TE;>; newLinkedBlockingDeque ,()Ljava/util/concurrent/LinkedBlockingDeque; G<E:Ljava/lang/Object;>()Ljava/util/concurrent/LinkedBlockingDeque<TE;>; -(I)Ljava/util/concurrent/LinkedBlockingDeque; H<E:Ljava/lang/Object;>(I)Ljava/util/concurrent/LinkedBlockingDeque<TE;>; @(Ljava/lang/Iterable;)Ljava/util/concurrent/LinkedBlockingDeque; *Ljava/util/concurrent/LinkedBlockingDeque; /Ljava/util/concurrent/LinkedBlockingDeque<TE;>; a<E:Ljava/lang/Object;>(Ljava/lang/Iterable<+TE;>;)Ljava/util/concurrent/LinkedBlockingDeque<TE;>; newLinkedBlockingQueue ,()Ljava/util/concurrent/LinkedBlockingQueue; G<E:Ljava/lang/Object;>()Ljava/util/concurrent/LinkedBlockingQueue<TE;>; -(I)Ljava/util/concurrent/LinkedBlockingQueue; H<E:Ljava/lang/Object;>(I)Ljava/util/concurrent/LinkedBlockingQueue<TE;>; @(Ljava/lang/Iterable;)Ljava/util/concurrent/LinkedBlockingQueue; *Ljava/util/concurrent/LinkedBlockingQueue; /Ljava/util/concurrent/LinkedBlockingQueue<TE;>; a<E:Ljava/lang/Object;>(Ljava/lang/Iterable<+TE;>;)Ljava/util/concurrent/LinkedBlockingQueue<TE;>; newPriorityBlockingQueue .()Ljava/util/concurrent/PriorityBlockingQueue; I<E:Ljava/lang/Object;>()Ljava/util/concurrent/PriorityBlockingQueue<TE;>; B(Ljava/lang/Iterable;)Ljava/util/concurrent/PriorityBlockingQueue; ,Ljava/util/concurrent/PriorityBlockingQueue; 1Ljava/util/concurrent/PriorityBlockingQueue<TE;>; c<E:Ljava/lang/Object;>(Ljava/lang/Iterable<+TE;>;)Ljava/util/concurrent/PriorityBlockingQueue<TE;>; newPriorityQueue ()Ljava/util/PriorityQueue; 6<E:Ljava/lang/Object;>()Ljava/util/PriorityQueue<TE;>; /(Ljava/lang/Iterable;)Ljava/util/PriorityQueue; Ljava/util/PriorityQueue; Ljava/util/PriorityQueue<TE;>; P<E:Ljava/lang/Object;>(Ljava/lang/Iterable<+TE;>;)Ljava/util/PriorityQueue<TE;>; newSynchronousQueue )()Ljava/util/concurrent/SynchronousQueue; D<E:Ljava/lang/Object;>()Ljava/util/concurrent/SynchronousQueue<TE;>; drain ^(Ljava/util/concurrent/BlockingQueue;Ljava/util/Collection;IJLjava/util/concurrent/TimeUnit;)I e Ljava/lang/Object; q $Ljava/util/concurrent/BlockingQueue; buffer Ljava/util/Collection; numElements timeout J unit Ljava/util/concurrent/TimeUnit; deadline added TE; )Ljava/util/concurrent/BlockingQueue<TE;>; Ljava/util/Collection<-TE;>; ? Exceptions <E:Ljava/lang/Object;>(Ljava/util/concurrent/BlockingQueue<TE;>;Ljava/util/Collection<-TE;>;IJLjava/util/concurrent/TimeUnit;)I RuntimeInvisibleAnnotations $Lcom/google/common/annotations/Beta; drainUninterruptibly ex Ljava/lang/InterruptedException; interrupted Z ? ? synchronizedQueue $(Ljava/util/Queue;)Ljava/util/Queue; Ljava/util/Queue; Ljava/util/Queue<TE;>; D<E:Ljava/lang/Object;>(Ljava/util/Queue<TE;>;)Ljava/util/Queue<TE;>; SourceFile Queues.java * + 'java/util/concurrent/ArrayBlockingQueue * ? java/util/ArrayDeque java/util/Collection ? ? ? * ? ? ? ? *java/util/concurrent/ConcurrentLinkedQueue (java/util/concurrent/LinkedBlockingDeque (java/util/concurrent/LinkedBlockingQueue *java/util/concurrent/PriorityBlockingQueue java/util/PriorityQueue %java/util/concurrent/SynchronousQueue ? ? ? ? ? ? ? ? ? ? ? ? ? { ? ? ? ? java/lang/InterruptedException ? ? ? ? + ? H ? com/google/common/collect/Queues java/lang/Object java/lang/Throwable (I)V &com/google/common/collect/Collections2 cast ,(Ljava/lang/Iterable;)Ljava/util/Collection; (Ljava/util/Collection;)V #com/google/common/collect/Iterables addAll -(Ljava/util/Collection;Ljava/lang/Iterable;)Z $com/google/common/base/Preconditions checkNotNull &(Ljava/lang/Object;)Ljava/lang/Object; java/lang/System nanoTime ()J java/util/concurrent/TimeUnit toNanos (J)J "java/util/concurrent/BlockingQueue drainTo (Ljava/util/Collection;I)I NANOSECONDS poll 4(JLjava/util/concurrent/TimeUnit;)Ljava/lang/Object; add (Ljava/lang/Object;)Z java/lang/Thread currentThread ()Ljava/lang/Thread; interrupt &com/google/common/collect/Synchronized 6(Ljava/util/Queue;Ljava/lang/Object;)Ljava/util/Queue; 1 ( ) * + , / *? ? - * . / 0 1 2 , 3 ? Y? ? - 4 . 3 4 5 6 7 8 , ? Y? ? - @ 5 9 7 : , ? #*? ? ? Y*? ? ?? Y? L+*? W+? - K L N O ! P . # ; <