运行 3 个线程时出现分段错误

Question

所以我正在创建 3 个线程。 1 读取用户的输入 1 执行一些字符串操作， 1 写入命令提示符。

我已经设置了一些cout 语句来查看我在哪里遇到了错误。我可以看到我在创建线程后的某个时候收到了错误。

我认为它必须是首先执行哪个线程的东西。我希望readerThread 函数首先运行，然后是converterThread，最后是writerThread。我一直在寻找一些方法来在这些上实现更多逻辑，以限制线程运行的顺序并且找不到任何线程。

无论如何，这是我的代码：

pthread_mutex_t lock = PTHREAD_MUTEX_INITIALIZER;
int counter = 0;
vector<string> readBuffer;
vector<string> writeBuffer;
int main (){
    int readerInt,writerInt,converterInt;
    pthread_t reader,writer,converter;
    cout << "BEFORE"<<endl;
    readerInt = pthread_create(&reader, NULL,readerThread,NULL);
    converterInt = pthread_create(&converter,NULL,converterThread,NULL);
    writerInt = pthread_create(&writer,NULL,writerThread,NULL);
    cout << "AFTER" << endl;

    pthread_join(reader,NULL);
    pthread_join(converter,NULL);
    pthread_join(writer,NULL);

    return 0;
}
void * readerThread(void *unused){
    while(1){
    pthread_mutex_lock(&lock);
    string readLine;
    getline(cin,readLine);
    counter++;
    readBuffer.push_back(readLine);
    pthread_mutex_unlock(&lock);
    }
}
void * converterThread(void *unused){
    while(1){
    pthread_mutex_lock(&lock);
    if(readBuffer.size() > 0){
        replace(readBuffer[counter-1].begin(),readBuffer[counter-1].end(),' ','%');
        writeBuffer.push_back(readBuffer[counter-1]);
    }
    pthread_mutex_unlock(&lock);
    }
}
void * writerThread(void *unused){
    while(1){
    pthread_mutex_lock(&lock);
    cout << writeBuffer[counter-1] << endl;
    pthread_mutex_unlock(&lock);
    }
}

Answer 1

您的writerThread 线程在数据到达和您访问之前启动作业：

cout << writeBuffer[counter-1] << endl;

当counter 仍然是0。您应该在访问之前检查writeBuffer 的大小。

counter 变量并不总是对writeBuffer 有效。当数据在readBuffer 中，但尚未被converterThread 处理时，就会发生这种情况。

您可以删除 counter 变量的使用并改进 readBuffer 和 writeBuffer 的数据结构。使用std::queue 创建数据转换队列。一个队列readBuffer 用于读取数据，一个writeBuffer 队列用于处理结果。使用推送/弹出方法。