Linux 进程与线程六

//线程间的通信

#include <stdio.h>

#include <stdlib.h>

#include <string.h>

#include <errno.h>

#include <unistd.h>

#include <pthread.h>

/*线程1与控制线程通信方法1--全局变量*/

int g_num=;

void *thread_run(void *arg)

{

    //线程1被分离了，但最好不要使用pthread_join()函数接受，多线程下报错内存溢出

    pthread_detach(pthread_self());

    int *p=(int *)arg;

    (*p)++;

    g_num=;

    /*线程1与控制线程通信方法2--pthread_exit()函数的参数*/

    //pthread_exit(p);

    //执行pthread_exit()函数后，线程会直接退出

    printf("线程1退出了！\n");\

    /*线程1与控制线程通信方法3--线程中return*/

    return p;

}

int main(int arg,char *args[])

{

    /*

     * 每个线程都拥有各自的栈内存，但是彼此之间的栈内存是可以互相访问，

     * 比如在控制线程定义的变量，可以在线程1中访问

     * 线程1中定义变量可能无法在控制线程访问，因为无法确定变量是否因为线程执行完毕被释放了

     * */

    int index=;

    pthread_t thr1;

    if(pthread_create(&thr1,NULL,thread_run,&index)!=)

    {

        printf("pthread_create() failed !\n");

        return -;

    }

    //等待线程1

    int *p=NULL;

    pthread_join(thr1,(void **)&p);

    printf("线程1的返回值%d\n",*p);

    printf("控制线程的index=%d\n",index);

    printf("g_num=%d\n",g_num);

    return ;

}

//线程的并行执行

#include <stdio.h>

#include <stdlib.h>

#include <string.h>

#include <errno.h>

#include <unistd.h>

#include <pthread.h>

void *thread_run(void *arg)

{

    //pthread_detach(pthread_self());

    if (arg != NULL)

    {

        int *p = (int *) arg;

        int i = ;

        for (i = ; i < *p; i++)

        {

            printf("这是线程%d的第%d圈！\n", (int) pthread_self(), i);

            sleep();

        }

    }

    return NULL;

}

int main(int arg, char *args[])

{

    int i = ;

    int num1 = ;

    int num2 = ;

    printf("请输入创建线程的个数:\n");

    scanf("%d", &num1);

    printf("请输入每个线程的圈数:\n");

    scanf("%d", &num2);

    pthread_t thrs[];

    /*

     * 多线程是并行运行的

     * */

    for (i = ; i < num1; i++)

    {

        if (pthread_create(&thrs[i], NULL, thread_run, &num2) != )

        {

            printf("pthread_create() failed !\n");

            return -;

        }

    }

    for (i = ; i < num1; i++)

    {

        /*如果没有pthread_join()，那么控制线程不会等待子线程，会直接退出*/

        pthread_join(thrs[i],NULL);

    }

    return ;

}