Linux下使用两个线程协作完成一个任务的简易实现

刚解决了之前的那个Linux下Pthread库的问题,这次就来使用两个线程来协作,共同完成一个求和的任务。


打一下基础吧



本次需要使用到的知识点有:

  • lpthread,编译的时候用到,相当于一个声明的效果
  • pthread_mutex_t 作为一个锁对象而存在
  • pthread_create,创建一个新线程的函数调用
  • pthread_t ,线程的类型

代码展示


#include <stdio.h>
#include <stdlib.h>
//多线程库的引用
#include<pthread.h>

//分别用于记录总和和线程的数目
int sum  ,count;
//用于对线程的入口函数进行加锁操作的变量
pthread_mutex_t lockid;
//线程的入口函数
void* runner(void *param);

int main( int argc, char*argv[])
{
    //声明两个线程
    pthread_t tid , tid2;
    pthread_attr_t attr;

    if(argc != 2){
        fprintf(stderr,"usage : a.out<integer value>\n");
        return -1;
    }

    if(atoi(argv[1])<0){
        fprintf(stderr,"%d must be >= 0 \n",atoi(argv[1]));
        return -1;
    }

    pthread_attr_init(&attr);
    //创建两个线程
    pthread_create(&tid,&attr,runner,argv[1]);
    pthread_create(&tid2,&attr,runner,argv[1]);
    //等待两个线程的结束。才唤醒主函数
    pthread_join(tid,NULL);
    pthread_join(tid2,NULL);

    //输出最后的总的计算的结果
    printf("Sum = :%d\n",sum);
}

void* runner(void *param){
    int i , upper = atoi(param);
    pthread_mutex_lock(&lockid);
    count += 1;
    printf("正在执行第%d个线程的求和运算:\n",count);
    if(count == 1){
        for(i = 1; i < upper/2 ; i++){
            sum += i ;
        }
    }else if(count ==2 ){
        for(i = upper/2; i < upper ; i++){
            sum += i ;
        }
    }else{
        printf("对不起,目前只支持两个线程了!\n");
    }
    printf("第%d个线程的运算结果是:%d\t\n",count,sum);
    pthread_mutex_unlock(&lockid);
    pthread_exit(0);
}

程序运行结果


mark@mark-pc:~/Code/C/PThreadTest$ gcc  main.c  -lpthread  -o Main
mark@mark-pc:~/Code/C/PThreadTest$ ./Main 100

正在执行第1个线程的求和运算:
第1个线程的运算结果是:1225
正在执行第2个线程的求和运算:
第2个线程的运算结果是:4950    

Sum = :4950

细节分析



下面我来说一说此段代码的核心。
首先,是创建线程之前做的一些“异常”处理,不是最重要的,但是也不可缺少。就是对参数的判断罢了。

然后,是创建线程的四个参数的具体的含义。分别是引用的线程的id,属性的引用,线程的入口函数的名称,以及要传进线程的方法的参数。
注意这里是引用类型的线程id。找出就在于可以把创建线程的结果返回给线程id。这样就完成了对其的修改。

最后,在线程的入口函数里面,我对相关项进行了处理。包括判断线程,加锁,解锁等操作。当这两个线程都执行完成的时候,唤醒主函数(可以认为是“进程”)。完成最后的输出任务!


总结



额,我这里完成的多线程的交互,并不是最标准的,甚至可以认为是“挫”。但是主要的思想还是比较的正统的。实际的开发中,需要很多方面的配合才能更好的作出多线程的协作或者交互任务。
毕竟是刚接触这方面的知识,代码中不可避免的会存在一些问题。欢迎博友们批评指正,希望能和你们共同进步!

时间: 2024-07-29 23:54:03

Linux下使用两个线程协作完成一个任务的简易实现的相关文章

两个线程都通过一个socket进行send是否需要互斥锁?

问题描述 两个线程都通过一个socket进行send是否需要互斥锁? 两个线程都通过一个socket进行send是否需要互斥锁?同理,消息队列是不是也要尼? 解决方案 如果没有出现对同个资源write操作的情况下,是完全可以不适用锁的 解决方案二: 同一个资源?不是啊,socket数全局的,两个线程都进行send数据,也就是写缓冲,如果同时发生的话,会不会出现问题啊! 解决方案三: 需要加锁.不然数据可能会写乱 解决方案四: 最好锁一下 不然如果线程执行时间戳交叉 比如发12345 和 6788

