多线程编程：使用信号量同步线程执行，保证线程终止

使用信号量保证多线程终止运行

本文将探讨如何使用信号量（semaphore）来同步两个线程（thread1 和 thread2）的执行，确保它们在特定条件下交替执行，并最终都能终止运行。

代码示例c++int x = 1;struct sem a, b, c;

void init() { a.value = 0; // 初始化信号量a为0 b.value = 0; // 初始化信号量b为0 c.value = 1; // 初始化信号量c为1}

void thread1() { while (x != 12) { wait(&c); // 等待信号量c x = x * 2; signal(&a); // 发送信号量a } exit(0);}

void thread2() { while (x != 12) { wait(&a); // 等待信号量a x = x * 3; signal(&b); // 发送信号量b } exit(0);}

代码解析

• 信号量初始化: 代码首先定义了三个信号量 a、b 和 c，并在 init() 函数中将它们分别初始化为 0、0 和 1。- 线程同步: - 线程 1 在循环中首先执行 wait(&c) 等待信号量 c。由于 c 初始值为 1，线程 1 可以立即执行，并将 x 的值乘以 2。然后，线程 1 执行 signal(&a) 发送信号量 a，唤醒正在等待信号量 a 的线程 2。 - 线程 2 在循环中首先执行 wait(&a) 等待信号量 a。由于 a 初始值为 0，线程 2 会被阻塞，直到线程 1 发送信号量 a 唤醒它。线程 2 被唤醒后，将 x 的值乘以 3，并执行 signal(&b) 发送信号量 b。- 交替执行: 通过信号量 a 和 b 的传递，线程 1 和线程 2 可以交替执行，修改共享变量 x 的值。- 终止条件: 当 x 的值等于 12 时，两个线程的循环条件将不再满足，从而退出循环并终止运行。

总结

通过使用信号量，我们可以有效地控制线程的执行顺序，确保线程在特定条件下交替执行，并最终都能按照预期终止。这种同步机制对于保证多线程程序的正确性和可靠性至关重要。