Mutex(互斥鎖)是一種同步原語,用于防止多個線程同時訪問共享資源。不同編程語言提供了不同的方式來創建和使用Mutex鎖。以下是幾種常見編程語言中Mutex鎖的實現方式:
C++11及以上版本:
std::mutex
類,它提供了lock()
、unlock()
和try_lock()
等方法來控制對共享資源的訪問。#include <mutex>
std::mutex mtx;
void safe_increment() {
mtx.lock();
// 訪問共享資源
++counter;
mtx.unlock();
}
Java:
java.util.concurrent.locks.Mutex
接口提供了與std::mutex
類似的功能。ReentrantLock
類來實現Mutex
接口。import java.util.concurrent.locks.ReentrantLock;
public class Counter {
private final ReentrantLock lock = new ReentrantLock();
private int counter = 0;
public void increment() {
lock.lock();
try {
// 訪問共享資源
++counter;
} finally {
lock.unlock();
}
}
}
Python:
threading
模塊提供了Lock
類來實現互斥鎖。import threading
class Counter:
def __init__(self):
self.lock = threading.Lock()
self.counter = 0
def increment(self):
with self.lock:
# 訪問共享資源
self.counter += 1
C#:
System.Threading.Monitor
類提供了類似Mutex的功能。Monitor.Enter()
和Monitor.Exit()
方法來保護代碼塊。using System.Threading;
public class Counter {
private int counter = 0;
public void Increment() {
Monitor.Enter(this);
try {
// 訪問共享資源
++counter;
} finally {
Monitor.Exit(this);
}
}
}
請注意,在使用Mutex鎖時,務必確保在訪問共享資源之前獲取鎖,并在訪問完成后釋放鎖。這可以防止多個線程同時訪問共享資源而導致的數據不一致問題。