4.1多线程中使用进程复制
#include<stdio.h>
#include<stdlib.h>
#include<string.h>
#include<unistd.h>
#include<pthread.h>
void* fun(void* arg)
{
for(int i=0;i<5;++i)
{
printf("fun run pid=%d\n",getpid());
sleep(1);
}
}
int main()
{
pthread_t id;
pthread_create(&id,NULL,fun,NULL);
fork();//
for(int i=0;i<5;++i)
{
printf("main run pid=%d\n",getpid());
sleep(1);
}
pthread_join(id,NULL);
exit(0);
}在使用fork()函数之后，没有判断返回值大于0还是等于0，则之后的代码在父子进程都会执行。
pid相同的为父进程中的两个线程，pid不同的为子进程的线程。此时子进程启动的为父进程的主线程所在的执行路径。
当把fork()从主线程中放到子线程中时：
void* fun(void* arg)
{
fork();//
for(int i=0;i<5;++i)
{
printf("fun run pid=%d\n",getpid());
sleep(1);
}
}
int main()
{
pthread_t id;
pthread_create(&id,NULL,fun,NULL);
for(int i=0;i<5;++i)
{
printf("main run pid=%d\n",getpid());
sleep(1);
}
pthread_join(id,NULL);
exit(0);
}
pid相同的为父进程中的两个线程，pid不同的为子进程的线程。此时子进程启动的为父进程的子线程所在的执行路径（线程）。
从上述两种情况能看到，在复制子进程时fork()函数父进程的资源状态等会全部复制过来，但是只有一条执行路径（线程），只会将fork()函数所在的执行路径（线程）进行复制。也就意味着，复制的子进程只有一条执行路径（线程），该路径是父进程中fork()函数所在的路径（线程）。
4.2多线程中互斥锁与fork()函数
pthread_mutex_t mutex;
void* fun(void* arg)
{
pthread_mutex_lock(&mutex);
printf("theread fun lock\n");
sleep(5);
pthread_mutex_unlock(&mutex);
printf("thread fun unlock\n");
}
int main()
{
pthread_mutex_init(&mutex,NULL);
pthread_t id;
pthread_create(&id,NULL,fun,NULL);
sleep(1);
pid_t pid=fork();
if(pid==-1)
{
exit(1);
}
if(pid==0)
{
printf("child 准备加锁\n");
pthread_mutex_lock(&mutex);
printf("child 加锁成功\n");
pthread_mutex_unlock(&mutex);
exit(0);
}
wait(NULL);
printf("main over\n");
pthread_join(id,NULL);
exit(0);
}运行结果：
原因：父进程的子线程先加锁并打印加锁信息，等待五秒钟，此时子进程打印准备加锁后阻塞住，等到父进程的子线程解锁并打印信息后子进程依然在阻塞，没有加上锁，所以子进程和父进程用的不是同一个锁。子进程一直不能加锁，说明子进程的锁一直处于加锁状态没有解锁，在fork()之前睡眠一秒钟，这一秒钟足够父进程的子线程加锁，所以子进程在复制父进程时，将父进程的加锁状态复制过来。
当去掉上述代码中的sleep()语句后，复制子进程时，子进程的锁的状态就变成不确定随机的，因为是在启动父进程的子线程后才开始复制的，复制时可能子线程加锁还没解锁，也可能子进程加完锁又解开了。
为了避免这种子进程不确定锁的状态，需要在父进程中挑取一个没人加锁的状态进行进程的复制，可以在fork()前进行加锁，在fork()后再进行解锁。当如果多出使用fork()函数这样的方法比较繁杂，于是就使用函数pthread_atfork(父进程加锁函数，父进程解锁函数，子进程解锁函数)，当程序中使用fork()函数时，会先调用父进程加锁函数，然后在fork()结束后在父进程调用父进程解锁函数，然后在子进程中调用子进程解锁函数。
pthread_mutex_t mutex;
void fun_mutex_lock()
{
pthread_mutex_lock(&mutex);
}
void fun_mutex_unlock()
{
pthread_mutex_unlock(&mutex);
}
void child_mutex_unlock()
{
pthread_mutex_unlock(&mutex);
}
void* fun(void* arg)
{
pthread_mutex_lock(&mutex);
printf("theread fun lock\n");
sleep(5);
pthread_mutex_unlock(&mutex);
printf("thread fun unlock\n");
}
int main()
{
pthread_mutex_init(&mutex,NULL);
pthread_atfork(fun_mutex_lock,fun_mutex_unlock,child_mutex_unlock);
pthread_t id;
pthread_create(&id,NULL,fun,NULL);
sleep(1);
pid_t pid=fork();
if(pid==-1)
{
exit(1);
}
if(pid==0)
{
printf("child 准备加锁\n");
pthread_mutex_lock(&mutex);
printf("child 加锁成功\n");
pthread_mutex_unlock(&mutex);
exit(0);
}
wait(NULL);
printf("main over\n");
pthread_join(id,NULL);
exit(0);
}
