Linux detached(分离线程) 消费者和生产者模型

1.分离线程常用库

把一个线程的属性设置为 detachd 的状态，让系统来回收它的资源，而不再需要在其它线程中对其进行 pthread_join() 操作。

<pthread.h>
pthread_t tid;
pthread_attr_t attr;
pthread_attr_init(&attr);
pthread_attr_setdetachstate(&attr, PTHREAD_CREATE_DETACHED);
pthread_create(&tid, &attr, THREAD_FUNCTION, NULL);

2.如果把一个线程设为分离的线程，一定要在主线程中循环的等待一下新创建的线程执行，否则就会出现，新创建的线程还没执行结束呢，主线程已经执行结束了

3.采用消费者生产者模型，链表为“消费者对象”，一个生产者，两个消费者。

1.头文件定义 “detach.h”

#include <stdio.h>
#include <string.h>
#include <stdlib.h>
#include <pthread.h>
#include <sys/types.h>
#include <unistd.h>
#include <semaphore.h>
#include <pthread.h>
typedef struct Nodes
{int num;struct Nodes *next;
} Nodes;

2.函数实现 “detach.c”

#include "detach.h"
void printNode(Nodes *head)
{Nodes *temp = head;if (NULL == head){printf("head is NULL! \n");return;}else{while (temp != NULL){printf("get datas is %d \n", temp->num);temp = temp->next;}}
}

3.主函数实现

