快捷導(dǎo)航

C語(yǔ)言中的線程信號(hào)控制詳解

更新時(shí)間：2023年02月03日 09:02:42 作者：我要出家當(dāng)?shù)朗?

這篇文章主要通過(guò)一些示例為大家詳細(xì)介紹一下C語(yǔ)言中的線程信號(hào)控制，文中的示例代碼講解詳細(xì)，對(duì)我們深入了解C語(yǔ)言有一定的幫助，感興趣的可以學(xué)習(xí)一下

一、場(chǎng)景介紹

存在三個(gè)線程，一個(gè)主線程和兩個(gè)子線程（子線程數(shù)量不固定）。為了節(jié)省頻繁創(chuàng)建銷(xiāo)毀線程造成的資源浪費(fèi)，將這些線程設(shè)置為常駐線程。但這樣引入了一個(gè)新的問(wèn)題，如何協(xié)調(diào)這些線程完成工作。

主線程內(nèi)是循環(huán)檢測(cè)某個(gè)文件夾內(nèi)文件的變動(dòng)，當(dāng)文件夾內(nèi)出現(xiàn)新的文件時(shí)，更新可拷貝文件列表，并告知子線程開(kāi)始干活；子線程拷貝結(jié)束后需要告知主線程任務(wù)完成了，主線程開(kāi)始下一輪檢測(cè)。

二、解決方法

1、臨時(shí)線程

主線程每次檢測(cè)完畢后，新建子線程執(zhí)行拷貝任務(wù)，并阻塞等待線程任務(wù)的結(jié)束。

#include "main.h"
 
void *filecopy_thread(void *args)
{
    pthread_t id = pthread_self();
    PTHREAD_ARGS *thread_args = (PTHREAD_ARGS *)args;
    string dst_dir = thread_args->dst_dir;
    while (1)
    {
        // get the file to copy
        pthread_mutex_lock(thread_args->mutex);
        // exit when the list is empty
        if (thread_args->file_list.empty())
        {
            pthread_mutex_unlock(thread_args->mutex);
            break;
        }
        string src_file = thread_args->file_list.back();
        thread_args->file_list.pop_back();
        pthread_mutex_unlock(thread_args->mutex);
        copy_file(src_file, dst_dir);
    }
    return NULL;
}
 
 
int main(int argc, char **argv)
{
    while(1)
    {
        bool is_switch = oracle.is_redolog_switch();
 
        // judge whether the redolog has bean switched
        if ( is_switch )
        {
            printf("pthread create\n");
            pthread_t *pthread_list = (pthread_t *)malloc(sizeof(pthread_t) * cfg_utils.m_filecopy_pcount);
            if (!pthread_list)
            {
                LOG_F(ERROR, "pthread list created failed");
                continue;
            }
            pthread_mutex_t mutex;
            pthread_mutex_init(&mutex, NULL);
            PTHREAD_ARGS pthread_args = {file_list_src, &mutex, cfg_utils.m_logbk_syspath, &oncebk_count};
            
            struct timeval start, end;
            gettimeofday(&start, NULL);
                        
            // start file copy thread
            for (int i = 0; i < cfg_utils.m_filecopy_pcount; i++)
            {
                 printf("creating pthread(%d)\n", i + 1);
                pthread_create(pthread_list + i, NULL, filecopy_thread, &pthread_args);
            }
            // block until all file has copied
            for (int i = 0; i < cfg_utils.m_filecopy_pcount; i++)
            {
                pthread_join(pthread_list[i], NULL);
            }
            
            gettimeofday(&end, NULL);
            double timeuse = ( end.tv_sec - start.tv_sec ) + (end.tv_usec - start.tv_usec)/1000000.0;
            printf("%.1lf(s)\n", timeuse);
            
            pthread_mutex_destroy(&mutex);
            free(pthread_list);
 
        }
        sleep(cfg_utils.m_bk_cycle);
    }
    return 0;
}

（1）優(yōu)點(diǎn)

邏輯簡(jiǎn)單

（2）缺點(diǎn)

頻繁創(chuàng)建與銷(xiāo)毀線程，資源浪費(fèi)。