我收到一个事件,并根据该事件进行一些处理,然后 fork + execvp 一些其他程序(称为 some_jazzy_program)。最初我使用了 while 循环,其中执行了以下操作:
while (some condition)
{
pid = fork();
if (pid == 0)
{
do_some_work()
execvp (some_jazzy_program..);
}
else
{
do_some_bookkeeping();
}
}
这种设计的问题是,如果 do_some_work() 占用大量时间,那么我无法足够快地生成新进程来启动 some_jazzy_program。为了解决这个问题,我开始使用 pthreads:
pthread_t *work_threads[MAX_FORKS_ALLOWED];
while (some condition)
{
work_threads[index] = (pthread_t *) malloc (sizeof (pthread_t));
pthread_create(work_threads[index], NULL, do_some_good_work, NULL);
index ++;
}
void * do_some_good_work (void *arg)
{
pid = fork();
if (pid == 0)
{
do_some_work()
execvp (some_jazzy_program..);
}
else
{
do_some_bookkeeping();
}
}
这个设计有效。不过,我有几个问题。
调用 fork + excvp 来生成一个新进程。我应该在父程序中的哪里调用 pthread_exit() 。无论我读过什么,我都不一定需要调用 pthread_exit,因为当它要完成的工作完成时,线程会自动终止。在这种情况下,一旦我执行 fork + execvp 它就会死掉。
我的另一个担忧是关于work_threads[index] = (pthread_t *) malloc (sizeof (pthread_t))——我正在做的内存malloc。当我使用 malloc 时,我从堆中分配内存。我在哪里可以释放该内存并将其释放回堆。对我来说,不做任何事情看起来就像是内存泄漏。
我在这里尝试的通常是这样做的——首先运行多个 pthreads,然后在每个 pthread 中执行 fork + execvp
最佳答案
关于你的第一个问题,你不需要调用pthread_exit
。如果您的主程序想要跟踪线程,您可以使用 pthread_join 并检查线程的返回状态。
关于你的第二个问题,你可以通过使用来避免堆内存分配:
pthread_t work_threads[MAX_FORKS_ALLOWED];
关于你的第三个问题,正如 Joachim 所说,在线程内 fork
并不常见;事实上也有点危险。 Think before you mix them
关于c - 为 pthread 分配内存,然后 fork + execvp,我们在Stack Overflow上找到一个类似的问题: https://stackoverflow.com/questions/25865724/