在 Linux 系统中,C++ 多线程通信可以通过以下几种方式实现:
std::mutex
类来实现互斥锁。使用互斥锁时,需要注意加锁和解锁的顺序,以避免死锁。#include <iostream>
#include <thread>
#include <mutex>
std::mutex mtx;
int shared_data = 0;
void thread_func() {
std::unique_lock<std::mutex> lock(mtx);
shared_data++;
lock.unlock();
}
int main() {
std::thread t1(thread_func);
std::thread t2(thread_func);
t1.join();
t2.join();
std::cout << "Shared data: " << shared_data << std::endl;
return 0;
}
std::condition_variable
类来实现条件变量。使用条件变量时,需要与互斥锁结合使用。#include <iostream>
#include <thread>
#include <mutex>
#include <condition_variable>
std::mutex mtx;
std::condition_variable cv;
bool ready = false;
void thread_func() {
std::unique_lock<std::mutex> lock(mtx);
cv.wait(lock, []{ return ready; });
std::cout << "Thread executed" << std::endl;
}
int main() {
std::thread t1(thread_func);
{
std::lock_guard<std::mutex> lock(mtx);
ready = true;
}
cv.notify_one();
t1.join();
return 0;
}
信号量(Semaphore):信号量是一种计数器,用于控制对共享资源的访问。C++11 没有直接提供信号量的实现,但可以使用 POSIX 信号量(如 sem_t
)或第三方库(如 Boost.Thread)来实现。
消息队列(Message Queue):消息队列是一种通信方式,允许线程之间发送和接收消息。C++11 没有直接提供消息队列的实现,但可以使用 POSIX 消息队列(如 msgq
)或第三方库(如 Boost.Interprocess)来实现。
管道(Pipe):管道是一种半双工通信方式,允许线程之间发送和接收数据。C++11 提供了 std::Pipe
类来实现管道。
这些方法可以根据具体需求进行选择,以实现 C++ 多线程之间的通信。