Ubuntu——多线程实现单词统计工具

时间:2022-06-27 18:58:16
题目要求:多线程实现单词统计工具
1.区分单词原则:凡是一个非字母或数字的字符跟在字母或数字的后面,那么这个字母或数字就是单词的结尾
2.允许线程使用互斥锁来修改临界资源,确保线程间的同步与协作
3.如果两个线程需要安全地共享一个公共计数器,需要把公共计数器加锁

代码如下:

#include <stdio.h>
#include <stdlib.h>
#include <pthread.h>
#include <unistd.h>
#include <semaphore.h>
#include <string.h>

pthread_mutex_t f_mutex;//互斥信号量
FILE *fp1,*fp2;//文件指针
char ch;
int count=0;

void *pthread_function1(void *arg)//第一个子线程
{
//sleep(1);
fp1=fopen("1.txt","r");
if(!fp1)
{
printf("Open file failed!");
}
while((ch=fgetc(fp1))!=EOF)//以字符为单位读文件
{
if((ch>='a'&&ch<='z')||(ch>='0'&&ch<='9'))
continue;
pthread_mutex_lock(&f_mutex);
count++;
pthread_mutex_unlock(&f_mutex);
}
}

void *pthread_function2(void *arg)//第一个子线程
{
//sleep(1);
fp2=fopen("2.txt","r");
if(!fp2)
{
printf("Open file2 failed!");
}
while((ch=fgetc(fp2))!=EOF)//以字符为单位读文件
{
if((ch>='a'&&ch<='z')||(ch>='0'&&ch<='9'))
continue;
pthread_mutex_lock(&f_mutex);
count++;
pthread_mutex_unlock(&f_mutex);
}
}

int main()
{
pthread_t a,b;
int res;
res=pthread_mutex_init(&f_mutex,NULL);//初始化临界区
if(res!=0)
{
perror("Mutex initialization failed\n");
exit(EXIT_FAILURE);
}
res=pthread_create(&a,NULL,pthread_function1,NULL);//创建第一个子线程
if(res!=0)
{
perror("Thread creation failed\n");
exit(EXIT_FAILURE);
}
res=pthread_create(&b,NULL,pthread_function2,NULL);//创建第二个子线程
if(res!=0)
{
perror("Thread creation failed\n");
exit(EXIT_FAILURE);
}

res=pthread_join(a,NULL);//等待第一个线程结束
if(res!=0)
{
perror("Thread join failed\n");
exit(EXIT_FAILURE);
}
res=pthread_join(b,NULL);//等待第二个线程结束
if(res!=0)
{
perror("Thread join failed\n");
exit(EXIT_FAILURE);
}
printf("There have %d words in two files\n",count);//父线程运行结束
pthread_mutex_destroy(&f_mutex);
return 0;
}
这里面包含了pthread.h这一个头文件,因此再用gcc编译的时候与以往的有所不同,需要改为gcc -o <目的文件名> <原文件名> -lpthread    来进行编译。
还要创建两个测试文档1.txt和2.txt。