c++ - 在 C++ 中删除和重建单例

Question

我有一个应用程序在连接不同传感器的控制硬件上运行。在加载应用程序时，它会一个一个地检查各个传感器，以查看是否根据预定义的协议(protocol)与传感器进行了正确的通信。

现在，我已经将检查单个传感器通信的代码实现为单例线程，下面是运行函数，它使用选择系统调用和管道进行进程间通信以发出线程结束信号。

void SensorClass::run()
{
    mFdWind=mPort->GetFileDescriptor();
    fd_set readfs;
    int max_fd = (mFdWind > gPipeFdWind[0] ? mFdWind : gPipeFdWind[0]) + 1;
    int res;

    mFrameCorrect=false;
    qDebug("BEFORE WHILE"); 
    while(true)
    {
        qDebug("\n IN WHILE LOOP"); 
        usleep(50);
        FD_ZERO(&readfs);
        FD_SET(mFdWind,&readfs);
        FD_SET(gPipeFdWind[0],&readfs);

        res=select(max_fd,&readfs,NULL,NULL,NULL);
        if(res < 0)
            perror("Select Failed");
        else if(res == 0)
            puts("TIMEOUT");
        else
        {
            if(FD_ISSET(mFdWind,&readfs))
            {
                puts("*************** RECEIVED DATA ****************");
                mFrameCorrect=false;
                FlushBuf();
                //int n=mPort->ReadPort(mBuf,100);
                int n=mPort->ReadPort(mBuf,100);

                if(n>0)
                {
                    Count++;


                    QString str((const char*)mBuf);
                    //qDebug("\n %s",qPrintable(str));
                    //See if the Header of the frame is valid
                    if(IsHeaderValid(str))
                    {
                        if( (!IsCommaCountOk(str)) || (!IsChecksumOk(str,mBuf)) ||  (!CalculateCommaIndexes(str))  ) 
                        {

                            qDebug("\n  not ok");
                            mFrameCorrect=false;
                        } //if frame is incorrect
                        else 
                        {
                            qDebug("\n  OK");
                            mFrameCorrect=true;
                        }//if frame is correct(checksum etc are ok)
                    }//else if header is ok
                }//if n > 0
            }//if data received FD_ISSET
            if(FD_ISSET(gPipeFdWind[0],&readfs))
                break;
        }//end nested else res not <= 0
    }//infinite loop  
}

上面的线程是从主 GUI 线程开始运行的。这运行良好。问题是我已经给了用户一个选项来随意重新测试子系统。为此，我使用

删除了单例实例

delete SensorClass::instance();

然后使用

重启单例

SensorClass::instace()->start();

问题是这次控制在进入 while 循环后立即从 run() 函数中的 while 循环中出来，我的猜测是管道读取再次从上次写入的写入管道读取。我曾尝试使用 fflush() 清除 I/O，但没有成功。我的问题是

1. 我的想法是否正确？

2. 如果是，那么我们如何清理管道？

3. 如果没有，谁能提出为什么选择性重新测试不起作用？

提前致谢..

Answer 1

fflush 清除输出缓冲区。如果你想清除输入缓冲区，你将需要读取数据或寻找结束。

我不认为“单例”模式合适。还有其他方法可以确保每个硬件最多有一个实例。如果您以后想要多个线程，每个线程使用不同的传感器怎么办？