ITransferQueue インターフェイス

定義

名前空間:: Java.Util.Concurrent

アセンブリ:: Mono.Android.dll

重要

一部の情報は、リリース前に大きく変更される可能性があるプレリリースされた製品に関するものです。 Microsoft は、ここに記載されている情報について、明示または黙示を問わず、一切保証しません。

プロデューサーがコンシューマーが要素を受け取るのを待機できる BlockingQueue 。

[Android.Runtime.Register("java/util/concurrent/TransferQueue", "", "Java.Util.Concurrent.ITransferQueueInvoker")]
[Java.Interop.JavaTypeParameters(new System.String[] { "E" })]
public interface ITransferQueue : IDisposable, Java.Interop.IJavaPeerable, Java.Util.Concurrent.IBlockingQueue

[<Android.Runtime.Register("java/util/concurrent/TransferQueue", "", "Java.Util.Concurrent.ITransferQueueInvoker")>]
[<Java.Interop.JavaTypeParameters(new System.String[] { "E" })>]
type ITransferQueue = interface
    interface IBlockingQueue
    interface IQueue
    interface ICollection
    interface IIterable
    interface IJavaObject
    interface IDisposable
    interface IJavaPeerable

派生: Java.Util.Concurrent.LinkedTransferQueue

属性: RegisterAttribute JavaTypeParametersAttribute

実装: IJavaObject IJavaPeerable IIterable IBlockingQueue ICollection IQueue IDisposable

注釈

