Method serialStream1ThreadLoop

test/MultiThreadUnitTests.cpp:55–92

}

void
MultiThreadUnitTests::serialStream1ThreadLoop()
{
    size_t threadLoopStartTimeMilliseconds = getTimeInMilliSeconds() ;
    size_t timeElapsedMilliSeconds = 0;

    while (timeElapsedMilliSeconds < timeOutMilliseconds)
    {
        //
        // Write data to the serial port. It should be received by the other
        // thread.
        //
        serialStream1 << writeString1 << std::endl;
        serialStream1.DrainWriteBuffer() ;

        //
        // Wait for data to arrive from the other thread
        //
        if (serialStream1.IsDataAvailable())
        {
            alarm(5) ;   // Set a system alarm in case getline() blocks longer than 5 seconds.
            readString2.clear() ;
            getline(serialStream1, readString2) ;
            alarm(0) ;   // Deactivate the alarm.
            
            if(readString2 != writeString2)
            {
                const std::lock_guard<std::mutex> lock {mutex} ;
                failureRate++;
            } 
        }

        const std::lock_guard<std::mutex> lock {mutex} ;
        loopCount++;

        timeElapsedMilliSeconds = getTimeInMilliSeconds() - threadLoopStartTimeMilliseconds;
    }
}

void
MultiThreadUnitTests::serialStream2ThreadLoop()