文章详情

短信预约-IT技能 免费直播动态提醒

请输入下面的图形验证码

提交验证

短信预约提醒成功

C语言中的线程信号控制详解

2023-02-03 12:00

关注

一、场景介绍

存在三个线程,一个主线程和两个子线程(子线程数量不固定)。为了节省频繁创建销毁线程造成的资源浪费,将这些线程设置为常驻线程。但这样引入了一个新的问题,如何协调这些线程完成工作。

主线程内是循环检测某个文件夹内文件的变动,当文件夹内出现新的文件时,更新可拷贝文件列表,并告知子线程开始干活;子线程拷贝结束后需要告知主线程任务完成了,主线程开始下一轮检测。

二、解决方法

1、临时线程

主线程每次检测完毕后,新建子线程执行拷贝任务,并阻塞等待线程任务的结束。

#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)优点

逻辑简单

(2)缺点

频繁创建与销毁线程,资源浪费。

2、全局变量信号

定义一个全局变量作为线程的控制信号。

主线程将该信号设置为子线程的个数的负数,以启动子线程。

当该信号小于 0 时,子线程开始启动。子线程的启动与任务完毕都需要将该信号加一。

当主线程检测到该信号为线程总数时推导子线程本次任务结束。

(1)优点

子线程作为常驻线程,节省了一定的资源。

(2)缺点

子线程与主线程在等待信号的过程中要么造成 CPU 的空转,要么 sleep 会增加程序的处理时延。

而且,子线程启动与结束都对全局信号进行加一的操作,极端情况(某些线程执行速度存在极端差异)下可能造成信号控制的紊乱。

3、信号量

使用两组信号:start_signal 和 over_signal。

主线程启动子线程时,需要将 start_signal 赋值为子线程数,over_signal 赋值为0.

子线程执行down(start_signal) ,该操作执行成功即可执行任务逻辑,执行完后 up(over_signal)。

主线程需要执行 num 次down(over_signal)操作,只有所有子线程执行结束,该操作才可以执行完成。

在等待执行信号down和up的过程中,线程都是阻塞的,不会造成 CPU 的空转,当信号可操作时也会立即执行,不会增加操作时延。

到此这篇关于C语言中的线程信号控制详解的文章就介绍到这了,更多相关C语言线程信号控制内容请搜索编程网以前的文章或继续浏览下面的相关文章希望大家以后多多支持编程网!

阅读原文内容投诉

免责声明:

① 本站未注明“稿件来源”的信息均来自网络整理。其文字、图片和音视频稿件的所属权归原作者所有。本站收集整理出于非商业性的教育和科研之目的,并不意味着本站赞同其观点或证实其内容的真实性。仅作为临时的测试数据,供内部测试之用。本站并未授权任何人以任何方式主动获取本站任何信息。

② 本站未注明“稿件来源”的临时测试数据将在测试完成后最终做删除处理。有问题或投稿请发送至: 邮箱/279061341@qq.com QQ/279061341

软考中级精品资料免费领

  • 历年真题答案解析
  • 备考技巧名师总结
  • 高频考点精准押题
  • 2024年上半年信息系统项目管理师第二批次真题及答案解析(完整版)

    难度     813人已做
    查看
  • 【考后总结】2024年5月26日信息系统项目管理师第2批次考情分析

    难度     354人已做
    查看
  • 【考后总结】2024年5月25日信息系统项目管理师第1批次考情分析

    难度     318人已做
    查看
  • 2024年上半年软考高项第一、二批次真题考点汇总(完整版)

    难度     435人已做
    查看
  • 2024年上半年系统架构设计师考试综合知识真题

    难度     224人已做
    查看

相关文章

发现更多好内容

猜你喜欢

AI推送时光机
位置:首页-资讯-后端开发
咦!没有更多了?去看看其它编程学习网 内容吧
首页课程
资料下载
问答资讯