c++ - ACE Reactor フレームワークでの単一イベントに対する複数のハンドラ

Question

着信接続を受け入れるサーバーを設計しています。クライアントは、サーバーが応答する必要がある要求を送信することがありますが、ほとんどの場合、サーバーはいくつかのイベントを検出し、接続されているすべてのクライアントにイベントをブロードキャストします。基本的に私が持っているのはこれです：

#include <ace/Acceptor.h>
#include <ace/INET_Addr.h>
#include <ace/Reactor.h>
#include <ace/SOCK_Acceptor.h>
#include <ace/SOCK_Stream.h>
#include <ace/Svc_Handler.h>

#include <iostream>
#include <thread>

// XXX: for simplicity
HANDLE const hEvent = ::CreateEvent(NULL, FALSE, FALSE, NULL);

class MyService
  : public ACE_Svc_Handler<ACE_SOCK_STREAM, ACE_NULL_SYNCH>
{
public:
  MyService() : signalCount_(0) { }

  int open(void*) override
  {
    ACE_Reactor::instance()->register_handler(
        this,
        ACE_Event_Handler::READ_MASK);

    ACE_Reactor::instance()->register_handler(
        this,
        hEvent);

    return 0;
  }

  int handle_input(ACE_HANDLE) override
  {
    // Handle stuff coming in from clients.
    return 0;
  }

  int handle_signal(int, siginfo_t*, ucontext_t*) override
  {
    // handle the detected event, send to client.
    std::cout
      << signalCount_++ << " "
      << this << " "
      << __FUNCTION__
      << std::endl;
    return 0;
  }

  unsigned signalCount_;
};

typedef ACE_Acceptor<MyService, ACE_SOCK_ACCEPTOR> MyAcceptor;

int main()
{
  WSADATA wsData;
  WSAStartup(MAKEWORD(2, 0), &wsData);

  std::thread thr([=]()
  {
    // simulate the events.
    Sleep(1000);
    SetEvent(hEvent);
  });

  auto r = ACE_Reactor::instance();
  MyAcceptor acceptor(ACE_INET_Addr(1234), r);

  r->run_reactor_event_loop();
}

ここでの問題は、hEvent が設定されるたびに、MyService の最初のインスタンスだけがその handle_signal を呼び出すことです。1 つのイベントに対して 1 つのハンドラーのみが許可されているようですが、ハンドラーは複数のイベントを処理できます。複数のハンドラーを 1 つのイベントとして処理するにはどうすればよいですか?

イベントを manual-reset-event にすると、イベントが設定されている限り、すべてのハンドラで handle_signal が呼び出されます。しかし、それは本当に私が望んでいることではありません。クライアントに同じイベントが複数回通知されることは望ましくありません。

イベントの代わりにセマフォを使用して、目標を達成しました。

HANDLE const hEvent = ::CreateSemaphore(NULL, 0, 16, NULL);

そして、 MyService のコンストラクターとデストラクタが接続されているクライアントの数をカウントするようにして、セマフォを正しい回数解放できるようにしました。

  std::thread thr([=]()
  {
     while (true)
     {
        Sleep(1000);
        ReleaseSemaphore(hEvent, clientCount, nullptr);
     }
  });

これは間違っているようで、ハックのようなにおいがします。ACEでこれを行う適切な方法はありますか?