是否可以在c中同时运行主线程及其子线程答案

【问题标题】：is it possible a simultaneous run of main thread and its child thread in c是否可以在c中同时运行主线程及其子线程
【发布时间】：2013-10-31 12:38:35
【问题描述】：

我必须使用 c 中的线程程序从服务器读取一些文件（日志）。程序应该保持同步意味着一方面这个子线程应该正在执行，同时主线程应该通知它的子线程的时间。

所以在示例程序中，我尝试在子线程中运行日志记录功能，同时父进程/父线程/主线程将以秒为单位的打印时间已经通过运行日志记录。

PS：我的问题是如果我将使用 pthread_join() 那么第一个 logreading 函数将执行，实际上由于无限循环而阻塞了线程。而且我无法在主要功能中获得控制流。无论如何，我想同时执行两者而不会互相打扰。我在 Java 中使用线程和同步方法做了类似的事情。但是在 C 语言中，我对多线程编程知之甚少

目前我没有使用锁，因为我不想要停止/恢复条件，我唯一的要求是两个函数保持启动，同时运行而不相互交互。感谢您的帮助。

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;
}

【问题讨论】：

pthread_join() 将阻塞直到线程结束。在 main 中的 while 循环之后使用它（当你想停止程序时）。
请花几个小时或几天时间阅读一些好的pthread tutorial 和Advanced Linux Programming。我们不能在几分钟和几段内教给你所有这些。而且您很可能必须同步（使用互斥锁或其他方式）。不要忘记fflush 和/或以\n 结束您的printf 格式字符串

标签： c linux multithreading sockets systems-programming

【解决方案1】：

您似乎误解了 pthread_create 和 pthread_join 的作用。

在pthread_create 之后，您将有两个线程并行运行。您无需再做任何事情，就可以让他们都做他们所做的任何事情。两个线程都“没有控制权”，它们都存在。

当一个线程“B”完成了它需要做的任何事情时，它可以“返回”一个值。线程“B”然后停止运行（做任何事情），但返回值被存储起来，直到它需要它。

另一个线程“A”可以通过运行pthread_join 从已完成的线程中检索返回值。如果线程“B”实际上还没有完成（它仍在运行），那么pthread_join 将阻塞线程“A”，直到线程“B”完成并返回一个值。

因此，在永不退出的线程“B”上调用pthread_join 是一个错误。

使用pthread_join有两个原因：

获取返回值。
确保程序在所有线程完成之前不会退出。

因此，在您的程序中，您根本不需要pthread_join。

【讨论】：