0

2 つの別々のスレッドを使用して 1-500 と 500-1000 の合計を書き込むプログラムを使用しています。プログラム自体によって作成されたテキスト ファイルに出力を書き込む必要があります。プログラムを実行すると、指定された名前に従ってファイルが作成されますが、必要に応じて出力が得られません。テキスト ファイルに 1 行だけ書き込みます。それは500-1000の合計です。しかし、コンソールを使用して出力を取得すると、必要に応じて答えが表示されます。この問題を克服する方法。ありがとう！

#include <stdio.h>
#include <pthread.h>
#include <fcntl.h>
#include <stdlib.h>

#define ARRAYSIZE 1000
#define THREADS 2

void *slave(void *myid);

/* shared data */
int data[ARRAYSIZE];    /* Array of numbers to sum */
int sum = 0;
pthread_mutex_t mutex;/* mutually exclusive lock variable */
int wsize;              /* size of work for each thread */
int fd1;
int fd2;
FILE * fp;
char name[20];

/* end of shared data */

void *slave(void *myid)
{

    int i,low,high,myresult=0;

    low = (int) myid * wsize;
    high = low + wsize;

    for(i=low;i<high;i++)
        myresult += data[i];
        /*printf("I am thread:%d low=%d high=%d myresult=%d \n",
        (int)myid, low,high,myresult);*/
    pthread_mutex_lock(&mutex);
    sum += myresult; /* add partial sum to local sum */

    fp = fopen (name, "w+");
    //printf("the sum from %d to %d is %d",low,i,myresult);
    fprintf(fp,"the sum from %d to %d is %d\n",low,i,myresult);
    printf("the sum from %d to %d is %d\n",low,i,myresult);
    fclose(fp);

    pthread_mutex_unlock(&mutex);

    return;
}
main()
{
    int i;
    pthread_t tid[THREADS];
    pthread_mutex_init(&mutex,NULL); /* initialize mutex */
    wsize = ARRAYSIZE/THREADS; /* wsize must be an integer */

    for (i=0;i<ARRAYSIZE;i++) /* initialize data[] */
        data[i] = i+1;

    printf("Enter file name : \n");
    scanf("%s",name);
    //printf("Name = %s",name);
    fd1=creat(name,0666);
    close(fd1);

    for (i=0;i<THREADS;i++) /* create threads */
        if (pthread_create(&tid[i],NULL,slave,(void *)i) != 0)
            perror("Pthread_create fails");

    for (i=0;i<THREADS;i++){ /* join threads */
        if (pthread_join(tid[i],NULL) != 0){
            perror("Pthread_join fails");
        }
    }
}
4

1 に答える 1

1

これは、各スレッドで 1 つずつ、同じファイルを 2 回開いているためです。彼らはお互いの仕事を上書きしています。

これを解決するには、次のことができます。

  1. a+モード onを使用してfopen()、既存のファイルの末尾に新しい行を追加します。または;

  2. でファイルを開くmain()と、スレッドはそのファイルのみfprintf()になります。

于 2013-11-03T04:49:36.043 に答える