正文

多线程编程：主副线程高效传递数据与同步技巧详解

/0 浏览量
0402

在多线程编程中，主副线程之间的数据传递和同步是确保程序正确性和效率的关键。本文将深入探讨这一主题，包括主副线程高效传递数据的几种方法以及同步技巧。

一、主副线程数据传递方法

1. 共享内存

共享内存是主副线程之间传递数据最直接的方式。通过在主副线程共享的内存区域读写数据，可以实现数据的快速传递。

示例代码：

#include <pthread.h>
#include <stdio.h>

int shared_data = 0;

void* thread_function(void* arg) {
    // 副线程读取共享数据
    printf("Shared data: %d\n", shared_data);
    return NULL;
}

int main() {
    pthread_t thread_id;

    // 设置共享数据
    shared_data = 10;

    // 创建副线程
    pthread_create(&thread_id, NULL, thread_function, NULL);

    // 等待副线程结束
    pthread_join(thread_id, NULL);

    return 0;
}

2. 线程局部存储（Thread Local Storage，TLS）

TLS允许每个线程拥有自己的数据副本，从而避免了共享内存带来的线程安全问题。

示例代码：

#include <pthread.h>
#include <stdio.h>

void* thread_function(void* arg) {
    // TLS变量
    static int local_data = 0;

    local_data++;
    printf("Local data: %d\n", local_data);
    return NULL;
}

int main() {
    pthread_t thread_id;

    // 创建副线程
    pthread_create(&thread_id, NULL, thread_function, NULL);

    // 等待副线程结束
    pthread_join(thread_id, NULL);

    return 0;
}

3. 线程间通信（Inter-Thread Communication，ITC）

ITC是线程之间进行通信的一种机制，包括条件变量、信号量、互斥锁等。

示例代码：

#include <pthread.h>
#include <stdio.h>

pthread_mutex_t mutex = PTHREAD_MUTEX_INITIALIZER;
pthread_cond_t cond = PTHREAD_COND_INITIALIZER;

void* thread_function(void* arg) {
    // 锁定互斥锁
    pthread_mutex_lock(&mutex);

    // 等待条件变量
    pthread_cond_wait(&cond, &mutex);

    // 解锁互斥锁
    pthread_mutex_unlock(&mutex);

    printf("Condition variable triggered\n");
    return NULL;
}

int main() {
    pthread_t thread_id;

    // 创建副线程
    pthread_create(&thread_id, NULL, thread_function, NULL);

    // 锁定互斥锁
    pthread_mutex_lock(&mutex);

    // 触发条件变量
    pthread_cond_signal(&cond);

    // 解锁互斥锁
    pthread_mutex_unlock(&mutex);

    // 等待副线程结束
    pthread_join(thread_id, NULL);

    return 0;
}

二、同步技巧

1. 互斥锁（Mutex）

互斥锁是一种常用的同步机制，用于保护共享资源，防止多个线程同时访问。

示例代码：

#include <pthread.h>
#include <stdio.h>

pthread_mutex_t mutex = PTHREAD_MUTEX_INITIALIZER;

void* thread_function(void* arg) {
    // 锁定互斥锁
    pthread_mutex_lock(&mutex);

    // 执行临界区代码
    printf("Thread %ld is running\n", pthread_self());

    // 解锁互斥锁
    pthread_mutex_unlock(&mutex);
    return NULL;
}

int main() {
    pthread_t thread_id1, thread_id2;

    // 创建副线程
    pthread_create(&thread_id1, NULL, thread_function, NULL);
    pthread_create(&thread_id2, NULL, thread_function, NULL);

    // 等待副线程结束
    pthread_join(thread_id1, NULL);
    pthread_join(thread_id2, NULL);

    return 0;
}

2. 条件变量（Condition Variable）

条件变量允许线程在某些条件下暂停执行，直到其他线程通知它们继续执行。

示例代码：

#include <pthread.h>
#include <stdio.h>

pthread_mutex_t mutex = PTHREAD_MUTEX_INITIALIZER;
pthread_cond_t cond = PTHREAD_COND_INITIALIZER;

void* thread_function(void* arg) {
    // 锁定互斥锁
    pthread_mutex_lock(&mutex);

    // 执行条件变量等待
    pthread_cond_wait(&cond, &mutex);

    // 解锁互斥锁
    pthread_mutex_unlock(&mutex);

    printf("Condition variable triggered\n");
    return NULL;
}

int main() {
    pthread_t thread_id;

    // 创建副线程
    pthread_create(&thread_id, NULL, thread_function, NULL);

    // 触发条件变量
    pthread_cond_signal(&cond);

    // 等待副线程结束
    pthread_join(thread_id, NULL);

    return 0;
}

3. 信号量（Semaphore）

信号量是一种同步机制，用于控制对共享资源的访问。

示例代码：

#include <pthread.h>
#include <stdio.h>

pthread_sem_t sem = PTHREAD_SEM_INITIALIZER(1);

void* thread_function(void* arg) {
    // 获取信号量
    pthread_sem_wait(&sem);

    // 执行临界区代码
    printf("Thread %ld is running\n", pthread_self());

    // 释放信号量
    pthread_sem_post(&sem);
    return NULL;
}

int main() {
    pthread_t thread_id1, thread_id2;

    // 创建副线程
    pthread_create(&thread_id1, NULL, thread_function, NULL);
    pthread_create(&thread_id2, NULL, thread_function, NULL);

    // 等待副线程结束
    pthread_join(thread_id1, NULL);
    pthread_join(thread_id2, NULL);

    return 0;
}

通过以上方法，我们可以有效地在主副线程之间传递数据，并确保程序的同步与正确性。在实际开发中，根据具体需求选择合适的方法和技巧至关重要。

-- 展开阅读全文 --