2

cのスレッドプログラムを使用して、サーバーからファイル(ログ)を読み取る必要があります。プログラムは、一方ではこの子スレッドが実行され、同時にメインスレッドがその子スレッドの時間を通知する必要があるという同時手段のままである必要があります。

そのため、サンプル プログラムでは、子スレッドでログ機能を実行しようとしています。同時に、親プロセス/親スレッド/メイン スレッドは、ログの実行に渡された時間を秒単位で出力します。

PS: 私の問題は、pthread_join() を使用すると、最初のログ読み取り関数が実行され、無限ループのために実際にスレッドがブロックされることです。そして、メイン関数で制御の流れを取得できません。とにかくお互いに邪魔せずに一緒に実行したい。スレッドと同期メソッドを使用して、Javaで同様のことを行いました。しかし、CI では、マルチスレッド プログラミングの知識があまりありません。

現在、停止/再開条件が必要ないため、ロックを使用していません。私の唯一の要件は、両方の機能が開始されたままになり、相互に対話することなく同時に実行されることです。助けてくれてありがとう。

void process(FILE *FP, int sockfd);
int create_ma_header(char*, int, int, int, int);
void* t_main(void*);

int i;

int main(int argc, char** argv)
{
  void* arg;
  void* t_result;
  if (argc != 2)
  {
    printf("usage: tcpcli <IPaddress>");
    exit(0);
  }
  arg = (void*) argv[1];
  pthread_t t;
  pthread_attr_t t_attr;
  pthread_attr_init(&t_attr);
  printf("before calling pthread_create getpid: %d getpthread_self %u tid:%u\n",
      getpid(), pthread_self(), syscall(SYS_gettid));
  pthread_create(&t, &t_attr, t_main, (void*) argv[1]); //loging tread
  /* if(pthread_join(t,&t_result) != 0)
   {
   printf("Thread not joined \n");
   exit(1);
   }
   */
  printf("Thread joined and status is  Logs are getting printed what else you want to do .... \n");
  while (1)
  {
    printf(
        "Running time of log reading displayed from main thread: %d    seconds",
        i++);
    slep(1);
  }
  pthread_exit(0);
}

void* loging_thread(void* arg)
{
  char* server_ip;
  server_ip = (char*) arg;
  int sockfd;
  struct sockaddr_in servaddr;
  sockfd = socket(AF_INET, SOCK_STREAM, 0);
  bzero(&servaddr, sizeof(servaddr));
  servaddr.sin_family = AF_INET;
  servaddr.sin_port = htons(SERV_PORT);
  inet_pton(AF_INET, server_ip, &servaddr.sin_addr);

  printf(
      "in loging_thread log has been redirected to log_read.dat getpid: %d getpthread_self %u tid:%u\n",
      getpid(), pthread_self(), syscall(SYS_gettid));
  connect(sockfd, (struct sockaddr *) &servaddr, sizeof(servaddr));
  process(stdin, sockfd); /* do it all */
  pthread_exit(0);
}

void process(FILE *fp, int sockfd)
{
  FILE* log_f;
  int fd;
  fd = open("log_read.dat", O_CREAT | O_WRONLY, 0644);
  char sendline[MAXLINE];
  char reply[MAXLINE], string2[MAXLINE], *body;
  char *p1, *p2, *p3;
  create_ma_header(reply, 999, 999, VERSION, 999);
  write(sockfd, reply, sizeof(reply));
  while (1)
  {
    char header[SDNS_MA_HEADERSZ];
    read(sockfd, body, size);
    write(fd, body, size);
  }
}

int create_ma_header(char * reply, int type, int size, int version, int lic)
{
  sprintf(reply, "%4d%c%10d%c%4d%c%4d", type, SD_PIPE, size, SD_PIPE, version,
      SD_PIPE, lic);
  if (strlen(reply) != 26 - 1)
  {

    return 0;
  }
  reply[strlen(reply)] = SD_PIPE;
  return 1;
}

char * get_ma_header(char *curr_p, int *type_p, int *size_p, int *version_p,
    int *lic_p)
{
  *type_p = (int) strtol(curr_p, NULL, 10);
  curr_p += 5;
  *size_p = (int) strtol(curr_p, NULL, 10);
  curr_p += 11;
  *version_p = (int) strtol(curr_p, NULL, 10);
  curr_p += 5;
  *lic_p = (int) strtol(curr_p, NULL, 10);
  curr_p += 5;
  return curr_p;
}
4

1 に答える 1

0

pthread_createあなたは何を何をしているのか誤解しているようpthread_joinです。

pthread_create2 つのスレッドを並行して実行した後。両方が何をするにしても、それ以上何もする必要はありません。どちらのスレッドも「制御できません」。両方とも存在します。

スレッド「B」は、必要な処理を完了すると、値を「返す」ことができます。その後、スレッド "B" は (何もするために) 実行を停止しますが、戻り値は必要になるまで格納されます。

別のスレッド「A」は、 を実行して、完了したスレッドから戻り値を取得できますpthread_join。スレッド "B" が実際にはまだ完了していない (まだ実行中の) 場合、pthread_joinスレッド "B" が完了して値が返されるまで、 はスレッド "A" をブロックします。

pthread_joinしたがって、決して終了しないスレッド「B」を呼び出すのは間違いです。

使用する理由は 2 つありますpthread_join。

  1. 戻り値を取得します。
  2. すべてのスレッドが終了する前にプログラムが終了しないようにするため。

したがって、プログラムでは、 a はまったく必要ありませんpthread_join。

于 2013-10-31T16:36:42.680 に答える