更多資料請關注微信公眾號：Linux兵工廠
在多進程或多線程的操作系統環境中，同步和互斥是關鍵的概念，用于確保共享資源的正確訪問。下面是同步和互斥的設計原理以及在 Linux 中的實現方式：
同步（Synchronization）
同步是指協調多個執行線程或進程的執行，以確保它們按照一定的順序執行或在特定的條件下等待。常見的同步機制包括信號量、條件變量和屏障等。
設計原理
-
原子操作： 原子操作是不可分割的操作，要么全部執行，要么都不執行。在同步中，原子操作是確保線程或進程安全執行的基本要素。
-
互斥訪問： 同步的一個關鍵目標是確保共享資源的互斥訪問，即同一時刻只有一個線程或進程能夠訪問共享資源。
-
條件等待： 同步機制通常需要支持條件等待，即一個線程或進程在某個條件滿足前等待，而其他線程或進程在條件滿足時通知等待的線程繼續執行。
-
順序保持： 同步還可能涉及到對執行順序的控制，以確保線程或進程按照期望的順序執行。
在 Linux 中的實現
-
信號量： 通過信號量可以實現對資源的計數，確保同一時刻只有有限數量的線程或進程能夠訪問共享資源。在 Linux 中，信號量通常使用
sem_init、sem_wait和sem_post等函數進行操作。 -
條件變量： 條件變量允許線程在某個條件滿足前等待，以及在條件滿足時被通知繼續執行。在 Linux 中，條件變量通常使用
pthread_cond_init、pthread_cond_wait和pthread_cond_signal等函數進行操作。
互斥（Mutex）
互斥是一種用于確保共享資源互斥訪問的機制。在多線程或多進程環境中，互斥鎖是最常見的互斥機制。
設計原理
-
互斥鎖： 互斥鎖是一種用于確保在同一時刻只有一個線程能夠訪問共享資源的鎖。當一個線程獲得互斥鎖時，其他線程必須等待。
-
臨界區： 臨界區是一段代碼，可能訪問共享資源，而且同一時刻只能有一個線程進入。互斥鎖通常用于保護臨界區。
-
死鎖避免： 設計互斥機制時需要考慮死鎖的避免，確保系統不會因為互斥鎖的使用而陷入無法解除的等待。
在 Linux 中的實現
-
互斥鎖（Mutex）： 在 Linux 中，互斥鎖通常通過
pthread_mutex_init、pthread_mutex_lock和pthread_mutex_unlock等函數進行操作。它們允許線程安全地進入和退出臨界區。 -
自旋鎖（Spinlock）： 自旋鎖是一種在等待互斥鎖時不會讓出 CPU 而是一直循環檢查的鎖。在 Linux 中，自旋鎖通常通過
spin_lock和spin_unlock進行操作。
以上是在 Linux 中實現同步和互斥的一些常見機制。具體的選擇取決于應用的需求，以及對性能和可維護性的權衡。
在下面的示例代碼中，我將展示使用互斥鎖（Mutex）和條件變量（Condition Variable）來實現簡單的同步機制。這里使用了 POSIX 線程庫的相關函數。
#include <stdio.h>
#include <stdlib.h>
#include <pthread.h>
#define BUFFER_SIZE 5
int buffer[BUFFER_SIZE];
int count = 0;
pthread_mutex_t mutex = PTHREAD_MUTEX_INITIALIZER;
pthread_cond_t cond_producer = PTHREAD_COND_INITIALIZER;
pthread_cond_t cond_consumer = PTHREAD_COND_INITIALIZER;
void *producer(void *arg) {
for (int i = 0; i < 10; ++i) {
pthread_mutex_lock(&mutex);
while (count == BUFFER_SIZE) {
// 緩沖區滿，等待消費者消費
pthread_cond_wait(&cond_producer, &mutex);
}
buffer[count++] = i;
printf("Produced: %d\n", i);
// 通知消費者可以消費了
pthread_cond_signal(&cond_consumer);
pthread_mutex_unlock(&mutex);
}
pthread_exit(NULL);
}
void *consumer(void *arg) {
for (int i = 0; i < 10; ++i) {
pthread_mutex_lock(&mutex);
while (count == 0) {
// 緩沖區空，等待生產者生產
pthread_cond_wait(&cond_consumer, &mutex);
}
int item = buffer[--count];
printf("Consumed: %d\n", item);
// 通知生產者可以生產了
pthread_cond_signal(&cond_producer);
pthread_mutex_unlock(&mutex);
}
pthread_exit(NULL);
}
int main() {
pthread_t producer_thread, consumer_thread;
// 創建生產者和消費者線程
pthread_create(&producer_thread, NULL, producer, NULL);
pthread_create(&consumer_thread, NULL, consumer, NULL);
// 等待線程結束
pthread_join(producer_thread, NULL);
pthread_join(consumer_thread, NULL);
// 銷毀互斥鎖和條件變量
pthread_mutex_destroy(&mutex);
pthread_cond_destroy(&cond_producer);
pthread_cond_destroy(&cond_consumer);
return 0;
}
這個簡單的示例演示了一個生產者-消費者問題，其中生產者線程負責往緩沖區中生產數據，而消費者線程負責從緩沖區中消費數據。互斥鎖 mutex 用于確保對共享資源的互斥訪問，而條件變量 cond_producer 和 cond_consumer 用于在緩沖區滿或空時進行等待和通知。
請注意，實際應用中的同步和互斥可能更加復雜，具體的設計取決于應用的需求。
下面是一個簡單的示例代碼，演示了如何使用 Linux 中的 pthread_mutex_t 來實現互斥鎖。這個示例中，兩個線程共享一個計數器，通過互斥鎖確保對計數器的互斥訪問。
#include <stdio.h>
#include <pthread.h>
// 共享的計數器
int counter = 0;
// 互斥鎖
pthread_mutex_t mutex = PTHREAD_MUTEX_INITIALIZER;
// 線程函數，增加計數器的值
void* increment_counter(void* arg) {
for (int i = 0; i < 100000; ++i) {
// 上鎖
pthread_mutex_lock(&mutex);
// 訪問共享資源
counter++;
// 解鎖
pthread_mutex_unlock(&mutex);
}
pthread_exit(NULL);
}
int main() {
// 創建兩個線程
pthread_t thread1, thread2;
pthread_create(&thread1, NULL, increment_counter, NULL);
pthread_create(&thread2, NULL, increment_counter, NULL);
// 等待線程結束
pthread_join(thread1, NULL);
pthread_join(thread2, NULL);
// 銷毀互斥鎖
pthread_mutex_destroy(&mutex);
// 輸出最終的計數器值
printf("Final Counter Value: %d\n", counter);
return 0;
}
在這個例子中，兩個線程并發地增加 counter 變量的值。由于兩個線程共享同一個變量，存在競爭條件。互斥鎖 mutex 用來確保對 counter 的互斥訪問，一個線程在訪問 counter 時先上鎖，完成后再解鎖，這樣另一個線程才能進入。
要使用互斥鎖，需要注意以下幾點：
-
初始化互斥鎖： 使用
PTHREAD_MUTEX_INITIALIZER或者pthread_mutex_init來初始化互斥鎖。 -
上鎖和解鎖： 使用
pthread_mutex_lock來上鎖，使用pthread_mutex_unlock來解鎖。在臨界區內對共享資源的訪問應該位于上鎖和解鎖之間。 -
銷毀互斥鎖： 在不再需要互斥鎖時，使用
pthread_mutex_destroy來銷毀它。
以上代碼演示了如何使用互斥鎖來確保對共享資源的安全訪問，防止競爭條件。