2

pthread_join()関数は実行後にスレッドを強制終了するか、 pthread_cancel()/を呼び出す必要がありpthread_exit()ますか？

私はpthread_cancel()/を呼び出しpthread_kill()ています。これは3を返します。つまり、thread_idが付加されたスレッドはありません。

#include <stdio.h>
#include <pthread.h>
#include <unistd.h>
#include <signal.h>

void * run (void *);

int main() {
pthread_t p1, p2;
int a = 9;
printf("%d\n", pthread_create(&p1, NULL, &run, (void*)&p1));
printf("%d\n", pthread_create(&p2, NULL, &run, (void*)&p2));

printf("%d\n", pthread_join(p1, NULL));
//usleep(1000);
printf("%d\n", pthread_join(p2, NULL));

printf("before exit\n");
printf("%d\n", pthread_cancel(p1));
printf("after exit\n");
printf("%d\n", pthread_cancel(p2));
printf("both thread exited\n");

printf("%d\n", pthread_join(p1, NULL));
printf("%d\n", pthread_join(p2, NULL));
printf("terminated\n");

printf("%d\n", pthread_kill(p1, 0));
printf("%d\n", pthread_kill(p2, 0));
printf("ext\n");

printf("%d\n", pthread_join(p1, NULL));
printf("%d\n", pthread_join(p2, NULL));
printf("jion\n");

return 0;
}

void *run (void *p) {

int *i = (int*)p;
printf("created i = %d\n", *i);
}

これは私が使用しているコードです。このpthread_cancelでは、すべての関数が3を返します。これは、スレッドがすでに強制終了されていることを意味します。

4

3 に答える 3

7

pthread_joinスレッドを強制終了せず、スレッドが完了するのを待ちます。スレッドを強制終了したい場合は、 を使用しますpthread_kill。ただし、それは の前 pthread_joinに行う必要があります。そうしないと、スレッドは既に終了しています。

pthread_cancelは、スレッドが次のキャンセル ポイントで終了することを要求し、おそらく を使用するよりも安全ですpthread_kill。

pthread_exit現在のスレッドを終了します。

于 2012-09-05T11:16:39.827 に答える
0

いくつかのコンテキストはいいでしょう...しかし、スレッド（おそらくあなたが気にかけているのは1つしかない）が終了/戻るのを待っているだけなら、pthread_joinで十分です。

pthread_join() 関数は、thread で指定されたスレッドが終了するのを待ちます。そのスレッドがすでに終了している場合、 pthread_join() はすぐに戻ります。

http://www.kernel.org/doc/man-pages/online/pages/man3/pthread_join.3.html

使用法/警告については、man ページを確認してください。

于 2012-09-05T11:18:50.490 に答える
0

pthread_join()追加後

/* Last thing that main() should do */
   pthread_exit(NULL);

詳細については、こちらを参照してください。

pthread_join() は、すべてのスレッドが実行を完了するまで main() スレッドを待機させるために使用されます。その特定のスレッドがその実行を完了すると、制御は pthread_join() に到達します。したがって、その特定のスレッドをキャンセル/強制終了しようとすると、エラーが返されます。

サンプルコード

    #include <pthread.h>
    #include <stdio.h>
    #include <stdlib.h>
    #define NUM_THREADS 4

    void *BusyWork(void *t)
    {
       int i;
       long tid;
       tid = (long)t;
       printf("Thread %ld starting...\n",tid);
       pthread_exit((void*) t);                 //Exits that current thread.
    }

    int main (int argc, char *argv[])
    {
       pthread_t thread[NUM_THREADS];
       int rc;
       long t;
       void *status;

       for(t=0; t<NUM_THREADS; t++) {
          printf("Main: creating thread %ld\n", t);
          rc = pthread_create(&thread[t], NULL, BusyWork, (void *)t); 
          if (rc) {
             printf("ERROR; return code from pthread_create() is %d\n", rc);
             exit(-1);
             }
          }

      /* Wait for completion */
       for(t=0; t<NUM_THREADS; t++) {
          rc = pthread_join(thread[t], &status);
          if (rc) {
             printf("ERROR; return code from pthread_join() is %d\n", rc);
             exit(-1);
             }
printf("Main: completed join with thread %ld having a status of %ld\n",t,(long)status);
          }

    printf("Main: program completed. Exiting.\n");
    pthread_exit(NULL); // Exits main thread.
    }

@Joachim Pileborgのために

#include <pthread.h>
#include <stdio.h>
#include <stdlib.h>
#define NUM_THREADS 4

void *BusyWork(void *t)
{
   int i;
   long tid;
   tid = (long)t;

   printf("Thread %ld starting...\n",tid);

   for(i = 0; i <10000000; i++)
        printf("\n Thread: %ld,  %d", tid, i);

   pthread_exit((void*) t);                 //Exits that current thread.
}

int main (int argc, char *argv[])
{
   pthread_t thread[NUM_THREADS];
   int rc;
   long t;
   void *status;

   for(t=0; t<NUM_THREADS; t++) {
      printf("Main: creating thread %ld\n", t);
      rc = pthread_create(&thread[t], NULL, BusyWork, (void *)t);
      if (rc) {
         printf("ERROR; return code from pthread_create() is %d\n", rc);
         exit(-1);
         }
      }

//printf("Main: program completed. Exiting.\n");
pthread_exit(NULL); // Exits main thread(work will be done).
//return 0;//( Threads will exit once main exits.)
}
于 2012-09-05T11:17:45.203 に答える