当前位置: 技术问答>linux和unix
求助多线程并发的问题——rechard stevens网络编程第二卷例题
来源: 互联网 发布时间：2016-08-31
本文导语: #include "../unpipc.h" #include "../apuerror.h" #include "pthread.h" #define MAXNTHREADS 5 #define MAXNITEMS 10000 int nitems; struct { pthread_mutex_t mutex; int buff[MAXNITEMS]; int nput; int nval; } share...
#include "../unpipc.h"
#include "../apuerror.h"
#include "pthread.h"
#define MAXNTHREADS 5
#define MAXNITEMS 10000
int nitems;
struct {
pthread_mutex_t mutex;
int buff[MAXNITEMS];
int nput;
int nval;
} shared = {PTHREAD_MUTEX_INITIALIZER};
void *produce(void *),*consume(void *);
int
main(int argc,char **argv)
{
int i,nthreads,count[MAXNTHREADS];
pthread_t tid_produce[MAXNTHREADS],tid_consume;
// if(argc!=3)
// err_quit("usage:prodcons2");
//nitems = min(atoi(argv[1]),MAXNITEMS);
//nthreads = min(atoi(argv[2]),MAXNTHREADS);
nitems = MAXNITEMS;
nthreads = MAXNTHREADS;
if(pthread_setconcurrency(nthreads)!=0)
printf("setconvrrency error ");
int j=pthread_getconcurrency();
printf("number of concurrency is %dn",j);
for(i=0;i
#include "../apuerror.h"
#include "pthread.h"
#define MAXNTHREADS 5
#define MAXNITEMS 10000
int nitems;
struct {
pthread_mutex_t mutex;
int buff[MAXNITEMS];
int nput;
int nval;
} shared = {PTHREAD_MUTEX_INITIALIZER};
void *produce(void *),*consume(void *);
int
main(int argc,char **argv)
{
int i,nthreads,count[MAXNTHREADS];
pthread_t tid_produce[MAXNTHREADS],tid_consume;
// if(argc!=3)
// err_quit("usage:prodcons2");
//nitems = min(atoi(argv[1]),MAXNITEMS);
//nthreads = min(atoi(argv[2]),MAXNTHREADS);
nitems = MAXNITEMS;
nthreads = MAXNTHREADS;
if(pthread_setconcurrency(nthreads)!=0)
printf("setconvrrency error ");
int j=pthread_getconcurrency();
printf("number of concurrency is %dn",j);
for(i=0;i
本站(WWW.)旨在分享和传播互联网科技相关的资讯和技术，将尽最大努力为读者提供更好的信息聚合和浏览方式。
本站(WWW.)站内文章除注明原创外，均为转载、整理或搜集自网络。欢迎任何形式的转载，转载请注明出处。
本站(WWW.)站内文章除注明原创外，均为转载、整理或搜集自网络。欢迎任何形式的转载，转载请注明出处。
站内导航:
特别声明:169IT网站部分信息来自互联网,如果侵犯您的权利,请及时告知,本站将立即删除！