如何解决并发 C 应用程序中的多线程问题

结果应该始终是8000。然而，根据线程的执行顺序，结果会有很大的不同。
使用信号量，程序员可以保护关键区域，以便在任何给定时间只有一个线程可以访问全局变量:
Copy Code
/* Include statements omitted */# defineNUM_THREADS 8# defineLOOP_ITERATIONS 1000 sem_tsemaphore; pthread_tthreads[NUM_THREADS]; intresult = 0; void* createThread( void* id){ inttmp; for( inti = 0; i < LOOP_ITERATIONS; i++) { sem_wait(semaphore); tmp = result; tmp = tmp + 1; result = tmp; sem_post(semaphore); } returnNULL;} int main( intargc, char* argv[]){ sem_init(&semaphore, 0, 1); for( inti = 0; i < NUM_THREADS; i++) pthread_create(&threads , NULL, createThread, NULL);for(inti = 0; i < NUM_THREADS; i++) pthread_join(threads, NULL); sem_close(&semaphore);return0;}
此代码示例的新版本包含一个全局信号量变量，main 方法的第一行初始化该信号量。初始化调用的最后一个参数定义有多少个线程可以同时进入关键区域。然后，程序像之前一样生成多个线程。但是，在 createThread 方法的循环中，每个线程在使用变量之前检查它是否可以访问该变量。接下来，sem _ wait 方法请求访问，sem _ post 方法向变量发出信号，表示线程已离开关键部分。最后，main 方法的倒数第二行关闭信号量变量。请注意，信号量是特定于操作系统的，因此方法的确切名称可能会有所不同。但是，一般原则适用于所有操作系统和实现。
使用锁实现互斥锁如果您认为信号量对于实现简单的互斥锁来说太强大了，那么您还可以使用一个不需要信号量的特殊锁函数。这里，一个线程在进入临界区域之前调用 lock 函数，然后通过调用解锁函数释放锁:
Copy Code
#defineNUM_THREADS 8#defineLOOP_ITERATIONS 1000pthread_mutex_tlock;pthread_tthreads[NUM_THREADS];intresult = 0;void*createThread(void* id){inttmp;for(inti = 0; i < LOOP_ITERATIONS; i++) { pthread_mutex_lock(&lock); tmp = result; tmp = tmp + 1; result = tmp; pthread_mutex_unlock(&lock); }returnNULL;}intmain(intargc,char* argv[]){for(inti = 0; i < NUM_THREADS; i++) pthread_create(&threads, NULL, createThread, NULL);for(inti = 0; i < NUM_THREADS; i++) pthread_join(threads, NULL);return0;}

您可以看到锁调用发生在与前面的二进制信号量调用相同的位置。您可能想知道为什么要在锁上使用信号量。无需详细说明，锁始终与一个线程相关联，只有该线程可以解锁该区域。因此，如果该线程崩溃、冻结或进入死锁状态，无论是操作系统还是更高优先级的线程都无法在不结束整个程序的情况下解锁关键部分。除了其他原因，信号量也更加灵活，因为它们可以允许多个线程进入一个区域，而不仅仅是一个线程。
如何在多线程 C 程序中实现条件同步
当您回想上一篇文章中讨论的另一个大问题时，信号量增加的灵活性就变得很明显了。除了管理关键区域之外，并发线程有时还必须以特定的顺序运行，这可以通过使用信号量来实现。例如，假设线程 A 必须总是在线程 B 执行任务 Y 之前完成任务 X。您可以通过使用信号量来实现这个时间表:
Copy Code
/* import statements omitted */#defineLOOP_ITERATIONS 10000#defineMULTIPLIER 100intresult = 0;sem_tsemaphore;void*createThreadB(void* id){ sem_wait(semaphore); result = result * MULTIPLIER;returnNULL;}void*createThreadA(void* id){for(inti = 0; i < LOOP_ITERATIONS; i++) result = result + 1; sem_post(semaphore);returnNULL;}intmain(intargc,char* argv[]){pthread_tthreadA;pthread_tthreadB; sem_init(&semaphore, 0, 0); pthread_create(&threadA, NULL, createThreadA, NULL); pthread_create(&threadB, NULL, createThreadB, NULL); pthread_join(threadA, NULL); pthread_join(threadB, NULL); sem_close(&semaphore); // Should be 1.000.000 printf("The result is: %d
", result);return0;}
请注意，在本例中，main 方法是如何创建起始值为零的信号量的。线程 A 不等信号量，而线程 B 等信号量。因此，线程 A 始终可以在 createThreadA 方法内运行代码，而不必等待任何其他线程。一旦线程 A 完成其代码的执行，它就增加信号量。这样做使线程 B 也能够运行。但是，请注意，线程 A 总是在线程 B 开始执行任何代码之前完成其任务。这个简单的示例说明了如何使用信号量实现条件同步。

摘要
本文讨论了在多线程 C 程序中使用 POSIX 线程实现互斥锁和条件同步的几种方法。如前所述，信号量是高级操作系统实现的一个引人注目的概念。实际上，信号量包含一个计数器变量和一个队列。每当一个线程想要进入一个关键区域时，它就会请求信号量的权限。如果信号量计数器大于零，则线程可以进入。否则，操作系统将该线程放在等待列表中，并允许它在另一个线程退出关键区域时继续运行。二进制信号量可以对互斥锁进行建模，而且使用简单的锁也可以得到同样的结果。
但是，信号量比简单的锁更灵活，您可以使用它们来模拟各种其他情况。例如，信号量也可以实现条件同步。在这里，将信号量的计数器初始化为值为零。然后，其中一个线程可以立即继续，而另一个请求可以从信号量访问关键区域。当然，信号量会阻止第二个线程的访问。一旦第一个线程完成了它的任务，它就会增加信号量计数器，第二个线程就可以运行了。此过程保证第一个线程始终在第二个线程之前运行。