linux多线程互斥-售票

#include <stdio.h>
#include <stdlib.h>
#include <string.h>
#include <pthread.h>

int ticket_cnt = 20;     /* 共有20张票 */
typedef struct tag
{
    int s_id;
    pthread_mutex_t *s_p;
}DATA,*pDATA;

void* handler(void *arg )
{
    int id = ((pDATA)arg)->s_id;
    pthread_mutex_t *p_mutex = ((pDATA)arg)-> s_p;
    printf("a window on !: %d \n", id);
    while(1)
    {
        pthread_mutex_lock(p_mutex);
        if(ticket_cnt == 0)
        {
            printf("ticket out! \n");
            pthread_mutex_unlock(p_mutex);
            free((pDATA)arg);
            return (void*)0;
        }
        --ticket_cnt;
        sleep(rand()%3 + 1);
        printf("window: %d : a ticket sold. left : %d \n", id,ticket_cnt );
        pthread_mutex_unlock(p_mutex);
        sleep(rand() % 3 + 1); /* 如果不sleep,锁会一直被这个执行完的线程所占据 */

    }
}

int main(int argc, char *argv[])
{
    srand(getpid());
    pthread_mutex_t mutex;
    pthread_mutex_init(&mutex, NULL);
    int thd_cnt = atoi(argv[1]); /* 从命令行输入卖票窗口数 */
    pthread_t *tds = (pthread_t*)calloc(thd_cnt,sizeof(pthread_t));
    int index;
    for(index = 0; index < thd_cnt; index++ )
    {
        pDATA p = (pDATA)calloc(1,sizeof(DATA));
        p->s_id = index;
        p->s_p = &mutex;
        pthread_create(tds + index , NULL,handler,(void*)p);
    }
    printf("joining...\n");
    for(index = 0; index < thd_cnt; index++)
    {
        pthread_join(tds[index],NULL);
    }
    pthread_mutex_destroy(&mutex);
    return 0;
}
时间: 2024-10-10 01:49:21

linux多线程互斥-售票的相关文章

linux多线程-互斥&amp;条件变量与同步

多线程代码问题描述 我们都知道,进程是操作系统对运行程序资源分配的基本单位,而线程是程序逻辑,调用的基本单位.在多线程的程序中,多个线程共享临界区资源,那么就会有问题: 比如 #include <pthread.h> #include <unistd.h> #include <stdio.h> #include <stdlib.h> int g_val = 10; void * test1(void* args) { g_val = 20; printf(&

笔记1 linux 多线程 互斥锁

//mutex lock #include<stdio.h> #include<unistd.h> #include<pthread.h> struct test { char a[10]; char b[10]; char c[10]; }yb = {"111","222","33333"}; static int j=0; pthread_mutex_t mutex_1 = PTHREAD_MUTEX_IN

Linux多线程的使用一:互斥锁

多线程经常会在Linux的开发中用到,我想把平时的使用和思考记录下来,一是给自己做个备忘,二是分享给可能会用到的人. POSIX标准下互斥锁是pthread_mutex_t,与之相关的函数有: 1 int pthread_mutex_init(pthread_mutex_t * mutex , pthread_mutexattr_t * attr); 2 int pthread_mutex_destroy (pthread_mutex_t * mutex); 3 int pthread_mute

Linux多线程编程-互斥锁

互斥锁 多线程编程中,(多线程编程)可以用互斥锁(也称互斥量)可以用来保护关键代码段,以确保其独占式的访问,这有点像二进制信号量.POSIX互斥锁相关函数主要有以下5个: #include <pthread.h> int pthread_mutex_init(pthread_mutex_t *mutex, const pthread_mutexattr_t *mutexattr); int pthread_mutex_destroy(pthread_mutex_t *mutex); int p

【转】Linux平台上用C++实现多线程互斥锁

原作者:chexlong 原文地址:http://blog.csdn.net/chexlong/article/details/7058283 在上篇用C++实现了Win32平台上的多线程互斥锁,这次写个Linux平台上的,同样参考了开源项目C++ Sockets的代码,在此对这些给开源项目做出贡献的斗士们表示感谢! 下边分别是互斥锁类和测试代码,已经在Fedora 13虚拟机上测试通过. Lock.h [cpp] view plaincopy #ifndef _Lock_H #define _

Linux多线程--使用互斥量同步线程【转】

本文转载自:http://blog.csdn.net/ljianhui/article/details/10875883 前文再续,书接上一回,在上一篇文章:Linux多线程——使用信号量同步线程中,我们留下了一个如何使用互斥量来进行线程同步的问题,本文将会给出互斥量的详细解说,并用一个互斥量解决上一篇文章中,要使用两个信号量才能解决的只有子线程结束了对输入的处理和统计后,主线程才能继续执行的问题. 一.什么是互斥量 互斥量是另一种用于多线程中的同步访问方法,它允许程序锁住某个对象,使得每次只能

[转]一个简单的Linux多线程例子 带你洞悉互斥量 信号量 条件变量编程

一个简单的Linux多线程例子 带你洞悉互斥量 信号量 条件变量编程 希望此文能给初学多线程编程的朋友带来帮助,也希望牛人多多指出错误. 另外感谢以下链接的作者给予,给我的学习带来了很大帮助 http://blog.csdn.net/locape/article/details/6040383 http://www.cnblogs.com/liuweijian/archive/2009/12/30/1635888.html 一.什么是多线程? 当我自己提出这个问题的时候,我还是很老实的拿着操作系

Linux多线程与同步

Linux多线程与同步 作者:Vamei 出处:http://www.cnblogs.com/vamei 欢迎转载,也请保留这段声明.谢谢! 典型的UNIX系统都支持一个进程创建多个线程(thread).在Linux进程基础中提到,Linux以进程为单位组织操作,Linux中的线程也都基于进程.尽管实现方式有异于其它的UNIX系统,但Linux的多线程在逻辑和使用上与真正的多线程并没有差别. 多线程 我们先来看一下什么是多线程.在Linux从程序到进程中,我们看到了一个程序在内存中的表示.这个程

Linux多线程

1. Linux多线程概述 1.1. 概述 进程是系统中程序执行和资源分配的基本单位.每个进程有自己的数据段.代码段和堆栈段.这就造成进程在进行切换等操作时都需要有比较负责的上下文切换等动作.为了进一步减少处理器的空转时间支持多处理器和减少上下文切换开销,也就出现了线程. 线程通常叫做轻量级进程.线程是在共享内存空间中并发执行的多道执行路径,是一个更加接近于执行体的概念,拥有独立的执行序列,是进程的基本调度单元,每个进程至少都有一个main线程.它与同进程中的其他线程共享进程空间{堆 代码 数据