`
peng_wp
  • 浏览: 42119 次
社区版块
存档分类
最新评论

pthread_mutex实现进程间同步

阅读更多
   前面实验室的师兄们在讨论pthread这套接口能不能实现进程间同步,自己对这个不是十分地了解,但是对这个比较感兴趣,于是就在实验室师兄的指导下去实现了这个同步机制。

   测试的结果就是可以用pthread_mutex_t来实现进程间的同步。
   需要注意的是初始化 mutex 时需要指定 PTHREAD_PROCESS_SHARED 这个属性,代码如下

pthread_mutexattr_init(&attr);
pthread_mutexattr_setpshared(&attr, PTHREAD_PROCESS_SHARED);

pthread_mutex_init(&mutex, &attr);



   其中 pthread_mutexattr_setpshared 这个 API 在 open group 的标准中定义 http://pubs.opengroup.org/onlinepubs/9699919799/functions/pthread_mutexattr_getpshared.html

不过这个 feature 不是所有的平台都支持,compile time 用 _POSIX_THREAD_PROCESS_SHARED 检查,runtime 用 sysconf(_SC_THREAD_PROCESS_SHARED) 检查所在平台是否支持。



另外我是通过在 mmap 调用指定 MAP_SHARED 实现在父子进程间共享内存的,并没有使用 System V 的共享内存 API。

这是示例代码:
#include <pthread.h>
#include <stdio.h>
#include <stdlib.h>

#include <sys/mman.h>
#include <fcntl.h>
#include <unistd.h>

#ifndef _POSIX_THREAD_PROCESS_SHARED	
#error "This platform does not support process shared mutex"	
#endif

/* Define globally accessible variables and a mutex */

#define NUMTHRDS 4

int* shared_sum = NULL; 

pthread_mutex_t *sum_mutex;


int process_fn()
{
    int i;       
    for ( i=0; i < 100000000; i++)
    {
        pthread_mutex_lock(sum_mutex);
        *shared_sum += 1;
        pthread_mutex_unlock(sum_mutex);
    }
    return 0;
}

int main(int argc, char** argv)
{

  int i;
  pthread_mutex_t *p_map;
  int* temp;
  int cpid;
  p_map=(pthread_mutex_t*)mmap(NULL,sizeof(pthread_mutex_t)*10,PROT_READ|PROT_WRITE,
       MAP_SHARED|MAP_ANONYMOUS,-1,0);
 
  sum_mutex = p_map;
  shared_sum = (int*) (p_map+3);
  *shared_sum = 0;
 
  pthread_mutexattr_t mutex_shared_attr;

  /* Set pthread_mutex_attr to process shared */
  pthread_mutexattr_init(&mutex_shared_attr);
  pthread_mutexattr_setpshared(&mutex_shared_attr, PTHREAD_PROCESS_SHARED);
 
  pthread_mutex_init(sum_mutex, &mutex_shared_attr);

  cpid = fork();
  if(cpid == 0)
  {
      process_fn();
      return 0;
  } else {
      process_fn();
      waitpid(cpid, NULL, 0);
  }
  
  temp = (int*) (p_map+3);
  printf("in the end, the shared sum: %d\n",*temp);
  return 0;
}



这是进程中有线程的示例代码。
#include <pthread.h>
#include <stdio.h>
#include <stdlib.h>

#include <sys/mman.h>
#include <fcntl.h>
#include <unistd.h>

#ifndef _POSIX_THREAD_PROCESS_SHARED	
#error "This platform does not support process shared mutex"	
#endif

/* Define globally accessible variables and a mutex */

#define NUMTHRDS 4

int* shared_sum = NULL; 

pthread_t callThd[NUMTHRDS];
pthread_mutex_t *sum_mutex;

void *thread_fn(void *arg)
{
    int i;
    int id = (int)((long)arg);
    for(i = 0; i < 1000000; i++)
    {
        pthread_mutex_lock(sum_mutex);
        *shared_sum += 1;
        /*printf("Thread #%d:  mysum=%d\n",id, *shared_sum);*/
        pthread_mutex_unlock(sum_mutex);
    }
}

int process_fn()
{

    pthread_attr_t attr;

  
    int i;       
    /* Create threads to perform the dotproduct  */
    pthread_attr_init(&attr);
    pthread_attr_setdetachstate(&attr, PTHREAD_CREATE_JOINABLE);

    for(i=0;i<NUMTHRDS;i++)
    {
        pthread_create(&callThd[i], &attr, thread_fn, (void *)((long)i)); 
    }
  
    /* Wait on the other threads */
    for(i=0;i<NUMTHRDS;i++) {
        pthread_join(callThd[i], NULL);
    }
    /* After joining, print out the results and cleanup */
    printf("Sum =  %d\n",  *shared_sum);
    return 0;
}

int main(int argc, char** argv)
{

    int i;
    pthread_mutex_t *p_map;
    int cpid;
    p_map=(pthread_mutex_t*)mmap(NULL,sizeof(pthread_mutex_t)*10,PROT_READ|PROT_WRITE,
           MAP_SHARED|MAP_ANONYMOUS,-1,0);
 
    sum_mutex = p_map;
    shared_sum = (int*) (p_map+3);
    *shared_sum = 0;
 
    pthread_mutexattr_t mutex_shared_attr;

    /* Set pthread_mutex_attr to process shared */
    pthread_mutexattr_init(&mutex_shared_attr);
    pthread_mutexattr_setpshared(&mutex_shared_attr, PTHREAD_PROCESS_SHARED);
 
    pthread_mutex_init(sum_mutex, &mutex_shared_attr);

    cpid = fork();
    if(cpid == 0)
    {
        process_fn();
        return 0;
    } else {
        process_fn();
    }
  
    printf("In the end, the shared sum: %d\n",*shared_sum);
    return 0;
}
分享到:
评论

相关推荐

    linux无亲缘关系进程间通信(互斥锁+条件变量+共享内存)

    这三个工具结合使用,可以构建出安全、高效的进程间同步机制,尤其适用于多进程协作处理大量共享数据的场景。在实际编程中,需要注意正确释放资源,防止死锁和资源泄漏,以保证系统的稳定性和可维护性。

    pthread-primer.rar_Pthread Primer pdf_pthread_pthread primer

    `pthread_mutex_t`和`pthread_mutex_lock()`、`pthread_mutex_unlock()`用于互斥锁,保证资源的安全访问,`pthread_cond_t`和`pthread_cond_wait()`、`pthread_cond_signal()`用于条件变量实现线程间的同步。...

    进程间的同步实现读者写者问题

    进程间的同步实现读者写者问题 进程间的同步问题是操作系统中一个重要的概念,它指的是多个进程之间的同步和互斥访问共享资源的问题。为了解决这个问题,可以使用互斥型信号量来实现读者-写者问题。 读者-写者...

    Linux线程同步之互斥量(mutex)[收集].pdf

    若想实现跨进程的互斥量,需确保互斥量存储在进程间可共享的内存区域。 使用互斥量的主要操作包括尝试锁定、锁定和解锁。`pthread_mutex_trylock()`函数尝试立即锁定互斥量,若成功则返回0,失败(锁已被其他线程...

    Posix(1).rar_POSIX Pthread_posix_pthread_pthread posix

    4. **同步机制**:pthreads提供多种同步原语,包括互斥锁(`pthread_mutex_t`)、条件变量(`pthread_cond_t`)、读写锁(`pthread_rwlock_t`)和信号量(`sem_t`),用于控制对共享资源的访问。 5. **线程调度**:...

    Pthread互斥问题

    "Pthread互斥问题"指的是使用POSIX线程库(Pthreads)处理的进程间互斥访问资源的情况。POSIX线程,简称Pthreads,是UNIX系统标准的一部分,提供了跨平台的线程管理接口。在多线程环境中,互斥机制用于确保对共享...

    Pthread-Primer.rar_pthread_unix primer

    在pthread库中,主要使用条件变量和互斥锁实现线程间的通信和同步。 六、线程属性 pthread库允许设置线程的属性,如调度策略、栈大小等。`pthread_attr_init()`和`pthread_attr_set*()`函数可以用来初始化和修改...

    Linux线程同步之互斥量(mutex).pdf

    - `pthread_mutex_init`:用于初始化互斥量,可以指定互斥量的属性,如是否在进程间共享。如果使用PTHREAD_MUTEX_INITIALIZER宏定义的方式,则无需调用该函数。 - `pthread_mutex_destroy`:用于销毁互斥量,释放其...

    pthread_pthread_

    - **条件变量(Condition Variables)**:`pthread_cond_t`用于线程间的通信和同步,`pthread_cond_wait()`使线程等待,`pthread_cond_signal()`或`pthread_cond_broadcast()`唤醒等待的线程。 - **信号量...

    UNIX Linux实验教程 5实验五Linux多线程程序设计.doc

    当父子进程间需要交换信息时,需要借助操作系统提供的进程间通信机制来实现,如信号量、管道、消息通信、共享内存,这些机制通常开销很大,需要在用户程序与内核之间的上下文切换,还要在内存间多次数据拷贝。...

    共享内存+互斥量实现linux进程间通信.pdf

    共享内存并未提供进程同步机制,使用共享内存完成进程间通信时,需要借助互斥量或者信号量来完成进程的同步。 二、使用系统调用完成共享内存的申请、连接、分离和删除 共享内存函数由 shmget、shmat、shmdt、...

    pia.c.tar.gz_pthread_圆周率

    线程在读写这些共享数据时,需要使用`pthread_mutex_lock()`和`pthread_mutex_unlock()`进行同步。 5. 并行计算策略:程序可能会将计算任务划分为若干部分,每个线程处理一部分,最后汇总结果。这可能涉及到线程间...

    Linux系统编程之线程同步

    实际上,不仅线程间需要同步,进程间、信号间等等都需要同步机制。 因此,所有“多个控制流,共同操作一个共享资源”的情况,都需要同步。 数据混乱原因: 1. 资源共享(独享资源则不会) 2. 调度随机(意味着...

    linux下C语言多线程编程实例

    线程间通信和同步是多线程编程中的关键问题,防止数据竞争和死锁是实现高效并发的关键。 二、pthread库介绍 pthread库提供了以下主要函数: 1. `pthread_create()`: 创建新的线程,传入线程函数指针和参数。 2. `...

    linux无亲缘关系间进程同步通信实现(互斥锁+条件变量+共享内存模式)

    在Linux操作系统中,进程间的通信是系统编程的重要组成部分,尤其在多线程或多进程环境中,为了确保数据的一致性和正确性,同步机制显得至关重要。本主题将深入探讨如何使用互斥锁、条件变量以及共享内存这三种机制...

    linux多线程详解

    ### 线程间同步:互斥锁`pthread_mutex_t` 在多线程编程中,线程间共享资源的访问必须进行同步控制,以免发生竞态条件。`pthread_mutex_t`类型提供了一种机制来实现互斥访问。 #### 初始化互斥锁:`pthread_mutex_...

    Linux Multiply thread programming(多线程编程初步)

    2. **提高通信效率**:多线程之间的通信比进程间通信更为简单和高效,因为它们可以共享同一进程内的资源,如全局变量。 3. **减少上下文切换的开销**:相比于进程切换,线程切换的开销较小,这是因为它们共享同一...

    linux的多线程编程的高效开发经验

    条件变量是另一种同步机制,主要用于实现线程间的通信和同步。条件变量的操作主要有以下几种: 1. **创建条件变量**:`pthread_cond_init()`函数初始化一个条件变量。 ```c int pthread_cond_init(pthread_cond...

    管程实现子进程和父进程的互斥访问

    1. **信号量(Semaphore)**:信号量是一种用于进程间通信的同步机制,它通过维护一个整型变量来控制对公共资源的访问。当这个变量为正时,表示有可用资源;当变量为零时,表示资源已被占满,尝试访问的进程会被阻塞...

Global site tag (gtag.js) - Google Analytics