两个线程同时操作一个集合,一个线程读,一个线程写。有可能会产生并发问题吗?

问题描述 两个线程同时操作一个集合,一个线程读,一个线程写.有可能会产生并发问题吗? 我下面的代码为啥没有并发问题? 请哪位大神指导下 class Program { public Thread Threadone; public Thread Threadtwo; public event EventHandler EventRun; public static object obj=new object(); ArrayList ListArry = new ArrayList(); pri

linux shell脚本 两个变量中间有一个/ 一起输出时前面的变量出不来

问题描述 linux shell脚本 两个变量中间有一个/ 一起输出时前面的变量出不来 配置文件config.txt 内容为: abc=/home/test 计划在shell脚本中获取等号后面的路径,shell脚本如下; #!/bin/bash var=`grep abc /home/test/config.txt` #获取abc开头的一行 echo $var put_path=${put_line##*=} #截取等号后面路径 echo "${put_path}/1.txt" 可以获

Linux下Java开发环境搭建以及第一个HelloWorld_java

想在Linux进行JAVA开发吗?环境如何搭建,第一个HelloWorld如何实现,下面马上奉献:1环境搭建     1.1 Java JDK 的安装    Java JDK 是java编译和运行的必要环境,所以首先必须安装这一软件包,方法如下:     1)下载JDK压缩包,注意看好版本是x86还是x64,windows的还是           linux,要搞清楚,我下的是jdk-7u13-linux-i586.tar.gz:    2)解压压缩包,并将解压后的目录放到/usr/lib/j

linux下进程的最大线程数、进程最大数、进程打开的文件数【转】

转自:http://www.cnblogs.com/niocai/archive/2012/04/01/2428154.html ===========最大线程数============== linux 系统中单个进程的最大线程数有其最大的限制 PTHREAD_THREADS_MAX 这个限制可以在 /usr/include/bits/local_lim.h 中查看 对 linuxthreads 这个值一般是 1024,对于 nptl 则没有硬性的限制,仅仅受限于系统的资源 这个系统的资源主要就

Linux下的两个经典宏定义【转】

转自:http://www.linuxidc.com/Linux/2015-07/120014.htm 本文首先介绍Linux下的经典宏定义,感受极客的智慧,然后根据该经典定义为下篇文章作铺垫. offsetof宏定义: // 获得结构体(TYPE)的变量成员(MEMBER)在此结构体中的偏移量.#define offsetof(TYPE, MEMBER) ((size_t) &((TYPE *)0)->MEMBER) 说明:获得结构体(TYPE)的变量成员(MEMBER)在此结构体中的偏移

Linux下的两个聊天命令的使用方法

  一. write 用法:write 用户名;敲回车后,自己和对方将会同时处于聊天的状态,但是被发起连接的人只能收到发起聊天请求的人的聊天内容,但是不能回复,如果想要回复的话必须先向对方发起连接,这样以来两个人就可以聊天了,注意root可以向任何发起连接,但是其它人是不能向root发起连接的,默认情况下root的message 是disabled的.如果非要给root发起请求的话要先把root的mesg设置为y,这样设置:以root身份下输入,mesg y这样就可以了,这样其它用户就可以给ro

linux下pthread_cancel无法取消线程的原因【转】

转自:http://blog.csdn.net/huangshanchun/article/details/47420961 版权声明:欢迎转载,如有不足之处,恳请斧正. 一个线程可以调用pthread_cancel终止同一进程中的另一个线程,但是值得强调的是:同一进程的线程间,pthread_cancel向另一线程发终止信号.系统并不会马上关闭被取消线程,只有在被取消线程下次系统调用时,才会真正结束线程.或调用pthread_testcancel,让内核去检测是否需要取消当前线程.被取消的线程

Linux下C编程:线程互斥实例

/*编译时注意,要手动连接库*/ #include <stdio.h> #include <pthread.h> #include <unistd.h> #include <stdlib.h> static int value = 0; pthread_mutex_t mutex; void func(void* args) { while(1) { pthread_mutex_lock(&mutex); sleep(1); value ++; pr