私は C のプログラムに苦労しています。これは、1 つのスレッド (リーダー) がファイル内の行にある 2 つの int を読み取り、それらを出力することになっているマルチスレッド プログラムです。もう一方のスレッドは、int を追加してから、結果を出力する必要があります。
シグナルとの通信のみが許可され、ミューテックス、セマフォ、または条件変数は許可されません。
私が抱えている問題は、たとえば numbers.txt を引数としてプログラムを実行すると、何も起こらないように見えることです。ファイルを開こうとすると止まると思いますが、よくわかりません。
誰かが提供しなければならない助けをいただければ幸いです、ありがとう。
編集:straceで実行しました。何が起こったのですか:http://pastebin.com/DPf6RPKf
#include <stdio.h>
#include <stdlib.h>
#include <math.h>
#include <signal.h>
#include <unistd.h>
#include <sys/types.h>
#include <sys/wait.h>
#include <pthread.h>
//Struct for numbers and file
typedef struct
{
int num0, num1;
FILE *fp;
pid_t *pid;
unsigned int seed;
} pair_t;
static void cleanExitReader()
{
printf("Goodbye from Reader Thread");
}
static void cleanExitCalc()
{
printf("Goodbye from Calculator Thread");
}
//Reader thread
static void *
readerThread(void *numPair_in)
{
//Install cleanup handler
pthread_cleanup_push(cleanExitReader, NULL);
//Cast numPair_in as the struct
pair_t * numPair;
numPair = (pair_t *)numPair_in;
unsigned int seed;
//Create sigset and block
sigset_t blockSigs;
sigaddset(&blockSigs, SIGUSR1);
sigaddset(&blockSigs, SIGUSR2);
pthread_sigmask(SIG_BLOCK, &blockSigs, NULL);
//Create a sigset for sigwait to listen for.
sigset_t listenSigs;
sigemptyset(&listenSigs);
sigaddset(&listenSigs, SIGUSR1);
int listenSigs_r;
//Reading loop
while(1)
{
//Wait for signal from main before starting.
sigwait(&listenSigs, &listenSigs_r);
if(fscanf(numPair->fp, "%d %d", &numPair->num0, &numPair->num1) == EOF)
continue;
usleep(rand_r(&seed) % 10000);
printf("%d %d", numPair->num0, numPair->num1);
kill(*numPair->pid, SIGUSR1);
}
pthread_cleanup_pop(1);
}
//Calculator thread
static void *
calcThread(void *numPair_in)
{
//Install cleanup handler
pthread_cleanup_push(cleanExitCalc, NULL);
unsigned int seed;
//Cast numPair_in as the struct
pair_t * numPair;
numPair = (pair_t *)numPair_in;
//Create sigset and block
sigset_t blockSigs;
sigaddset(&blockSigs, SIGUSR1);
sigaddset(&blockSigs, SIGUSR2);
pthread_sigmask(SIG_BLOCK, &blockSigs, NULL);
//Create a sigset for sigwait to wait for.
sigset_t listenSigs;
sigemptyset(&listenSigs);
sigaddset(&listenSigs, SIGUSR2);
int listenSigs_r;
//Adding loop
while(1)
{
sigwait(&listenSigs, &listenSigs_r);
if(feof(numPair->fp))
continue;
int i = numPair->num0 + numPair->num1;
usleep(rand_r(&seed) % 10000);
printf("%d", i);
kill(*numPair->pid, SIGUSR2);
}
pthread_cleanup_pop(1);
}
//Main
int main (int argc, char *argv[])
{
//Declare threads, file pointer, pid and struct
pthread_t r, c;
FILE *fp;
pid_t pid;
pair_t numbers;
//Exit if no argument given
if(argc < 2)
{
printf("Please enter one file as an argument");
return 1;
}
//Open file
fp = fopen(argv[1], "r");
//Exit if fp = null
if(fp == NULL)
{
perror("fopen");
return 1;
}
//Get the process ID of the program
pid = getpid();
//Assign values to struct pid and fp
numbers.pid = &pid;
numbers.fp = fp;
//Blocking SIGUSR1 and SIGUSR2
sigset_t blockSigs;
sigaddset(&blockSigs, SIGUSR1);
sigaddset(&blockSigs, SIGUSR2);
pthread_sigmask(SIG_BLOCK, &blockSigs, NULL);
//Set up the listening set for SIGUSR1/2
sigset_t listenSigs;
sigemptyset(&listenSigs);
sigaddset(&listenSigs, SIGUSR1);
sigaddset(&listenSigs, SIGUSR2);
int listenSigs_r;
//Create threads here so they inherit sigmasks
pthread_create(&r, NULL, readerThread, (void *)&numbers);
pthread_create(&c, NULL, calcThread, (void *)&numbers);
while(1)
{
if(feof(fp))
break;
pthread_kill(r, SIGUSR1);
sigwait(&listenSigs, &listenSigs_r);
pthread_kill(c, SIGUSR2);
sigwait(&listenSigs, &listenSigs_r);
}
pthread_cancel(r);
pthread_cancel(c);
pthread_join(r, NULL);
pthread_join(c, NULL);
fclose(fp);
return 0;
}