1.实现互斥机制
#include <head.h>
char buf[128]; //全局数组，临界资源
//1、创建一个互斥锁
pthread_mutex_t mutex;
//定义分支线程
void *task(void *arg)
{
while(1)
{
//3、获取锁资源
pthread_mutex_lock(&mutex);
printf("分支线程中：buf = %s\n", buf);
strcpy(buf, "I love China\n");
//4、释放锁资源
pthread_mutex_unlock(&mutex);
}
}
int main(int argc, const char *argv[])
{
//定义线程号变量
pthread_t tid;
//2、初始化互斥锁
pthread_mutex_init(&mutex, NULL);
//创建线程
if(pthread_create(&tid, NULL, task, NULL) != 0)
{
printf("tid create error\n");
return -1;
}
//主线程
while(1)
{
//3、获取锁资源
pthread_mutex_lock(&mutex);
printf("主线程中buf = %s\n", buf); //访问临界资源
strcpy(buf, "hello world\n");
//4、释放锁资源
pthread_mutex_unlock(&mutex);
}
pthread_join(tid, NULL); //阻塞回收线程资源
//5、销毁锁资源
pthread_mutex_destroy(&mutex);
return 0;
}2.实现同步机制
#include <head.h>
//1、创建一个无名信号量
sem_t sem;
//生产者线程
void *task1(void *arg)
{
while(1)
{
sleep(2);
printf("我生产了一辆特斯拉\n");
//4、释放资源
sem_post(&sem);
}
}
//消费者线程
void *task2(void *arg)
{
while(1)
{
//3、申请资源，如果没有资源，则在该处阻塞
sem_wait(&sem);
printf("我消费了一辆特斯拉\n");
}
}
int main(int argc, const char *argv[])
{
//创建两个线程
pthread_t tid1,tid2;
//2、初始化无名信号量
sem_init(&sem, 0, 0);
//第一个0：表示用于线程之间的通信
//第二个0：表示value初始值为0
//创建生产者线程
if(pthread_create(&tid1, NULL, task1, NULL) != 0)
{
printf("tid1 create error\n");
return -1;
}
//创建消费者线程
if(pthread_create(&tid2, NULL, task2, NULL) != 0)
{
printf("tid2 create error\n");
return -1;
}
//主线程回收资源
pthread_join(tid1, NULL);
pthread_join(tid2, NULL);
//5、销毁无名信号量
sem_destroy(&sem);
return 0;
}3.使用三个线程完成两个文件的拷贝，线程1完成拷贝前一半，线程2完成拷贝后一半，主线程回收两个分支线程的资源
1 #include <head.h>
2 sem_t sem;
3 struct Info
4 {
5 int fd1;
6 int fd2;
7 int size;
8 };
9
10 void *task1(void *buf)
11 {
12 //不断得将源文件中的内容读出，并写入的目标文件中
13 //直到源文件读取一半结束
14 char buf1[1] = "";
15 int count=0;
16 lseek(((struct Info*)buf)->fd1,0,SEEK_SET);
17 while(1)
18 {
19 memset(buf1, 0, sizeof(buf1)); //将容器清空
20 int res = read(((struct Info*)buf)->fd1, buf1, sizeof(buf1)); //从源文件中读取数据
21 count+=res;
22 //对读取的数据个数进行判断
23 if(count>((struct Info*)buf)->size/2)
24 {
25 break;
26 }
27 write(((struct Info*)buf)->fd2, buf1, res); //将数据写入目标文件
28 }sem_post(&sem);
29 pthread_exit(NULL);
30 }
31 void *task2(void *buf)
32 {
33 sem_wait(&sem);
34 lseek(((struct Info*)buf)->fd1,(((struct Info *)buf)->size)/2,SEEK_SET);
35 //不断得将源文件中的内容读出，并写入的目标文件中
36 //直到源文件读取后一半结束
37 char buf2[128] = "";
38 while(1)
39 {
40 memset(buf2, 0, sizeof(buf2)); //将容器清空
41 int res = read(((struct Info *)buf)->fd1, buf2, sizeof(buf2)); //从源文件中读取数据
42 //对读取的数据个数进行判断
43 if(res==0)
44 {
45 break;
46 }
47 write(((struct Info*)buf)->fd2, buf2, res); //将数据写入目标文件
48 }
49 pthread_exit(NULL);
50 }
51 int main(int argc, const char *argv[])
52 {
53 //判断传入的文件个数
54 if(argc != 3)
55 {
56 printf("input file error\n");
57 printf("usage:./a.out srcfile dstfile\n");
58 return -1;
59 }
60 //定义文件描述符变量
61 int fd1, fd2;
62 //以只读的形式打开源文件
63 if((fd1 = open(argv[1], O_RDONLY)) ==-1)
64 {
65 perror("open srcfile error");
66 return -1;
67 }
68 //以只写的形式打开目标文件
69 if((fd2 = open(argv[2], O_WRONLY|O_CREAT|O_TRUNC, 0664)) ==-1)
70 {
71 perror("open dstfile error");
72 return -1;
73 }
74 sem_init(&sem, 0, 0);
75 unsigned int size;
76 size = lseek(fd1, 0, SEEK_END);
77 struct Info buf = {fd1, fd2, size};
78 //定义一个线程号变量
79 pthread_t tid1,tid2;
80 //创建出一个分支线程
81 if(pthread_create(&tid1, NULL, task1, &buf) != 0)
82 {
83 printf("tid create error\n");
84 return -1;
85 }
86 if(pthread_create(&tid2, NULL, task2, &buf) != 0)
87 {
88 printf("tid create error\n");
89 return -1;
90 }
91 pthread_join(tid1, NULL);
92 pthread_join(tid2, NULL);
93 sem_destroy(&sem);
94 close(fd1);
95 close(fd2);
96 return 0;
97 }4.使用三个线程完成：线程1输出字符'A',线程2输出字符'B',线程3输出字符'C',要求输出结果为：ABCABCABCABCABC...
#include <head.h>
sem_t sem1,sem2,sem3;//无名信号量
void *task1(void *arg)
{
while(1)
{
sem_wait(&sem1);//询问当前任务的无名信号量（下同）
putchar('A');
fflush(stdout);//刷新缓冲区（下同）
sleep(1);
sem_post(&sem2);//将下一个任务的无名信号量改变为1（下同）
}
}
void *task2(void *arg)
{
while(1)
{
sem_wait(&sem2);
putchar('B');
fflush(stdout);
sleep(1);
sem_post(&sem3);
}
}
void *task3(void *arg)
{
while(1)
{
sem_wait(&sem3);
putchar('C');
fflush(stdout);
sleep(1);
sem_post(&sem1);
}
}
int main(int argc, const char *argv[])
{
//无名信号量初始化
sem_init(&sem1,0,1);
sem_init(&sem2,0,0);
sem_init(&sem3,0,0);
//定义三个线程
pthread_t tid1,tid2,tid3;
if(pthread_create(&tid1,NULL,task1,NULL)!=0)
{
printf("error1\n");
return -1;
}
if(pthread_create(&tid2,NULL,task2,NULL)!=0)
{
printf("error2\n");
return -1;
}
if(pthread_create(&tid3,NULL,task3,NULL)!=0)
{
printf("error3\n");
return -1;
}
//进程收尸
pthread_join(tid1,NULL);
pthread_join(tid2,NULL);
pthread_join(tid3,NULL);
return 0;
}
