Method addCommand_

source/MRViewer/MRCommandLoop.cpp:115–155

}

void CommandLoop::addCommand_( CommandFunc func, bool blockThread, StartPosition state )
{
    std::exception_ptr exception;
    if ( blockThread )
    {
        // Adjust the `func` to store thrown exceptions.
        func = [next = std::move( func ), &exception]
        {
            try
            {
                next();
            }
            catch ( ... )
            {
                exception = std::current_exception();
            }
        };
    }

    auto& inst = instance_();
    std::shared_ptr<Command> cmd = std::make_shared<Command>();
    cmd->state = state;
    cmd->func = func;
    cmd->threadId = std::this_thread::get_id();
    std::unique_lock<std::mutex> lock( inst.mutex_ );
    if ( inst.queueClosed_ )
    {
        spdlog::debug( "CommandLoop::addCommand_: cannot accept new command because it is closed" );
        return;
    }
    inst.commands_.push( cmd );

    getViewerInstance().postEmptyEvent();
    if ( blockThread )
    {
        cmd->callerThreadCV.wait( lock );

        if ( exception )
            std::rethrow_exception( exception );
    }
}

void skipFramesAfterInput()
{