-
22-08-2019 - |
题
对于下面的代码,你能找出 "您输入了 7 个字符 "出现 3 次的原因吗? 上次呢?
#include <stdio.h>
#include <unistd.h>
#include <stdlib.h>
#include <string.h>
#include <pthread.h>
#include <semaphore.h>
void *thread_function(void *arg);
sem_t bin_sem;
#define WORK_SIZE 1024
char work_area[WORK_SIZE];
int main(){
int res;
pthread_t a_thread;
void *thread_result;
res = sem_init(&bin_sem,0,0);
if (res!=0){
perror("Semaphore initialization failed");
exit(EXIT_FAILURE);
}
res = pthread_create(&a_thread,NULL,thread_function,NULL);
if (res!=0){
perror("Thread creation failed");
exit(EXIT_FAILURE);
}
printf("Input some text. Enter ‘end’ to finish");
while (strncmp("end",work_area,3)!=0){
if(strncmp(work_area,"FAST",4)==0){
sem_post(&bin_sem);
strcpy(work_area,"Wheeee...");
}else{
fgets(work_area,WORK_SIZE,stdin);
}
sem_post(&bin_sem);
}
printf("\nWaiting for thread to finish\n");
res = pthread_join(a_thread,&thread_result);
if(res!=0){
perror("Thread join failed!");
exit(EXIT_FAILURE);
}
printf("Thread joined\n");
sem_destroy(&bin_sem);
exit(EXIT_SUCCESS);
}
void *thread_function(void* arg){
sem_wait(&bin_sem);
while(strncmp("end",work_area,3)!=0){
printf("You input %d characters\n",strlen(work_area-1));
sem_wait(&bin_sem);
}
pthread_exit(NULL);
}
测试输入/输出:
$ cc -D_REENTRANT thread3a.c -o thread3a -lpthread
$ ./thread3a
Input some text. Enter ‘end’ to finish
Excession
You input 9 characters
FAST
You input 7 characters
You input 7 characters
You input 7 characters
end
Waiting for thread to finish...
Thread joined
解决方案
输入“FAST”后:
- sem_post(while 循环末尾的那个)--> bin-sem = 1
- 测试是否work_area == end (FALSE)
- 测试 work_area == FAST (TRUE)
- sem_post --> bin-sem = 2
- 工作区 = 哎哟...
- sem_post(while 循环末尾的那个)--> bin-sem = 3
- 测试是否work_area == end (FALSE)
- 测试 work_area = FAST(FALSE)
- 等待输入
我认为主线程具有优先级,直到调用 fgets(..stdin..) 时被阻塞,然后线程函数可以运行并消耗信号量令牌。
这是发生的事情的痕迹。
> Input some text.
Main thread :
work_area = ?;
bin_sem = 0;
thread function :
wait on semaphore;
< Excession
Main thread :
work_area = Excession;
bin_sem = 1;
thread function :
work_area == Excession; (!= end)
> You input 9 characters; (1)
bin_sem = 0;
wait on semaphore;
Main thread :
work_area == Excession; (!= end)
work_area == Excession; (!= FAST)
< FAST
bin_sem = 1;
work_area == FAST; (!= end)
work_area == FAST;
bin_sem = 2;
work_area == Wheeee...;
bin_sem = 3;
wait on stdin;
thread function :
work_area == Wheeee...; (!= end)
> You input 7 characters; (Why seven?)
bin_sem = 3-1 = 2;
> You input 7 characters; (Why seven?)
bin_sem = 2-1 = 1;
> You input 7 characters; (Why seven?)
bin_sem = 1-1 = 0;
wait on semaphore;
其他提示
此线是错误的线程函数。
printf("You input %d characters\n",strlen(work_area-1));
它应该是strlen(work_area)
,不strlen(work_area-1)
。
的输出不似乎是从代码的列出版本:
的printf( “输入一些文本”);
不能产生:
输入一些文本。进入“结束”来完成
此外,你已经你两个线程之间循环控制不稳定或多或少分裂,然后用一个全局变量绑定它们。这是一种“转到”结构类型,这只是自找麻烦...
保罗。
不隶属于 StackOverflow