ConditionPriorityBlockingQueue
public
class
ConditionPriorityBlockingQueue
extends Object
java.lang.Object | |
↳ | com.android.tradefed.util.ConditionPriorityBlockingQueue<T> |
Belirli bir koşulla eşleşen nesneleri alabilecek ERROR(/PriorityBlockingQueue)
benzeri işlemlere sahip, iş parçacığı güvenli bir sınıf.
Yineleme de iş parçacığı açısından güvenlidir ancak tutarlı değildir. Döngüleyici oluşturulurken kuyruğun bir kopyası oluşturulur ve bu kopya iterasyon hedefi olarak kullanılır. Döngü sırasında sıra değiştirilirse ERROR(/ConcurrentModificationException)
atılmaz ancak iteratör de değiştirilen içerikleri yansıtmaz.
Özet
İç içe yerleştirilmiş sınıflar | |
---|---|
class |
ConditionPriorityBlockingQueue.AlwaysMatch<T>
Herhangi bir nesneyle eşleşen bir |
interface |
ConditionPriorityBlockingQueue.IMatcher<T>
Öğelerin bir koşulla eşleşip eşleşmediğini belirlemek için kullanılan bir arayüz. |
Herkese açık kurucular | |
---|---|
ConditionPriorityBlockingQueue()
Bir Öğelere öncelik, FIFO sırasına göre verilir. |
|
ConditionPriorityBlockingQueue(
Bir |
Herkese açık yöntemler | |
---|---|
boolean
|
add(T addedElement)
Belirtilen öğeyi bu sıraya ekler. |
T
|
addUnique(IMatcher<T> matcher, T object)
Belirtilen koşulla eşleşen mevcut nesnelerin yerini alarak bu sıraya bir öğe ekler. |
void
|
clear()
Bu sıradaki tüm öğeleri kaldırır. |
boolean
|
contains(T object)
Bir nesnenin şu anda bu sırada bulunup bulunmadığını belirleme. |
|
getCopy()
Sırada bekleyen öğelerin bir kopyasını alın. |
|
iterator()
|
T
|
poll(long timeout, TimeUnit unit)
Sırayla sağlanan |
T
|
poll(long timeout, TimeUnit unit, IMatcher<T> matcher)
matcher.matches(T)'un |
T
|
poll(IMatcher<T> matcher)
matcher.matches(T)'un |
T
|
poll()
Bu kuyruğun başını alır ve kaldırır. |
boolean
|
remove(T object)
Bir öğeyi bu sıradan kaldırır. |
int
|
size()
|
T
|
take()
Sırayla sağlanan |
T
|
take(IMatcher<T> matcher)
matcher.matches(T) değerinin |
Herkese açık kurucular
ConditionPriorityBlockingQueue
public ConditionPriorityBlockingQueue ()
Bir ConditionPriorityBlockingQueue
oluşturur
Öğelere öncelik, FIFO sırasına göre verilir.
ConditionPriorityBlockingQueue
public ConditionPriorityBlockingQueue (c)
Bir ConditionPriorityBlockingQueue
oluşturur
Parametreler | |
---|---|
c |
: Sıraya öncelik vermek için kullanılan ERROR(/Comparator) . |
Herkese açık yöntemler
ekle
public boolean add (T addedElement)
Belirtilen öğeyi bu sıraya ekler. Sıra sınırsız olduğundan bu yöntem hiçbir zaman engellenmez.
Parametreler | |
---|---|
addedElement |
T : eklenecek öğe |
İlerlemeler | |
---|---|
boolean |
true |
Atışlar | |
---|---|
ClassCastException |
Belirtilen öğe, öncelik kuyruğunun sıralamasına göre şu anda öncelik kuyruğunda bulunan öğelerle karşılaştırılamazsa |
NullPointerException |
Belirtilen öğe null ise |
addUnique
public T addUnique (IMatcher<T> matcher, T object)
Belirtilen koşulla eşleşen mevcut nesneleri değiştirerek bu sıraya bir öğe ekler.
Parametreler | |
---|---|
matcher |
IMatcher : Mevcut nesneleri değerlendirecek eşleyici |
object |
T : eklenecek nesne |
İlerlemeler | |
---|---|
T |
Değiştirilen nesne veya yoksa null |
temizle
public void clear ()
Bu sıradaki tüm öğeleri kaldırır.
şunu içeriyor:
public boolean contains (T object)
Bir nesnenin şu anda bu sırada yer alıp almadığını belirleme.
Parametreler | |
---|---|
object |
T : bulunacak nesne |
İlerlemeler | |
---|---|
boolean |
true , belirli bir nesne kuyruktaysa. false>
aksi halde. |
getCopy
publicgetCopy ()
Sırada bekleyen öğelerin bir kopyasını alın.
İlerlemeler | |
---|---|
|
iteratör
publiciterator ()
İlerlemeler | |
---|---|
|
anket
public T poll (long timeout, TimeUnit unit)
Sırayla sağlanan ERROR(/Comparator)
öğesi T'ye göre minimum değeri alır ve kaldırır.
Bir öğenin kullanılabilir hale gelmesi için timeout saate kadar süreyi engeller.
Parametreler | |
---|---|
timeout |
long : Bir öğenin kullanılabilir hale gelmesi için bekleme süresi |
unit |
TimeUnit : zaman aşımı ERROR(/TimeUnit) |
İlerlemeler | |
---|---|
T |
Eşleşen minimum öğe veya eşleşen öğe yoksa null |
anket
public T poll (long timeout, TimeUnit unit, IMatcher<T> matcher)
matcher.matches(T)'un true
olduğu kuyrukta sağlanan ERROR(/Comparator)
öğesi T'ye göre değerlendirilen minimum değeri alır ve kaldırır.
Bir öğenin kullanılabilir hale gelmesi için timeout saate kadar süreyi engeller.
Parametreler | |
---|---|
timeout |
long : Bir öğenin kullanılabilir hale gelmesi için bekleme süresi |
unit |
TimeUnit : zaman aşımı ERROR(/TimeUnit) |
matcher |
IMatcher : Öğeleri değerlendirmek için kullanılacak IMatcher |
İlerlemeler | |
---|---|
T |
Eşleşen minimum öğe veya eşleşen öğe yoksa null |
anket
public T poll (IMatcher<T> matcher)
matcher.matches(T)'un true
olduğu kuyrukta sağlanan ERROR(/Comparator)
öğesi T'ye göre değerlendirilen minimum değeri alır ve kaldırır.
Parametreler | |
---|---|
matcher |
IMatcher : Öğeleri değerlendirmek için kullanılacak IMatcher |
İlerlemeler | |
---|---|
T |
Eşleşen minimum öğe veya eşleşen öğe yoksa null |
anket
public T poll ()
Bu kuyruğun başını alır ve kaldırır.
İlerlemeler | |
---|---|
T |
Bu kuyruğun başı veya kuyruk boşsa null |
kaldırma
public boolean remove (T object)
Bir öğeyi bu sıradan kaldırır.
Parametreler | |
---|---|
object |
T : Kaldırılacağı nesne |
İlerlemeler | |
---|---|
boolean |
true , belirtilen nesne sıradan kaldırıldıysa. false>
aksi halde. |
beden
public int size ()
İlerlemeler | |
---|---|
int |
Sırada bekleyen öğe sayısı |
al
public T take ()
Sırayla sağlanan ERROR(/Comparator)
öğesi T'ye göre minimum değeri alır ve kaldırır.
Bir öğenin kullanılabilir hale gelmesini süresiz olarak engeller.
İlerlemeler | |
---|---|
T |
bu kuyruğun başı |
Atışlar | |
---|---|
InterruptedException |
Bekleme sırasında kesinti olursa |
al
public T take (IMatcher<T> matcher)
matcher.matches(T) değerinin true
olduğu sıradaki ilk T öğesini alır ve kaldırır. Gerekirse böyle bir öğe bulunana kadar bekler.
Parametreler | |
---|---|
matcher |
IMatcher : Öğeleri değerlendirmek için kullanılacak IMatcher |
İlerlemeler | |
---|---|
T |
eşleşen öğe |
Atışlar | |
---|---|
InterruptedException |
Bekleme sırasında kesinti olursa |