Linux 多线程编程入门：线程基础、创建、生产者消费者与线程安全

gcc -o test test.c -pthread

void *fun(void *arg)//线程函数 { for (int i = 0; i < 7; i++) { printf("fun run\n"); sleep(1); } pthread_exit("fun exit");//退出线程 } int main() { pthread_t id; //定义线程id pthread_create(&id, NULL, fun, NULL);//创建线程 //第一个参数传id的地址，创建成功后给id赋值；最后一个参数是交给fun函数的参数 for (int i = 0; i < 2; i++) { printf("main run\n"); sleep(1); } char* s = NULL; pthread_join(id, (void**)&s);//等待线程结束 //最后一个参数传二级指针，指向线程函数想返回给主函数的信息（&s：让s指向"fun exit"） printf("s=%s\n",s); }

#include <stdio.h> #include <stdlib.h> #include <unistd.h> #include <string.h> #include <pthread.h> #include <semaphore.h> #define BUFF_MAX 30 #define SC_NUM 2 #define XF_NUM 3 int buff[BUFF_MAX] = {0};//缓冲区 int in = 0;//产生数据的位置 int out = 0;//消费数据的位置 sem_t sem_empty;//代表空格子的数目，生产者参考 sem_t sem_full;//代表有数据的格子数目，消费者参考 pthread_mutex_t mutex;//控制对缓冲区的互斥性访问，互斥锁 void* sc_fun(void* arg) { for(int i = 0; i < 30; i++) { sem_wait(&sem_empty);//p(s1) pthread_mutex_lock(&mutex);//加锁 buff[in] = rand() % 100;//产生数据 printf("生产者在%d,产生数据：%d\n",in,buff[in]); in = (in + 1) % BUFF_MAX; pthread_mutex_unlock(&mutex);//解锁 sem_post(&sem_full);//v(s2) sleep(1); } } void* xf_fun(void* arg) { for(int i = 0; i < 20; i++) { sem_wait(&sem_full);//p(s2) pthread_mutex_lock(&mutex);//加锁 printf("-----消费者在%d,位置打印 %d\n",out,buff[out]); out = (out + 1) % BUFF_MAX; pthread_mutex_unlock(&mutex);//解锁 sem_post(&sem_empty);//v(s1) sleep(1); } } int main() { pthread_mutex_init(&mutex,NULL); sem_init(&sem_empty,0,BUFF_MAX);//s1 sem_init(&sem_full,0,0);//s2 pthread_t sc_id[SC_NUM];//生产者线程组 pthread_t xf_id[XF_NUM];//消费者线程组 for(int i = 0; i < SC_NUM; i++) { pthread_create(&sc_id[i],NULL,sc_fun,NULL);//创建两个生产者 } for(int i = 0; i < XF_NUM; i++) { pthread_create(&xf_id[i],NULL,xf_fun,NULL);//创建三个消费者 } //等待线程结束 for(int i = 0; i < SC_NUM;i++) { pthread_join(sc_id[i],NULL); } for(int i = 0; i < XF_NUM;i++) { pthread_join(xf_id[i],NULL); } sem_destroy(&sem_empty); sem_destroy(&sem_full); pthread_mutex_destroy(&mutex); exit(0); }

#include <stdio.h> #include <stdlib.h> #include <string.h> #include <unistd.h> #include <pthread.h> pthread_mutex_t mutex;//互斥锁 pthread_cond_t cond;//条件变量 char buff[128] = {0};//存放键盘输入的数据 void *funa(void* arg)//线程函数a { while(1) { pthread_mutex_lock(&mutex);//加锁 pthread_cond_wait(&cond, &mutex); //wait：放在等待队列中，先进行解锁操作，解锁前阻塞，唤醒返回时进行加锁操作 pthread_mutex_unlock(&mutex);//解锁 if( strncmp(buff, "end", 3) == 0 ) { break; } printf("funa buff=%s\n",buff); } } void *funb(void* arg)//线程函数b { while(1) { pthread_mutex_lock(&mutex); pthread_cond_wait(&cond, &mutex); pthread_mutex_unlock(&mutex); if( strncmp(buff, "end", 3) == 0 ) { break; } printf("funb buff=%s\n",buff); } } int main() { pthread_mutex_init(&mutex, NULL); pthread_cond_init(&cond, NULL); pthread_t ida, idb; pthread_create(&ida, NULL, funa, NULL); pthread_create(&idb, NULL, funb, NULL); while(1) { fgets(buff, 128, stdin); if( strncmp(buff, "end", 3) == 0 ) { pthread_mutex_lock(&mutex); pthread_cond_broadcast(&cond);//唤醒所有线程函数 pthread_mutex_unlock(&mutex); break; } else { pthread_mutex_lock(&mutex); pthread_cond_signal(&cond);//仅唤醒一个线程函数 pthread_mutex_unlock(&mutex); } } pthread_join(ida, NULL); pthread_join(idb, NULL); pthread_mutex_destroy(&mutex);//销毁锁 pthread_cond_destroy(&cond);//销毁条件变量 exit(0); }