Function BOOST_AUTO_TEST_CASE

Disruptor.Tests/LifecycleAwareTests.cpp:57–78

};

BOOST_AUTO_TEST_CASE(ShouldNotifyOfBatchProcessorLifecycle)
{
    ManualResetEvent startSignal(false);
    ManualResetEvent shutdownSignal(false);
    auto ringBuffer = std::make_shared< RingBuffer< StubEvent > >([] { return StubEvent(0); }, 16);

    auto sequenceBarrier = ringBuffer->newBarrier();
    auto eventHandler = std::make_shared< LifecycleAwareEventHandler >(startSignal, shutdownSignal);
    auto batchEventProcessor = std::make_shared< BatchEventProcessor< StubEvent > >(ringBuffer, sequenceBarrier, eventHandler);

    auto thread = std::thread([&] { batchEventProcessor->run(); });

    startSignal.waitOne();
    batchEventProcessor->halt();

    shutdownSignal.waitOne();

    thread.join();

    BOOST_CHECK_EQUAL(eventHandler->startCounter(), 1);
    BOOST_CHECK_EQUAL(eventHandler->shutdownCounter(), 1);
}

BOOST_AUTO_TEST_SUITE_END()