正文

揭秘C语言线程终止的五大绝招，告别程序僵局！

/0 浏览量
0321

在C语言编程中，线程的终止是一个常见的操作，它涉及到多线程编程的复杂性和挑战。正确地终止线程对于避免程序僵局和资源泄漏至关重要。以下是五大绝招，帮助您在C语言中优雅地终止线程。

绝招一：使用pthread_join函数

pthread_join函数是C语言中用于等待线程终止的标准函数。它允许一个线程（通常称为父线程）等待另一个线程（称为子线程）的终止。以下是一个使用pthread_join的示例：

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

void* thread_function(void* arg) {
    printf("Thread is running...\n");
    sleep(5); // 模拟线程工作
    printf("Thread is exiting...\n");
    return NULL;
}

int main() {
    pthread_t thread_id;
    int rc;

    rc = pthread_create(&thread_id, NULL, thread_function, NULL);
    if (rc) {
        printf("ERROR; return code from pthread_create() is %d\n", rc);
        return 1;
    }

    pthread_join(thread_id, NULL); // 等待线程终止
    printf("Thread has finished.\n");

    return 0;
}

绝招二：使用pthread_cancel函数

pthread_cancel函数用于取消一个线程。当调用此函数时，目标线程会收到一个取消请求，如果线程正在执行取消点（cancel point），则线程会立即终止。以下是一个使用pthread_cancel的示例：

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

void* thread_function(void* arg) {
    for (int i = 0; i < 10; i++) {
        printf("Thread is running...\n");
        sleep(1);
    }
    return NULL;
}

int main() {
    pthread_t thread_id;
    int rc;

    rc = pthread_create(&thread_id, NULL, thread_function, NULL);
    if (rc) {
        printf("ERROR; return code from pthread_create() is %d\n", rc);
        return 1;
    }

    sleep(3); // 等待一段时间后取消线程
    pthread_cancel(thread_id);

    pthread_join(thread_id, NULL); // 确保线程终止
    printf("Thread has finished.\n");

    return 0;
}

绝招三：使用pthread_detach函数

pthread_detach函数用于将线程与其创建者分离。一旦线程终止，其资源将被自动回收。这样可以避免因为忘记调用pthread_join而导致的资源泄漏。以下是一个使用pthread_detach的示例：

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

void* thread_function(void* arg) {
    printf("Thread is running...\n");
    sleep(5); // 模拟线程工作
    printf("Thread is exiting...\n");
    return NULL;
}

int main() {
    pthread_t thread_id;
    int rc;

    rc = pthread_create(&thread_id, NULL, thread_function, NULL);
    if (rc) {
        printf("ERROR; return code from pthread_create() is %d\n", rc);
        return 1;
    }

    pthread_detach(thread_id); // 将线程与其创建者分离

    printf("Thread has been detached.\n");

    return 0;
}

绝招四：使用信号量（Semaphores）

信号量是一种同步机制，可以用来控制对共享资源的访问。在多线程环境中，可以使用信号量来优雅地终止线程。以下是一个使用信号量的示例：

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

pthread_mutex_t lock;
pthread_cond_t cond;

void* thread_function(void* arg) {
    pthread_mutex_lock(&lock);
    printf("Thread is waiting...\n");
    pthread_cond_wait(&cond, &lock);
    printf("Thread is continuing...\n");
    pthread_mutex_unlock(&lock);
    return NULL;
}

int main() {
    pthread_t thread_id;
    int rc;

    pthread_mutex_init(&lock, NULL);
    pthread_cond_init(&cond, NULL);

    rc = pthread_create(&thread_id, NULL, thread_function, NULL);
    if (rc) {
        printf("ERROR; return code from pthread_create() is %d\n", rc);
        return 1;
    }

    sleep(3); // 等待一段时间后唤醒线程
    pthread_cond_signal(&cond);

    pthread_join(thread_id, NULL); // 确保线程终止
    printf("Thread has finished.\n");

    pthread_mutex_destroy(&lock);
    pthread_cond_destroy(&cond);

    return 0;
}

绝招五：使用原子操作

原子操作是确保在多线程环境中操作数据的一致性和线程安全的一种方法。在C语言中，可以使用<stdatomic.h>头文件提供的原子操作。以下是一个使用原子操作的示例：

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

atomic_int counter = ATOMIC_VAR_INIT(0);

void* thread_function(void* arg) {
    for (int i = 0; i < 1000; i++) {
        atomic_fetch_add_explicit(&counter, 1, memory_order_relaxed);
    }
    return NULL;
}

int main() {
    pthread_t threads[10];
    int rc;

    for (int i = 0; i < 10; i++) {
        rc = pthread_create(&threads[i], NULL, thread_function, NULL);
        if (rc) {
            printf("ERROR; return code from pthread_create() is %d\n", rc);
            return 1;
        }
    }

    for (int i = 0; i < 10; i++) {
        pthread_join(threads[i], NULL); // 确保线程终止
    }

    printf("Final counter value: %d\n", atomic_load_explicit(&counter, memory_order_relaxed));

    return 0;
}

通过以上五大绝招，您可以在C语言中更有效地管理线程的终止，从而避免程序僵局和资源泄漏。在实际编程中，应根据具体场景选择合适的终止方法。

-- 展开阅读全文 --