ForkJoinPool.IManagedBlocker 介面

定義

命名空間:

Java.Util.Concurrent

組件:

Mono.Android.dll

用於擴展在 s 中 ForkJoinPool執行任務的管理平行處理介面。

[Android.Runtime.Register("java/util/concurrent/ForkJoinPool$ManagedBlocker", "", "Java.Util.Concurrent.ForkJoinPool/IManagedBlockerInvoker")]
public interface ForkJoinPool.IManagedBlocker : Android.Runtime.IJavaObject, IDisposable, Java.Interop.IJavaPeerable

[<Android.Runtime.Register("java/util/concurrent/ForkJoinPool$ManagedBlocker", "", "Java.Util.Concurrent.ForkJoinPool/IManagedBlockerInvoker")>]
type ForkJoinPool.IManagedBlocker = interface
    interface IJavaObject
    interface IDisposable
    interface IJavaPeerable

屬性

RegisterAttribute

實作

IJavaObject IJavaPeerable IDisposable

備註

用於擴展在 s 中 ForkJoinPool執行任務的管理平行處理介面。

A ManagedBlocker 提供了兩種方法。 若不需要阻塞，則必須返回#isReleasable方法true。 如果有需要，方法 #block 會封鎖目前執行緒（例如在實際封鎖前先內部 isReleasable 調用）。 這些動作可由任何執行 ForkJoinPool#managedBlock(ManagedBlocker)緒呼叫執行。 這個 API 中不尋常的方法允許同步器，這些同步器可能會（但通常不會）長時間阻擋。 同樣地，它們允許更有效率地內部處理可能需要額外工作者但通常不需要的案例，以確保足夠的平行性。 為此，方法 isReleasable 的實作必須能夠反覆被引用。 在先前呼叫 或 isReleasableblocktrue後，兩種方法都不會被調用。

舉例來說，這裡有一個基於 ReentrantLock 的 ManagedBlocker：

{@code
            class ManagedLocker implements ManagedBlocker {
              final ReentrantLock lock;
              boolean hasLock = false;
              ManagedLocker(ReentrantLock lock) { this.lock = lock; }
              public boolean block() {
                if (!hasLock)
                  lock.lock();
                return true;
              }
              public boolean isReleasable() {
                return hasLock || (hasLock = lock.tryLock());
              }
            }}

這裡有一個類別可能會阻擋在特定佇列中等待某個項目：

{@code
            class QueueTaker<E> implements ManagedBlocker {
              final BlockingQueue<E> queue;
              volatile E item = null;
              QueueTaker(BlockingQueue<E> q) { this.queue = q; }
              public boolean block() throws InterruptedException {
                if (item == null)
                  item = queue.take();
                return true;
              }
              public boolean isReleasable() {
                return item != null || (item = queue.poll()) != null;
              }
              public E getItem() { // call after pool.managedBlock completes
                return item;
              }
            }}

Java 文件 java.util.concurrent.ForkJoinPool.ManagedBlocker。

本頁部分內容為基於 Open Source Project 所創建與分享的作品，並依授權條款所描述的使用進行修改。

屬性

名稱	Description
Handle	取得底層 Android 物件的 JNI 值。 (繼承來源 IJavaObject)
IsReleasable	如果不需要阻擋，則會回傳為真。
JniIdentityHashCode	回傳包裹實例的 java.lang.System.identityHashCode() 值。 (繼承來源 IJavaPeerable)
JniManagedPeerState	管理貴族的狀況。 (繼承來源 IJavaPeerable)
JniObjectReferenceControlBlock	用於擴展在 s 中 ForkJoinPool執行任務的管理平行處理介面。 (繼承來源 IJavaPeerable)
JniPeerMembers	成員存取與召喚支援。 (繼承來源 IJavaPeerable)
PeerReference	回傳JniObjectReference包裹後的 Java 物件實例。 (繼承來源 IJavaPeerable)

方法

名稱	Description
Block()	可能會阻塞目前執行緒，例如等待鎖定或條件。
Disposed()	當實例被處理後才被召喚。 (繼承來源 IJavaPeerable)
DisposeUnlessReferenced()	如果沒有未解決的參考資料，則 Dispose()呼叫;否則，則不做任何事。 (繼承來源 IJavaPeerable)
Finalized()	當實例完成後才會被通知。 (繼承來源 IJavaPeerable)
SetJniIdentityHashCode(Int32)	將回傳的值設為 JniIdentityHashCode。 (繼承來源 IJavaPeerable)
SetJniManagedPeerState(JniManagedPeerStates)	用於擴展在 s 中 ForkJoinPool執行任務的管理平行處理介面。 (繼承來源 IJavaPeerable)
SetPeerReference(JniObjectReference)	將回傳的值設為 PeerReference。 (繼承來源 IJavaPeerable)
UnregisterFromRuntime()	取消註冊此實例，讓執行時不會在未來 Java.Interop.JniRuntime+JniValueManager.PeekValue 的呼叫中回傳該實例。 (繼承來源 IJavaPeerable)

擴充方法

名稱	Description
GetJniTypeName(IJavaPeerable)	取得實例 self類型的 JNI 名稱。
JavaAs<TResult>(IJavaPeerable)	試著強制self輸入 TResult，檢查 強制在 Java 端是否有效。
JavaCast<TResult>(IJavaObject)	執行 Android 執行時檢查型別轉換。
JavaCast<TResult>(IJavaObject)	用於擴展在 s 中 ForkJoinPool執行任務的管理平行處理介面。
TryJavaCast<TResult>(IJavaPeerable, TResult)	試著強制self輸入 TResult，檢查 強制在 Java 端是否有效。