Как добавить все файлы в текущем каталоге в массив из потока в c? - PullRequest
Новая
       19

Как добавить все файлы в текущем каталоге в массив из потока в c?

2 голосов
/ 23 ноября 2011 
#include <pthread.h>
#include <stdio.h>
#include <stdlib.h>
#include <dirent.h>

pthread_mutex_t mut1 = PTHREAD_MUTEX_INITIALIZER,
            mut2 = PTHREAD_MUTEX_INITIALIZER,
            mut3 = PTHREAD_MUTEX_INITIALIZER,
            mut4 = PTHREAD_MUTEX_INITIALIZER;
char *buff1, *buff2, *buff3, *buff4;

void *stage1(void *arg)
{
    DIR *dir = (DIR*)arg
    struct dirent *ent;
    if (dir != NULL)
    {
  while ((ent = readdir (dir)) != NULL)
  {
    printf ("%s\n", ent->d_name);
  }
  closedir (dir);
  } else
{
    printf("FAILURE");
}
}

int main(int argc, char *argv[])
{
    if(argc != 6)
{
  printf("Usage: %s <buffsize> <filesize> <uid> <gid> <string>\n", argv[0]);
  return(-1);
}

int buffsize, filesize, uid, gid;
sscanf(argv[1],"%d",&buffsize);
sscanf(argv[2],"%d",&filesize);
sscanf(argv[3],"%d",&uid);
sscanf(argv[4],"%d",&gid);

char *string = argv[5];

buff1 = malloc(buffsize * sizeof(*buff1));
buff2 = malloc(buffsize * sizeof(*buff2));
buff3 = malloc(buffsize * sizeof(*buff3));
buff4 = malloc(buffsize * sizeof(*buff4));

pthread_t th1,th2,th3,th4,th5;

    DIR *dir = opendir(".");

pthread_create(&th1,NULL,stage1,dir);

if(filesize != -1) pthread_create(&th2,NULL,stage2,buff2);

return 0;
}

Кажется, это нормально работает в отладчике, но когда я его запускаю, на терминале ничего не отображается. Я буду заменять строку printf в методе stage1 на: 

buff1[i] = ent;
i++;

Я добавлю больше кода, чтобы убедиться, что я всегда указываю на правильное местоположение, но это то, с чем я сейчас работаю. Я хотел бы, чтобы он распечатывал файлы, чтобы я знал, что он работает.

1 Ответ

1 голос
/ 23 ноября 2011

Ваш основной поток завершает процесс, прежде чем ваш рабочий поток успеет что-то сделать. Добавьте вызов к pthread_join() в конце main(): 

    pthread_t th1,th2,th3,th4,th5;
    DIR *dir = opendir(".");

    pthread_create(&th1, NULL, stage1, dir);

    if (filesize != -1)
        pthread_create(&th2, NULL, stage2, buff2);

    pthread_join(th1, NULL);

    if (filesize != -1)
        pthread_join(th2, NULL);

    return 0;
}
...