prg12_3_1.c

配套光盘网络编程进程间的通信,网络编程进程间的通信是一本很经典的好书

#include <stdlib.h>
#include <semaphore.h>
#include <sys/types.h>
#include <unistd.h>
#include <errno.h>
#include <pthread.h>
#include <sys/stat.h>
#include <sys/mman.h>
#include <fcntl.h>
#include <stdio.h>
#include "myipc.h"

#define	SEQFILE	"zjm.txt"
#define	FILE_MODE	(S_IRUSR | S_IWUSR | S_IRGRP | S_IROTH)
int main(int argc,char **argv)
{
  int  fd,fdlock,i,nloop,zero = 0;
  int  *ptr;
  pid_t  pid;
   
  if (argc !=3)
  {
    printf("usage:%s <pathname><#loops>",argv[0]);
    exit(0);
  }
  
  fdlock = open(SEQFILE,O_RDWR,FILE_MODE);
  nloop = atoi(argv[2]);
  fd = open(argv[1],O_RDWR | O_CREAT, FILE_MODE);
  write(fd,&zero,sizeof(int));
  ptr = mmap(NULL,sizeof(int),PROT_READ | PROT_WRITE,MAP_SHARED,
     fd,0);
  close(fd);
  setbuf(stdout,NULL);
  
  if ( (pid=fork()) == 0)
  {
    for(i=0;i<nloop;i++)
    {
      zm_readw_lock(fdlock,0,SEEK_SET,0);
      printf("child:%d\n",(*ptr)++);
      zm_un_lock(fdlock,0,SEEK_SET,0);
    }
    exit(0);
  }
  else if (pid >0)
  {//parent    
    for(i=0; i<nloop;i++)
    {
    	zm_readw_lock(fdlock,0,SEEK_SET,0);
    	printf("parent:%d\n",(*ptr)++);
    	zm_un_lock(fdlock,0,SEEK_SET,0);
    }
  else
  {
  	printf("fork() error\n");
  }
    
  exit(0);
}