#include "detach.h"
pthread_mutex_t mutex = PTHREAD_MUTEX_INITIALIZER;
pthread_cond_t cond = PTHREAD_COND_INITIALIZER;
sem_t sem;Nodes *head = NULL;Nodes *createNodes()
{Nodes *nodes = (Nodes *)malloc(sizeof(Nodes));nodes->next = NULL;return nodes;
}
Nodes *addTail(int i)
{Nodes *tempNode = head;Nodes *newNode = NULL;newNode = createNodes();newNode->num = i;if (NULL == head){head = newNode;return head;}else{while (tempNode->next != NULL){tempNode = tempNode->next;}tempNode->next = newNode;newNode->next = NULL;return newNode;}
}
void deleNode(Nodes *newNode)
{Nodes *temp = NULL;if (NULL == newNode){return;}else if (newNode == head){temp = head->next;free(newNode);head = temp;}else{temp = head->next;free(head);}
}
void printids(const char *s)
{pid_t pid;pthread_t tid;pid = getpid();tid = pthread_self();printf("%s :pid :%d tid :%d\n", s, (unsigned int)pid, (unsigned int)tid);
}
void *thr_product(void *arg)
{int i;int flag;int x;Nodes *newNode = head;printids("start thread_producter!");pthread_mutex_lock(&mutex);for (i = 0; i < 5; i++){newNode = addTail(i);}pthread_cond_signal(&cond);pthread_mutex_unlock(&mutex);
}
void *thr_conmone(void *arg)
{int i = 0;pthread_mutex_lock(&mutex);pthread_cond_wait(&cond, &mutex);printids("thread_consumer_one start!");// sem_post(&sem);// sem_wait(&sem);while (head != NULL){printf("consumer one get node msg:%d\n", head->num);deleNode(head);if (i == 2){pthread_mutex_unlock(&mutex);sem_post(&sem);}sleep(2);i++;}}
void *thr_conmtwo(void *arg)
{sem_wait(&sem);printids("thread_consumer_two start!");while (head != NULL){printf("consumer two get node msg:%d\n", head->num);deleNode(head);}sem_post(&sem);
}
int main(int argc, char **argv)
{int err;pthread_t thr_dh_product;pthread_t thr_dh_conmone;pthread_t thr_dh_conmtwo;pthread_attr_t attr;sem_init(&sem, 0, 0);pthread_attr_init(&attr);pthread_attr_setdetachstate(&attr, PTHREAD_CREATE_DETACHED);err = pthread_create(&thr_dh_product, &attr, thr_product, NULL);if (0 != err){printf("pthread_create failed: %s\n", strerror(err));}else{printf("thr_producter start success!\n");}err = pthread_create(&thr_dh_conmone, &attr, thr_conmone, NULL);if (0 != err){printf("thr_consumer_one failed:%s\n", strerror(err));}else{printf("thr_consumer_one success! \n");}err = pthread_create(&thr_dh_conmtwo, &attr, thr_conmtwo, NULL);if (0 != err){printf("thr_consumer_two failed:%s\n", strerror(err));}else{printf("thr_consumer_two success! \n");}sleep(5);pthread_attr_destroy(&attr);sem_destroy(&sem);return 0;
}

4.关与Makefile的编写

TARGET=test
CC=gcc
INCLUDE=./
LIBS=-lpthread
OBJS=main.o detach.o
${TARGET}:${OBJS}${CC} -g -Wall -o ${TARGET} ${OBJS} ${LIBS}
main.o:main.c${CC} -c main.c
detach.o:detach.c${CC} -c detach.c
.PHONY:clean
clean:rm -f *.o ${TARGET}

5.实验现象

thr_producter start success!
thr_consumer_one success!
start thread_producter! :pid :21274 tid :1363531520
thr_consumer_two success!
thread_consumer_one start! :pid :21274 tid :1355138816
consumer one get node msg:0
consumer one get node msg:1
consumer one get node msg:2
thread_consumer_two start! :pid :21274 tid :1346746112
consumer two get node msg:3
consumer two get node msg:4

Linux detached(分离线程) 消费者和生产者模型相关推荐

java消费者和生产者模型_Java实现简易生产者消费者模型过程解析
一.概述一共两个线程,一个线程生产产品,一个线程消费产品,使用同步代码块方法,同步两个线程.当产品没有时,通知生产者生产,生产者生产后,通知消费者消费,并等待消费者消费完. 需要注意的是,有可能出现 ...
【Linux入门】多线程(线程概念、生产者消费者模型、消息队列、线程池)万字解说
目录 1️⃣线程概念什么是线程线程的优点线程的缺点线程异常线程异常 Linux进程VS线程 2️⃣线程控制创建线程获取线程的id 线程终止等待线程线程分离 3️⃣线程互斥进程线程间 ...
【Linux下】线程同步生产者与消费者模型
文章目录 [Linux下] 线程同步生产者与消费者模型线程同步同步概念与竞态条件条件变量条件变量本质操作条件变量初始化和销毁条件变量等待唤醒通过条件变量实现的简单线程同步例子为什 ...
Linux系统编程---17（条件变量及其函数，生产者消费者条件变量模型，生产者与消费者模型（线程安全队列），条件变量优点，信号量及其主要函数，信号量与条件变量的区别，）
条件变量条件变量本身不是锁!但它也可以造成线程阻塞.通常与互斥锁配合使用.给多线程提供一个会合的场所. 主要应用函数: pthread_cond_init 函数 pthread_cond_destr ...
用三个线程实现生产者消费者模型，其中一个线程作为生产者，二个线程作为消费者，生产者随机生产一个时间戳或者字符串，消费者消费这个时间戳，并不能重复消费，并将其打印出来
题目要求: 用三个线程实现生产者消费者模型,其中一个线程作为生产者,二个线程作为消费者,生产者随机生产一个时间戳或者字符串,消费者消费这个时间戳,并不能重复消费,并将其打印出来.(这是一道百度面试的算 ...
线程同步之生产者消费者模型详解
前言博主本来没打算讲这个比较前面的知识的(博主socket编程还有两个部分没讲,进程也才写完回收僵尸进程的三种方法,信号捕捉器也才完结),但是今天有朋友来问博主,什么是生产者消费者模型,所以博主就先 ...
linux使用线程实现生产者消费者问题,Linux平台下线程同步，实现“生产者消费者问题”...
(1)线程同步,实现"生产者消费者问题" 要求:缓冲区大小为20,生产者每次放一个产品,消费者每次取走一个产品:生产者和消费者至少2个. (2)代码如下: #include #in ...
Linux 多线程开发-线程的属性-分离detached和连接joinable
1.描述 linux的POSIX线程分离状态决定一个线程以什么方式来终止.默认的分离状态是可连接态(joinable),创建线程是参数设置为NULL,就是默认连接态,可以被pthread_join. ...
Linux信号量与互斥锁解决生产者与消费者问题
先来看什么是生产者消费者问题: 生产者消费者问题(英语:Producer-consumer problem),也称有限缓冲问题(英语:Bounded-buffer problem),是一个多线程同步问 ...

Linux detached(分离线程) 消费者和生产者模型

1.分离线程常用库

2.如果把一个线程设为分离的线程，一定要在主线程中循环的等待一下新创建的线程执行，否则就会出现，新创建的线程还没执行结束呢，主线程已经执行结束了

3.采用消费者生产者模型，链表为“消费者对象”，一个生产者，两个消费者。

Linux detached(分离线程) 消费者和生产者模型相关推荐

最新文章

热门文章