PriorityBlockingQueue 類別
定義
重要
部分資訊涉及發行前產品,在發行之前可能會有大幅修改。 Microsoft 對此處提供的資訊,不做任何明確或隱含的瑕疵擔保。
一個無界的阻塞佇列,使用與類別 PriorityQueue 相同的排序規則,並提供阻塞檢索操作。
[Android.Runtime.Register("java/util/concurrent/PriorityBlockingQueue", DoNotGenerateAcw=true)]
[Java.Interop.JavaTypeParameters(new System.String[] { "E" })]
public class PriorityBlockingQueue : Java.Util.AbstractQueue, IDisposable, Java.IO.ISerializable, Java.Util.Concurrent.IBlockingQueue
[<Android.Runtime.Register("java/util/concurrent/PriorityBlockingQueue", DoNotGenerateAcw=true)>]
[<Java.Interop.JavaTypeParameters(new System.String[] { "E" })>]
type PriorityBlockingQueue = class
inherit AbstractQueue
interface ISerializable
interface IJavaObject
interface IDisposable
interface IJavaPeerable
interface IBlockingQueue
interface IQueue
interface ICollection
interface IIterable
- 繼承
- 屬性
- 實作
備註
一個無界的阻塞佇列,使用與類別 PriorityQueue 相同的排序規則,並提供阻塞檢索操作。 雖然此隊列邏輯上無界,但嘗試新增可能因資源耗盡而失敗(導致 OutOfMemoryError)。 此類別不允許 null 元素。 依賴可比較自然排序的優先佇列也不允許插入非可比較物件( ClassCastException插入會導致 )。
這個類別及其迭代器實作了 和 介面中所有 <em>可選</em> 方法Collection。Iterator 方法#iterator()中提供的迭代器與方法中提供的#spliterator()分割器,皆保證<><>能以任意順序遍歷優先區塊排隊的元素。 如果你需要有序遍歷,可以考慮使用 Arrays.sort(pq.toArray())。 此外, drainTo 也可以用方法以 <優先>順序移除<或移除> 部分或全部元素,並將它們放到另一個集合中。
此類別的操作不保證元素優先順序相等。 如果你需要強制排序,可以定義自訂類別或比較器,使用次要鍵來打破主要優先權值的平手。 例如,這裡有一類對可比元素套用先入先出的決勝法。 使用時,你會插入一個 new FIFOEntry(anEntry) 而非純入口物件。
{@code
class FIFOEntry<E extends Comparable<? super E>>
implements Comparable<FIFOEntry<E>> {
static final AtomicLong seq = new AtomicLong();
final long seqNum;
final E entry;
public FIFOEntry(E entry) {
seqNum = seq.getAndIncrement();
this.entry = entry;
}
public E getEntry() { return entry; }
public int compareTo(FIFOEntry<E> other) {
int res = entry.compareTo(other.entry);
if (res == 0 && other.entry != this.entry)
res = (seqNum < other.seqNum ? -1 : 1);
return res;
}
}}
此類別是 Java 集合框架的成員。
已在1.5中新增。
Java 文件 java.util.concurrent.PriorityBlockingQueue。
本頁部分內容為基於 Open Source Project 所創建與分享的作品,並依授權條款所描述的使用進行修改。
建構函式
| 名稱 | Description |
|---|---|
| PriorityBlockingQueue() |
創造 |
| PriorityBlockingQueue(ICollection) |
建立包含指定集合中元素的 a |
| PriorityBlockingQueue(Int32, IComparator) |
創造具有指定初始容量的 , |
| PriorityBlockingQueue(Int32) |
創造具有指定初始容量的 , |
| PriorityBlockingQueue(IntPtr, JniHandleOwnership) |
建立 JNI 物件的 Managed 表示法時使用的建構函式;由運行時間呼叫。 |
屬性
| 名稱 | Description |
|---|---|
| Class |
傳回這個 |
| Handle |
基礎Android實例的句柄。 (繼承來源 Object) |
| IsEmpty |
待補充 (繼承來源 AbstractCollection) |
| JniIdentityHashCode |
取得由互通執行時指派給此 Java 對等端的身份雜湊碼。 (繼承來源 Object) |
| JniManagedPeerState |
一個無界的阻塞佇列,使用與類別 |
| JniPeerMembers |
一個無界的阻塞佇列,使用與類別 |
| PeerReference |
取得這個 Java 節點的 JNI 物件參考。 (繼承來源 Object) |
| ThresholdClass |
此 API 支援 Mono for Android 基礎架構,並非直接從你的程式碼中使用。 |
| ThresholdType |
此 API 支援 Mono for Android 基礎架構,並非直接從你的程式碼中使用。 |
方法
| 名稱 | Description |
|---|---|
| Add(Object) |
待補充 (繼承來源 AbstractCollection) |
| AddAll(ICollection) |
待補充 (繼承來源 AbstractCollection) |
| Clear() |
待補充 (繼承來源 AbstractCollection) |
| Clone() |
建立並傳回這個 對象的複本。 (繼承來源 Object) |
| Comparator() |
回傳用於排序此佇列元素的比較器,或 |
| Construct(JniObjectReference, JniObjectReferenceOptions) |
一個無界的阻塞佇列,使用與類別 |
| Contains(Object) |
待補充 (繼承來源 AbstractCollection) |
| ContainsAll(ICollection) |
待補充 (繼承來源 AbstractCollection) |
| Dispose() |
釋放該 Java 節點所持有的資源。 (繼承來源 Object) |
| Dispose(Boolean) |
釋放該 Java 節點所持有的資源。 (繼承來源 Object) |
| DisposeUnlessReferenced() |
一個無界的阻塞佇列,使用與類別 |
| DrainTo(ICollection, Int32) |
最多從該佇列中移除指定數量的可用元素,並將其加入給定的集合中。 |
| DrainTo(ICollection) |
從此佇列中移除所有可用元素,並將其加入給定的集合中。 |
| Element() |
擷取但不移除此隊列的首端。 (繼承來源 AbstractQueue) |
| Equals(Object) |
一個無界的阻塞佇列,使用與類別 |
| Equals(Object) |
指出其他物件是否「等於」這個物件。 (繼承來源 Object) |
| ForEach(IConsumer) |
對可迭代的每個元素執行指定動作,直到所有元素處理完畢或動作拋出例外為止。 |
| GetHashCode() |
傳回此物件的雜湊碼值。 (繼承來源 Object) |
| Iterator() |
回傳對佇列中元素的迭代器。 |
| JavaFinalize() |
已淘汰.
當垃圾收集決定不再參考物件時,垃圾收集行程在 物件上呼叫。 (繼承來源 Object) |
| Notify() |
喚醒正在等候此物件監視器的單一線程。 (繼承來源 Object) |
| NotifyAll() |
喚醒正在等候此物件監視器的所有線程。 (繼承來源 Object) |
| Offer(Object, Int64, TimeUnit) |
將指定的元素插入此優先佇列。 |
| Offer(Object) |
將指定的元素插入此優先佇列。 |
| Peek() |
擷取但不移除該佇列的首部,若該佇列為空則返回 |
| Poll() |
擷取並移除此佇列的首,或若佇列為空則返回 |
| Poll(Int64, TimeUnit) |
擷取並移除此佇列的頭部,必要時會等待指定等待時間以讓元素可用。 |
| Put(Object) |
將指定的元素插入此優先佇列。 |
| RemainingCapacity() |
總是回傳 |
| Remove() |
擷取並移除此佇列的頭部。 (繼承來源 AbstractQueue) |
| Remove(Object) |
待補充 (繼承來源 AbstractCollection) |
| RemoveAll(ICollection) |
待補充 (繼承來源 AbstractCollection) |
| RemoveIf(IPredicate) |
移除該集合中所有滿足該謂詞的元素。 |
| RetainAll(ICollection) |
待補充 (繼承來源 AbstractCollection) |
| SetHandle(IntPtr, JniHandleOwnership) |
設定 Handle 屬性。 (繼承來源 Object) |
| SetPeerReference(JniObjectReference, JniObjectReferenceOptions) |
一個無界的阻塞佇列,使用與類別 |
| Size() |
回傳該物件 |
| Spliterator() |
回傳 a |
| Take() |
擷取並移除此佇列的頭部,必要時等待元素可用。 |
| ToArray() |
待補充 (繼承來源 AbstractCollection) |
| ToArray(Object[]) |
待補充 (繼承來源 AbstractCollection) |
| ToArray<T>() |
從這個 Java 陣列包裝器建立一個受管理陣列。 (繼承來源 Object) |
| ToString() |
傳回物件的字串表示。 (繼承來源 Object) |
| UnregisterFromRuntime() |
將此 Java 節點從互通執行時中取消註冊。 (繼承來源 Object) |
| Wait() |
讓目前線程等候直到喚醒為止,通常是藉由em <notified/em>或<em>interrupted</em> 來喚醒它。<> (繼承來源 Object) |
| Wait(Int64, Int32) |
讓目前的線程等到喚醒為止,通常是因為 <em>notified</em> 或 <em>interrupted</em>,或直到經過一定數量的實時為止。 (繼承來源 Object) |
| Wait(Int64) |
讓目前的線程等到喚醒為止,通常是因為 <em>notified</em> 或 <em>interrupted</em>,或直到經過一定數量的實時為止。 (繼承來源 Object) |
明確介面實作
| 名稱 | Description |
|---|---|
| IJavaPeerable.Disposed() |
一個無界的阻塞佇列,使用與類別 |
| IJavaPeerable.Finalized() |
一個無界的阻塞佇列,使用與類別 |
| IJavaPeerable.JniObjectReferenceControlBlock |
一個無界的阻塞佇列,使用與類別 |
| IJavaPeerable.SetJniIdentityHashCode(Int32) |
一個無界的阻塞佇列,使用與類別 |
| IJavaPeerable.SetJniManagedPeerState(JniManagedPeerStates) |
一個無界的阻塞佇列,使用與類別 |
| IJavaPeerable.SetPeerReference(JniObjectReference) |
一個無界的阻塞佇列,使用與類別 |
| IJavaPeerable.UnregisterFromRuntime() |
一個無界的阻塞佇列,使用與類別 |
擴充方法
| 名稱 | Description |
|---|---|
| GetJniTypeName(IJavaPeerable) |
取得實例 |
| JavaAs<TResult>(IJavaPeerable) |
試著強制 |
| JavaCast<TResult>(IJavaObject) |
執行 Android 執行時間檢查的類型轉換。 |
| JavaCast<TResult>(IJavaObject) |
一個無界的阻塞佇列,使用與類別 |
| OfferAsync(IBlockingQueue, Object, Int64, TimeUnit) |
一個無界的阻塞佇列,使用與類別 |
| OfferAsync(IBlockingQueue, Object) |
一個無界的阻塞佇列,使用與類別 |
| PollAsync(IBlockingQueue, Int64, TimeUnit) |
一個無界的阻塞佇列,使用與類別 |
| PutAsync(IBlockingQueue, Object) |
一個無界的阻塞佇列,使用與類別 |
| TakeAsync(IBlockingQueue) |
一個無界的阻塞佇列,使用與類別 |
| ToEnumerable(IIterable) |
回傳 和 IEnumerable ,會對 Java IIterable進行迭代,允許 |
| ToEnumerable<T>(IIterable) |
回傳 和 IEnumerable<T> ,該 在 Java IIterable上迭代,將每個元素 集結為 |
| TryJavaCast<TResult>(IJavaPeerable, TResult) |
試著強制 |