コードからの複数の非同期呼び出しを呼び出しthrift
ています。すべてが完了するのを待ってから、次のステージに進みます。
for (...) {
TNonblockingTransport transport = new TNonblockingSocket(host, port);
TAsyncClientManager clientManager = new TAsyncClientManager();
TProtocolFactory protocolFactory = new TBinaryProtocol.Factory();
AsyncClient c = new AsyncClient(protocolFactory, clientManager, transport);
c.function(params, callback);
}
// I would like to wait for all the calls to be complete here.
待機/通知のようなコールバックでカウントダウンを行い、これを実行できます。しかし、thrift
システムは、できればタイムアウトを使用して、非同期関数呼び出しを待機する方法を許可していますか?
TAsyncClientManager
またはに何も表示されませんでしたAsyncClient
。助けてください。