互斥锁在 Linux 中没有像我希望的那样工作

Question

我正在尝试锁定两个互斥锁，以便每个线程（总共 8 个线程）的输出不会混淆。代码的主要部分创建这 8 个线程并将策略设置为 FIFO。它有点工作，但不是所有的线程输出。下面的代码是整个代码中唯一包含任何类型的任何互斥锁的函数。

代码是：

void* print_message_function2( void* x )
{   

ostringstream convert;

long int num = (long int) x;
long int counter = 0;

pthread_mutex_lock(&mutex1);
string ThreadId;
convert << num;
ThreadId = convert.str();

cout << "Thread " << ThreadId << " is started";
cout << endl;
pthread_mutex_unlock(&mutex1);
while(globalstop == false)
{
counter++;
}
pthread_mutex_lock(&mutex2);
string LoopCounter;
convert << counter;
LoopCounter = convert.str();

cout << "Thread "<< ThreadId <<" Looped: " << LoopCounter;
cout << endl;
pthread_mutex_unlock(&mutex2);
pthread_exit (NULL);
}

也是来自 bourne shell 的示例输出：

Thread 1 is started
Thread 5 is started
Thread 3 is started
Thread 7 is started

Thread 1 Looped: 1185961319

Answer 1

你发布的代码对我来说很好如果我使用printf而不是cout；这解释了为什么会出现这种情况：Is cout synchronized/thread-safe?。

您可以通过与每个互斥锁关联一个全局计数器来验证您的线程是否到达了正确的部分（问题仅在于打印），并在每个关键部分增加关联的计数器，并打印它们的最终值一旦所有线程都退出了。