19

いくつかのプロセスをフォークしています。タスク全体を完了するのにかかる時間を測定したいと考えています。つまり、フォークされたすべてのプロセスが完了したときです。すべての子プロセスが終了するまで親プロセスを待機させる方法を教えてください。適切なタイミングでタイマーを確実に停止したい。

ここに私が使用するコードがあります：

#include <iostream>
#include <string>
#include <fstream>
#include <sys/time.h>
#include <sys/wait.h>

using namespace std;

struct timeval first,  second,  lapsed;
struct timezone tzp; 

int main(int argc, char* argv[])// query, file, num. of processes.
{

    int pCount = 5; // process count

    gettimeofday (&first, &tzp); //start time

    pid_t* pID = new pid_t[pCount];

    for(int indexOfProcess=0; indexOfProcess<pCount; indexOfProcess++)
    {
        pID[indexOfProcess]= fork();

        if (pID[indexOfProcess] == 0)                // child
        {
            // code only executed by child process

            // magic here

            // The End
            exit(0);
        }
        else if (pID[indexOfProcess] < 0)    // failed to fork
        {
            cerr << "Failed to fork" << endl;
            exit(1);
        }
        else                         // parent
        {
            // if(indexOfProcess==pCount-1) and a loop with waitpid??

            gettimeofday (&second, &tzp); //stop time
            if (first.tv_usec > second.tv_usec)
            {
                second.tv_usec += 1000000;
                second.tv_sec--;
            }

            lapsed.tv_usec = second.tv_usec - first.tv_usec;
            lapsed.tv_sec = second.tv_sec - first.tv_sec; 

            cout << "Job performed in " <<lapsed.tv_sec << " sec and " << lapsed.tv_usec    << " usec"<< endl << endl;

        }

    }//for

}//main
4

5 に答える 5

22

「else //parent」行の後のすべてを for ループの外側に移動します。fork のループの後、waitpid を使用して別の for ループを実行し、クロックを停止して残りを実行します。

for (int i = 0; i < pidCount; ++i) {
    int status;
    while (-1 == waitpid(pids[i], &status, 0));
    if (!WIFEXITED(status) || WEXITSTATUS(status) != 0) {
        cerr << "Process " << i << " (pid " << pids[i] << ") failed" << endl;
        exit(1);
    }
}

gettimeofday (&second, &tzp); //stop time

子プロセスがステータス 0 で正常に終了できなかった場合、子プロセスは作業を完了していないため、テストで有効なタイミング データを生成できなかったと想定しています。明らかに、子プロセスがシグナルによって強制終了される場合、または 0 以外の戻りステータスで終了する場合は、それに応じてエラー チェックを変更する必要があります。

待機を使用する別の方法:

while (true) {
    int status;
    pid_t done = wait(&status);
    if (done == -1) {
        if (errno == ECHILD) break; // no more child processes
    } else {
        if (!WIFEXITED(status) || WEXITSTATUS(status) != 0) {
            cerr << "pid " << done << " failed" << endl;
            exit(1);
        }
    }
}

これは、どのプロセスが順番に失敗したかを示しているわけではありませんが、気になる場合は、コードを追加して pids 配列で検索し、インデックスを取得することができます。

于 2008-11-11T01:27:10.607 に答える
13

最も簡単な方法は、

while(wait() > 0) { /* no-op */ ; }

wait()子が残っていないという事実以外の何らかの理由で失敗した場合、これは機能しません。したがって、いくつかのエラーチェックを行うと、これは次のようになります

int status;
[...]
do {
    status = wait();
    if(status == -1 && errno != ECHILD) {
        perror("Error during wait()");
        abort();
    }
} while (status > 0);

マニュアルページも参照してくださいwait(2)。

于 2008-11-11T01:17:28.443 に答える
4

すべての子が処理されるまでループ内で wait (または waitpid) を呼び出します。

この場合、とにかくすべてのプロセスが同期していますが、一般的に、より多くの作業を行うことができる場合 (例: ワーカー プロセス プール) には待機が優先されます。

于 2008-11-11T01:16:20.410 に答える
3

待ちシステムコールがあなたが探しているものを達成すると信じています。

于 2008-11-11T01:16:02.703 に答える
0 
for (int i = 0; i < pidCount; i++) {
    while (waitpid(pids[i], NULL, 0) > 0);
}

正しい順序で待機することはありませんが、最後の子が死亡するとすぐに停止します。

于 2008-11-11T01:17:31.453 に答える