2

コードからの複数の非同期呼び出しを呼び出し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。助けてください。

4

1 に答える 1