0

给定以下代码，您能弄清楚是什么原因导致“您输入 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
4

3 回答 3

3

输入“FAST”后：

  • sem_post（while 循环末尾的那个）--> bin-sem = 1
  • 测试 work_area == end (FALSE)
  • 测试 work_area == FAST (TRUE)
  • sem_post --> bin-sem = 2
  • work_area = 哇...
  • 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;
于 2009-03-25T15:25:00.400 回答
1

该行在线程函数中是错误的。

printf("You input %d characters\n",strlen(work_area-1));

应该是strlen(work_area)，不是strlen(work_area-1)。

于 2009-03-25T15:34:41.217 回答
0

输出似乎不是来自列出的代码版本：

printf("输入一段文字");

不能产生：

输入一些文字。输入'end'完成

此外，您或多或少地在两个线程之间不规则地控制循环，然后将它们与全局变量绑定。这是一种“goto”类型的构造，只是在自找麻烦……

保罗。

于 2009-03-25T15:03:01.950 回答