zoukankan      html  css  js  c++  java
  • 线程同步机制之互斥锁通信机制

    #include <stdio.h>
    #include <stdlib.h>
    #include <pthread.h>
    #include <string.h>
    
    void *thread_function(void *arg);
    pthread_mutex_t work_mutex;
    #define WORK_SIZE 1024
    char work_area[WORK_SIZE];
    int time_to_exit=0;
    int main(int argc, char *argv[])
    {
        int res;
        pthread_t a_thread;
        void *thread_result;
        res=pthread_mutex_init(&work_mutex,NULL);
        if(res!=0)
        {
            printf("Mutex initialization failed
    ");
            exit(EXIT_FAILURE);
        }
        res=pthread_create(&a_thread,NULL,thread_function,NULL);
        if(res!=0)
        {
            printf("Thread creation failed
    ");
            exit(EXIT_FAILURE);
        }
        pthread_mutex_lock(&work_mutex);
        printf("Input some text. Enter 'end' to finish
    ");
        while(!time_to_exit)
        {
            fgets(work_area,WORK_SIZE,stdin);
            pthread_mutex_unlock(&work_mutex);
            while(1)
            {
                pthread_mutex_lock(&work_mutex);
                if(work_area[0]!='')
                {
                    pthread_mutex_unlock(&work_mutex);
                    sleep(1);
                }
                else 
                    break;
            }
        }
        pthread_mutex_unlock(&work_mutex);
        printf("
    Waitting for thread to finish...
    ");
        res=pthread_join(a_thread,&thread_result);
        if(res!=0)
        {
            printf("Thread join failed
    ");
            exit(EXIT_FAILURE);
        }
        printf("Thread joined
    ");
        pthread_mutex_destroy(&work_mutex);
        exit(EXIT_SUCCESS);
        return 0;
    }
    
    void *thread_function(void *arg)
    {
        sleep(1);
        pthread_mutex_lock(&work_mutex);
        while(strncmp("end",work_area,3)!=0)
        {
            printf("You input %d characters
    ",strlen(work_area)-1);
            printf("the character is: %s",work_area);
            work_area[0]='';
            pthread_mutex_unlock(&work_mutex);
            sleep(1);
            pthread_mutex_lock(&work_mutex);
            while(work_area[0]=='')
            {
                pthread_mutex_unlock(&work_mutex);
                sleep(1);
                pthread_mutex_lock(&work_mutex);
            }
    
        }
        time_to_exit=1;
        work_area[0]='';
        pthread_mutex_unlock(&work_mutex);
        pthread_exit(0);
    }

  • 相关阅读:
    C# 手机号码隐藏中间四位
    mysql-8.0.20-winx64 绿色版安装教程
    C# 钩子函数使用
    C#反射机制学习
    docker学习笔记二
    从主机A得到id_rsa.pub文件,在主机B创建用户danny加入该文件,实现主机A免密登录主机B
    关于mysql远程登录问题
    playframework 编译打包过程失败
    docker学习笔记一
    记一次tomcat7.0版本启动项目失败问题
  • 原文地址:https://www.cnblogs.com/lakeone/p/3789639.html
Copyright © 2011-2022 走看看