0

我正在使用一个程序来使用两个单独的线程编写 1-500 和 500-1000 的总和。我需要将输出写入由程序本身创建的文本文件。当我运行程序时,它会根据给定的名称创建文件,但我没有得到需要的输出。它只向文本文件写入一行。那是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. 使用a+模式 onfopen()将新行附加到现有文件的末尾,或者;

  2. 打开文件,main()线程只会fprintf()处理它。

于 2013-11-03T04:49:36.043 回答