プロデューサーがコンシューマーが要素を受け取るのを待機できる BlockingQueue 。 TransferQueueは、プロデューサーが (メソッド #transfer を使用して) takeまたはpollを呼び出すことによって要素の受信を待機する場合もあれば、受信を待たずに (メソッド put を介して) 要素をエンキューする場合など、アプリケーションにメッセージを渡す場合に役立ちます。 #tryTransfer(Object) 非ブロッキングバージョンと #tryTransfer(Object,long,TimeUnit) タイムアウトバージョンの tryTransfer も使用できます。 TransferQueueは、#hasWaitingConsumerを介して、項目を待機しているスレッドがあるかどうかを照会することもできます。これは、peek操作と逆の例です。

他のブロックキューと同様に、 TransferQueue は容量に制限される可能性があります。その場合、転送操作が試行されると、最初に使用可能な領域の待機がブロックされ、その後コンシューマーによる受信の待機がブロックされる可能性があります。 SynchronousQueue、put、transferなどの容量がゼロのキューでは、実質的に同義であることに注意してください。

このインターフェイスは、Java コレクションフレームワークのメンバーです。

1.7 で追加されました。

Javaドキュメント。

このページの一部は、によって作成および共有され、に記載されている条件に従って使用される作業に基づく変更です。

プロパティ

名前	説明
Handle	基になる Android オブジェクトの JNI 値を取得します。 (継承元 IJavaObject)
HasWaitingConsumer	`true`または時間指定されたTake()を介して要素を受け取るのを待機しているコンシューマーが少なくとも 1 つ存在する場合は、Poll(Int64, TimeUnit)を返します。
IsEmpty	この`Collection`に要素が含`true`を返します。 (継承元 ICollection)
JniIdentityHashCode	ラップされたインスタンスの `java.lang.System.identityHashCode()` の値を返します。 (継承元 IJavaPeerable)
JniManagedPeerState	マネージドピアの状態。 (継承元 IJavaPeerable)
JniObjectReferenceControlBlock	プロデューサーがコンシューマーが要素を受け取るのを待機できる `BlockingQueue` 。 (継承元 IJavaPeerable)
JniPeerMembers	メンバーアクセスと呼び出しのサポート。 (継承元 IJavaPeerable)
PeerReference	ラップされたJava オブジェクトインスタンスのJniObjectReferenceを返します。 (継承元 IJavaPeerable)
WaitingConsumerCount	Take()または時間指定されたPoll(Int64, TimeUnit)を介して要素の受信を待機しているコンシューマーの数の見積もりを返します。

メソッド

名前	説明
Add(Object)	容量制限に違反せずにすぐに実行できる場合は、指定された要素をこのキューに挿入し、成功すると `true` を返し、現在使用できる領域がない場合は `IllegalStateException` をスローします。 (継承元 IQueue)
AddAll(ICollection)	指定したコレクション内のすべての要素をこのコレクションに追加します (省略可能な操作)。 (継承元 ICollection)
Clear()	このコレクションからすべての要素を削除します (省略可能な操作)。 (継承元 ICollection)
Contains(Object)	このコレクションに指定した要素が含まれている場合は、 `true` を返します。 (継承元 ICollection)
ContainsAll(ICollection)	このコレクションに指定したコレクション内のすべての要素が含まれている場合は、 `true` を返します。 (継承元 ICollection)
Disposed()	インスタンスが破棄されたときに呼び出されます。 (継承元 IJavaPeerable)
DisposeUnlessReferenced()	このインスタンスへの未処理の参照がない場合は、 `Dispose()`を呼び出します。それ以外の場合は何も実行しません。 (継承元 IJavaPeerable)
DrainTo(ICollection, Int32)	このキューから指定された数の使用可能な要素を最大で削除し、指定されたコレクションに追加します。 (継承元 IBlockingQueue)
DrainTo(ICollection)	このキューから使用可能なすべての要素を削除し、指定されたコレクションに追加します。 (継承元 IBlockingQueue)
Element()	このキューの先頭を取得しますが、削除しません。 (継承元 IQueue)
Equals(Object)	指定したオブジェクトをこのコレクションと比較して等しいかどうかを確認します。 (継承元 ICollection)
Finalized()	インスタンスが終了したときに呼び出されます。 (継承元 IJavaPeerable)
ForEach(IConsumer)	すべての要素が処理されるか、アクションが例外をスローするまで、 `Iterable` の各要素に対して指定されたアクションを実行します。 (継承元 IIterable)
GetHashCode()	このコレクションのハッシュコード値を返します。 (継承元 ICollection)
Iterator()	このコレクション内の要素に対する反復子を返します。 (継承元 ICollection)
Offer(Object, Int64, TimeUnit)	指定した要素をこのキューに挿入し、空き領域が使用可能になるまで必要な場合は、指定された待機時間まで待機します。 (継承元 IBlockingQueue)
Offer(Object)	容量制限に違反することなくすぐに行うことができる場合は、指定した要素をこのキューに挿入します。 (継承元 IQueue)
Peek()	このキューの先頭を取得しますが、削除は行いません。または、このキューが空の場合は `null` を返します。 (継承元 IQueue)
Poll()	このキューの先頭を取得して削除するか、このキューが空の場合は `null` を返します。 (継承元 IQueue)
Poll(Int64, TimeUnit)	このキューの先頭を取得して削除し、要素が使用可能になるまで必要な場合は、指定された待機時間まで待機します。 (継承元 IBlockingQueue)
Put(Object)	指定した要素をこのキューに挿入し、領域が使用可能になるまで必要に応じて待機します。 (継承元 IBlockingQueue)
RemainingCapacity()	このキューが (メモリやリソースの制約がない場合に) ブロックせずに受け入れられる、または組み込み制限がない場合に `Integer.MAX_VALUE` できる追加の要素の数を返します。 (継承元 IBlockingQueue)
Remove()	このキューの先頭を取得して削除します。 (継承元 IQueue)
Remove(Object)	指定した要素のインスタンスが存在する場合は、このコレクションから 1 つのインスタンスを削除します (省略可能な操作)。 (継承元 ICollection)
RemoveAll(ICollection)	指定したコレクションにも含まれているこのコレクションのすべての要素を削除します (省略可能な操作)。 (継承元 ICollection)
RemoveIf(IPredicate)	指定された述語を満たすこのコレクションのすべての要素を削除します (省略可能な操作)。 (継承元 ICollection)
RetainAll(ICollection)	指定したコレクションに含まれるこのコレクション内の要素のみを保持します (省略可能な操作)。 (継承元 ICollection)
SetJniIdentityHashCode(Int32)	`JniIdentityHashCode`によって返される値を設定します。 (継承元 IJavaPeerable)
SetJniManagedPeerState(JniManagedPeerStates)	プロデューサーがコンシューマーが要素を受け取るのを待機できる `BlockingQueue` 。 (継承元 IJavaPeerable)
SetPeerReference(JniObjectReference)	`PeerReference`によって返される値を設定します。 (継承元 IJavaPeerable)
Size()	このコレクション内の要素の数を返します。 (継承元 ICollection)
Spliterator()	この`Spliterator`で説明されている要素に対して`Iterable`を作成します。 (継承元 IIterable)
Take()	このキューの先頭を取得して削除し、要素が使用可能になるまで必要に応じて待機します。 (継承元 IBlockingQueue)
ToArray()	このコレクション内のすべての要素を含む配列を返します。 (継承元 ICollection)
ToArray(IIntFunction)	指定した `generator` 関数を使用して、返された配列を割り当てる、このコレクション内のすべての要素を含む配列を返します。 (継承元 ICollection)
ToArray(Object[])	このコレクション内のすべての要素を含む配列を返します。返される配列のランタイム型は、指定された配列のランタイム型です。 (継承元 ICollection)
Transfer(Object)	要素をコンシューマーに転送し、必要に応じて待機します。
TryTransfer(Object, Int64, TimeUnit)	タイムアウトが経過する前に可能な場合は、要素をコンシューマーに転送します。
TryTransfer(Object)	可能であれば、すぐに待機中のコンシューマーに要素を転送します。
UnregisterFromRuntime()	ランタイムが将来の Java.Interop.JniRuntime+JniValueManager.PeekValue 呼び出しから返されないように、このインスタンスの登録を解除します。 (継承元 IJavaPeerable)

明示的なインターフェイスの実装

名前	説明
IIterable.Spliterator()	このコレクション内の要素に対して `Spliterator` を作成します。 (継承元 ICollection)

拡張メソッド

名前	説明
GetJniTypeName(IJavaPeerable)	インスタンス `self`の型の JNI 名を取得します。
JavaAs<TResult>(IJavaPeerable)	`self`を強制的に`TResult`入力し、強制型がJava側で有効であることを確認します。
JavaCast<TResult>(IJavaObject)	Android ランタイムチェック型変換を実行します。
JavaCast<TResult>(IJavaObject)	プロデューサーがコンシューマーが要素を受け取るのを待機できる `BlockingQueue` 。
OfferAsync(IBlockingQueue, Object, Int64, TimeUnit)	プロデューサーがコンシューマーが要素を受け取るのを待機できる `BlockingQueue` 。
OfferAsync(IBlockingQueue, Object)	プロデューサーがコンシューマーが要素を受け取るのを待機できる `BlockingQueue` 。
PollAsync(IBlockingQueue, Int64, TimeUnit)	プロデューサーがコンシューマーが要素を受け取るのを待機できる `BlockingQueue` 。
PutAsync(IBlockingQueue, Object)	プロデューサーがコンシューマーが要素を受け取るのを待機できる `BlockingQueue` 。
TakeAsync(IBlockingQueue)	プロデューサーがコンシューマーが要素を受け取るのを待機できる `BlockingQueue` 。
ToEnumerable(IIterable)	Java IIterableを反復処理するIEnumerableを返します。これにより、`foreach`と LINQ をJavaコレクション型で使用できます。各要素は、Java インスタンスから対応するマネージド型にマーシャリングされます。
ToEnumerable<T>(IIterable)	Java IIterableを反復処理し、各要素を`T`にマーシャリングするIEnumerable<T>を返します。これにより、`foreach`と LINQ をJavaコレクション型で使用できます。
TryJavaCast<TResult>(IJavaPeerable, TResult)	`self`を強制的に`TResult`入力し、強制型がJava側で有効であることを確認します。

適用対象