在Debian上搞C++多线程,说起来其实就两条路:C++11标准库自带的,以及老牌的POSIX线程库(pthread)。前者更现代、更面向对象,推荐优先使用;后者如果能兼容C语言或者历史项目,也依然能打。下面从环境准备开始,一步步把基础、同步机制再到进阶玩法都过一遍。

Debian C++多线程编程实践

一、环境准备:安装必要工具与库

在Debian上写C++多线程,第一步当然是确保编译器到位。打开终端,先来一套标准操作:

sudo apt update
sudo apt install g++ build-essential
# 安装g++及编译工具链

C++11的库已经集成在libstdc++里了,不需要额外装。如果用pthread,Debian默认就带了,但保险起见可以更新一下:

sudo apt install libpthread-stubs0-dev

二、C++11线程库实践(推荐)

写多线程,代码清爽很多,不用像pthread那样手动折腾一堆C风格的结构体。

1. 基础线程创建与等待

来看一个最简单的例子:创建一个线程去执行print_hello,主线程等它结束再退出。

#include 
#include 

// 线程函数:无参数、无返回值
void print_hello() {
    std::cout << "Hello from a thread!" << std::endl;
}

int main() {
    // 创建线程:传递函数名作为参数
    std::thread t(print_hello);

    // 主线程继续执行
    std::cout << "Hello from the main thread!" << std::endl;

    // 等待子线程结束(必须调用,否则程序可能提前退出)
    t.join();

    return 0;
}

编译时注意启用C++11标准并链接pthread(虽然用了,但底层还是需要pthread的):

g++ -std=c++11 -pthread multithreading_example.cpp -o multithreading_example

运行结果(顺序可能不同,因为两个线程是并发的):

Hello from the main thread!
Hello from a thread!

2. 传递参数给线程函数

线程函数可以带参数,但要注意:默认情况下参数会被复制。如果想让线程修改原变量,就得传指针或引用,并且配合互斥锁保护。下面这个例子演示了两种方式:

#include 
#include 

// 线程函数:接受int参数
void print_number(int num) {
    std::cout << "Thread received number: " << num << std::endl;
}

int main() {
    int value = 42;
    // 传递参数(自动复制)
    std::thread t(print_number, value);
    t.join();

    // 传递引用(需用std::ref包装)
    int ref_value = 100;
    std::thread t2(print_number, std::ref(ref_value));
    t2.join();

    return 0;
}

3. 多线程并发执行

实际项目中经常需要开一堆线程并行干活。比如下面这个例子,创建3个线程,每个线程负责打印一段连续的数字:

#include 
#include 
#include 

void print_range(int start, int end) {
    for (int i = start; i <= end; ++i) {
        std::cout << "Thread " << std::this_thread::get_id() << ": " << i << std::endl;
    }
}

int main() {
    const int num_threads = 3;
    std::vector threads;  // 存储线程对象

    // 创建3个线程,分别处理不同范围
    for (int i = 0; i < num_threads; ++i) {
        int start = i * 10 + 1;
        int end = start + 9;
        threads.emplace_back(print_range, start, end);
    }

    // 等待所有线程结束
    for (auto& t : threads) {
        t.join();
    }

    return 0;
}

三、pthread库实践(传统方式)

如果项目里混着C代码,或者你维护的是老项目,那pthread可能才是你的菜。它接口是C风格的,需要手动管理线程生命周期,没那么省心,但胜在通用。

1. 基础线程创建与等待

#include 
#include 

// 线程函数:返回void*,参数为void*
void* print_hello(void* arg) {
    std::cout << "Hello from a pthread!" << std::endl;
    return nullptr;
}

int main() {
    pthread_t thread_id;

    // 创建线程:参数依次为线程ID、属性(nullptr表示默认)、线程函数、参数
    if (pthread_create(&thread_id, nullptr, print_hello, nullptr) != 0) {
        std::cerr << "Failed to create thread!" << std::endl;
        return 1;
    }

    // 等待线程结束
    if (pthread_join(thread_id, nullptr) != 0) {
        std::cerr << "Failed to join thread!" << std::endl;
        return 1;
    }

    return 0;
}

编译时加-pthread就行:

g++ -pthread pthread_example.cpp -o pthread_example

2. 互斥锁保护共享资源

多个线程同时访问共享资源(比如std::cout)时,必须用互斥锁来同步。pthread用pthread_mutex_t实现:

#include 
#include 

pthread_mutex_t mutex;  // 互斥锁

void* print_numbers(void* arg) {
    int id = *((int*)arg);
    for (int i = 0; i < 3; ++i) {
        pthread_mutex_lock(&mutex);    // 加锁
        std::cout << "Thread " << id << ": " << i << std::endl;
        pthread_mutex_unlock(&mutex);  // 解锁
    }
    return nullptr;
}

int main() {
    pthread_mutex_init(&mutex, nullptr);  // 初始化互斥锁

    int ids[2] = {1, 2};
    pthread_t threads[2];

    // 创建2个线程
    for (int i = 0; i < 2; ++i) {
        if (pthread_create(&threads[i], nullptr, print_numbers, &ids[i]) != 0) {
            std::cerr << "Failed to create thread " << i << std::endl;
            return 1;
        }
    }

    // 等待线程结束
    for (int i = 0; i < 2; ++i) {
        pthread_join(threads[i], nullptr);
    }

    pthread_mutex_destroy(&mutex);  // 销毁互斥锁
    return 0;
}

四、关键注意事项

  1. 线程同步:多线程访问共享资源(全局变量、文件句柄等)时,必须用互斥锁(std::mutexpthread_mutex_t)、条件变量等机制,否则竞态条件分分钟教做人。
  2. 线程生命周期:主线程退出前,必须对每个子线程调用join()(等待它结束)或者detach()(让它自行回收)。什么都不做就退出,程序大概率会崩溃。
  3. 编译选项:用C++11线程时加-std=c++11 -pthread;用pthread时加-pthread。链接不对,程序跑不起来。
  4. 性能考虑:线程创建和销毁是有开销的。频繁创建销毁会拖慢性能,建议用线程池(比如boost::asio::thread_pool)复用线程。

到这里,Debian上C++多线程的基础实践就差不多了。选对库、做好同步、管好生命周期,就能写出稳定并发的程序。动手试试吧。

本文转载于:https://www.yisu.com/ask/38735270.html 如有侵犯,请联系zhengruancom@outlook.com删除。
免责声明:正软商城发布此文仅为传递信息,不代表正软商城认同其观点或证实其描述。