Apache Thrift 외부 이벤트 루프

Question

C++에서 Apache Thrift 서버가 외부 이벤트를 처리하도록하려면 어떻게해야합니까? 내 자신의 이벤트 루프를 작성하고 차단하지 않고 Thrift 프로세스 보류중인 이벤트를 수동으로 만들고 싶습니다.

나는 이런 식으로 뭔가를 할 수 있도록하고 싶습니다 : 위에서

//... 
TSimpleServer server(processor, 
         serverTransport, 
         transportFactory, 
         protocolFactory); 

boost::asio::io_service io; 
boost::asio::deadline_timer t(io, boost::posix_time::seconds(5)); 
t.async_wait(&onTimer); 

while (!finished) 
{ 
    server.poll(); 
    io.poll(); 
} 

를 루프, 나는이 많이있을 것입니다 실현하면서 낭비 바쁜 대기 대기중인 이벤트가없는 경우. 이것을 피하는 방법에 대한 제안?

Answer 1

내가 알 수있는 한 Apache Thrift는 Boost.Asio 또는 다른 외부 이벤트 루프와 상호 운용 할 수있는 기본 제공 방법이 없습니다.

실제로 Asio 기반 Thrift 클라이언트/서버를 작성할 수 있습니다. 그들은 대체하는 Asio 기반 클라이언트/서버를 마무리하고 유지하는 사람이 필요하는 것

THRIFT-579: Alternative ASIO based fully async client/server for C++

: 그들은 같은 노력하고 있습니다 (실험적인 코드) 진행중인 아파치 드리프트 JIRA 작업이 있습니다.

sample server program의 스 니펫에는 TAsioServer을 boost::asio::io_service으로 전달할 수있는 방법이 나와 있습니다.

int main(int argc, char **argv) { 
    boost::asio::io_service io_service; 

    boost::shared_ptr<protocol::TProtocolFactory> protocolFactory(new protocol::TBinaryProtocolFactory()); 
    boost::shared_ptr<CalculatorAsyncHandler> handler(new CalculatorAsyncHandler(io_service)); 
    boost::shared_ptr<TProcessor> processor(new CalculatorAsyncProcessor(handler)); 

    boost::shared_ptr<apache::thrift::async::TAsioServer> server(
            new apache::thrift::async::TAsioServer(
                 io_service, 
                 9090, 
                 protocolFactory, 
                 protocolFactory, 
                 processor)); 

    server->start(); // Nonblocking 
    io_service.run(); // Blocking 

    return 0; 
} 

자신의 TAsioServer을 사용하여, 하나의 예를 들어, boost::asio::serial_port 및 boost::asio::deadline_timer 같은 boost::asio::io_service를 사용 할 수 있어야합니다.