公開方法(Public Methods) | |
| Channel (int capacity) | |
| Channel () | |
| void | Write (T message) throws InterruptedException |
| T | Read () throws InterruptedException |
| boolean | TryWrite (T message) |
| boolean | TryRead (T[] item) |
| void | Disconnect () |
| boolean | Offer (T msgToDeposit) |
| T | Poll (long timeout, TimeUnit unit) throws InterruptedException |
| T | Take () throws InterruptedException |
| int | Size () |
私有屬性 | |
| BlockingQueue< T > | queue |
| com.UniPRT.Sdk.Mgmt.Channel< T >.Channel | ( | int | capacity | ) |
| com.UniPRT.Sdk.Mgmt.Channel< T >.Channel | ( | ) |
| void com.UniPRT.Sdk.Mgmt.Channel< T >.Disconnect | ( | ) |
| boolean com.UniPRT.Sdk.Mgmt.Channel< T >.Offer | ( | T | msgToDeposit | ) |
| T com.UniPRT.Sdk.Mgmt.Channel< T >.Poll | ( | long | timeout, |
| TimeUnit | unit | ||
| ) | throws InterruptedException |
| T com.UniPRT.Sdk.Mgmt.Channel< T >.Read | ( | ) | throws InterruptedException |
| int com.UniPRT.Sdk.Mgmt.Channel< T >.Size | ( | ) |
| T com.UniPRT.Sdk.Mgmt.Channel< T >.Take | ( | ) | throws InterruptedException |
| boolean com.UniPRT.Sdk.Mgmt.Channel< T >.TryRead | ( | T[] | item | ) |
| boolean com.UniPRT.Sdk.Mgmt.Channel< T >.TryWrite | ( | T | message | ) |
| void com.UniPRT.Sdk.Mgmt.Channel< T >.Write | ( | T | message | ) | throws InterruptedException |
|
private |
被參考於 com.UniPRT.Sdk.Mgmt.Channel< String >.Disconnect(), com.UniPRT.Sdk.Mgmt.Channel< String >.Poll(), com.UniPRT.Sdk.Mgmt.Channel< String >.Read(), com.UniPRT.Sdk.Mgmt.Channel< String >.Size(), com.UniPRT.Sdk.Mgmt.Channel< String >.Take(), com.UniPRT.Sdk.Mgmt.Channel< String >.TryRead(), com.UniPRT.Sdk.Mgmt.Channel< String >.TryWrite(), 及 com.UniPRT.Sdk.Mgmt.Channel< String >.Write().