c++

linux c++多线程怎样通信

小樊
82
2024-12-03 23:59:38
栏目: 编程语言

在 Linux 系统中,C++ 多线程通信可以通过以下几种方式实现:

  1. 互斥锁(Mutex):互斥锁是一种同步机制,用于确保多个线程在访问共享资源时不会发生冲突。C++11 提供了 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;
}
  1. 条件变量(Condition Variable):条件变量是一种同步机制,用于在多个线程之间传递消息。C++11 提供了 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;
}
  1. 信号量(Semaphore):信号量是一种计数器,用于控制对共享资源的访问。C++11 没有直接提供信号量的实现,但可以使用 POSIX 信号量(如 sem_t)或第三方库(如 Boost.Thread)来实现。

  2. 消息队列(Message Queue):消息队列是一种通信方式,允许线程之间发送和接收消息。C++11 没有直接提供消息队列的实现,但可以使用 POSIX 消息队列(如 msgq)或第三方库(如 Boost.Interprocess)来实现。

  3. 管道(Pipe):管道是一种半双工通信方式,允许线程之间发送和接收数据。C++11 提供了 std::Pipe 类来实现管道。

这些方法可以根据具体需求进行选择,以实现 C++ 多线程之间的通信。

0
看了该问题的人还看了