Public 成员函数 | |
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 () |
Private 属性 | |
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().