0

特定のメソッドが呼び出されるたびに新しいスレッドを作成するプログラムを作成したいと考えています。これまでの私の作業コードは次のとおりです。

#define NUMBER_OF_THREADS   3

pthread_t threads[NUMBER_OF_THREADS];
pthread_attr_t attr;

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

   printf("Thread %ld running...\n",tid);
    // ...
    printf("Thread %ld completed...\n",tid);

   pthread_exit((void*) t);
}

void createNewThread(int number){
    printf("running createNewThread(%d)\n", number);
    pthread_t tid;
    int rc = pthread_create( &tid, &attr, BusyWork, (void *) (long)number);
    if (rc) {
        printf("ERROR; return code from pthread_create() is %d\n", rc);
        exit(-1);
    }
}

int main(int argc, char *argv[]) {
    int i, rc;

    //Set up thread attributes
    pthread_attr_init(&attr);
    pthread_attr_setdetachstate(&attr, PTHREAD_CREATE_JOINABLE);

    //Arbitary amount of calls (My real program will call the createNewThread() funcion multiple unkown amount of times)
    createNewThread(15);
    createNewThread(27);
    createNewThread(62);
    createNewThread(500);
    createNewThread(8864);
    createNewThread(99999);

    //Free attributes
    pthread_attr_destroy(&attr);

    //Wait for other threads still running
    // HOW CAN I DO THIS????
    /*for (i=0; i< NUMBER_OF_THREADS; i++){
        rc = pthread_join( ??? , NULL); //TODO
        if (rc){
            printf("ERROR: return code from pthread_join() %d\n", rc);
            exit(-1);
        }
        printf("Main: completed join with thread %d\n", i);
    }*/

    printf("Main: program completed. Exiting.\n");


    pthread_exit(NULL); // (?) Is this part nessassary as we are on the main thread and soon to exit the program 

    return 0;
}

ただし、私のコードでわかるように、いくつかの問題があります。たとえば、スレッド番号を追跡していないため、使用しているコードのすべてのプロセスが完了するのを待つにはどうすればよいでしょうか。また、スレッド「BusyWork」が完了すると、それ自体がクリーンアップされず、孤立したプロセスとして残されます。

私が思いついたアイデアの 1 つは、ベクターを使用して各スレッド番号を追跡し、それを main の最後の最終結合に使用することでした。ただし、問題は、配列リストが非常に大きくなりやすく、スレッドが完了しても縮小されないことです。

4

1 に答える 1

2

スレッドを切り離し、結合しないでください。スレッドを作成する前に、mutex によって保護されているカウンターをインクリメントします。スレッドが終了する直前に、mutex を取得してカウンターをデクリメントします。これで、カウンターがゼロを読み取ったときにすべてのスレッドが完了したことがわかります。必要に応じて、条件変数を使用してカウンターを待機可能にすることができます。

于 2014-12-05T21:51:01.063 に答える