多生产者多消费者linux内核,Linux多线程-生产者和消费者

一时失言乱红尘 2023-01-20 09:40 72阅读 0赞

\#include

using namespace std;

//\#define DEBUG

\#define VOLATILE volatile

\#ifndef VOLATILE

\#define VOLATILE

\#endif

\#define handle\_func\_ret\_val\_ne0(func)\\

do\{if(func!=0) \{ perror(\#func); exit(-1);\} \} while(0)

class locker

public:

locker ( pthread\_mutex\_t \*mutex):lock(mutex)\{

pthread\_mutex\_lock(lock);

\#ifdef DEBUG

cout<

\#endif

~locker () \{

pthread\_mutex\_unlock(lock);

\#ifdef DEBUG

cout<

\#endif

private:

pthread\_mutex\_t\* lock;

\};

class factory

public:

factory()

:push\_pos(0),pop\_pos(0),size(0)\{\}

~factory()\{

int pop()\{

int ret=buffer\[pop\_pos++\];

if(pop\_pos==buffer\_size)

pop\_pos=0;

\--size;

\#ifdef DEBUG

cout<

\#endif

return ret;

int push(int val)\{

buffer\[push\_pos++\]=val;

if(push\_pos==buffer\_size)

push\_pos=0;

\++size;

\#ifdef DEBUG

cout<

\#endif

return val;

bool is\_full()\{

return size==buffer\_size;

bool is\_empty()\{

return size==0;

protected:

VOLATILE int push\_pos;

VOLATILE int pop\_pos;

VOLATILE int size;

static const int buffer\_size=5;

private:

int buffer\[buffer\_size\];

\};

class factory\_manager

public:

factory\_manager():

mutex(PTHREAD\_MUTEX\_INITIALIZER),

not\_empty(PTHREAD\_COND\_INITIALIZER),

not\_full(PTHREAD\_COND\_INITIALIZER)\{\}

~factory\_manager()\{

pthread\_mutex\_destroy(&mutex);

pthread\_cond\_destroy(&not\_empty);

pthread\_cond\_destroy(&not\_full);

int put(int val)\{

locker lock(&mutex);

while(ft.is\_full())\{

\#ifdef DEBUG

cout<

\#endif

pthread\_cond\_wait(&not\_full,&mutex);

\#ifdef DEBUG

cout<

\#endif

ft.push(val);

pthread\_cond\_signal(&not\_empty);

return val;

int get()\{

int val;

locker lock(&mutex);

while(ft.is\_empty())\{

\#ifdef DEBUG

cout<

\#endif

pthread\_cond\_wait(&not\_empty,&mutex);

\#ifdef DEBUG

cout<

\#endif

val=ft.pop();

pthread\_cond\_signal(&not\_full);

return val;

private:

pthread\_mutex\_t mutex;

pthread\_cond\_t not\_empty;

pthread\_cond\_t not\_full;

factory ft;

\};

class user

public:

user(const string& n,factory\_manager& f):name(n),fm(f)\{\}

~user()\{\}

virtual void run()=0;

protected:

string name;

factory\_manager& fm;

\};

class producer:public user

public:

producer(const string& n,factory\_manager& f):user(n,f)\{\}

~producer()\{\}

void run()\{

\#ifdef DEBUG

cout<

\#endif

srand(time(0));

for(int i=0;i<10;++i)\{

int val=rand();

fm.put(val);

cout<

\};

class customer:public user

public:

customer(const string& n,factory\_manager& f):user(n,f)\{\}

~customer()\{\}

void run()\{

\#ifdef DEBUG

cout<

\#endif

for(int i=0;i<10;++i)\{

int val=fm.get();

cout<

sleep(1);

\};

void\* thread\_func(void\* data)

user\* u=(user\*)data;

u->run();

int main()

factory\_manager manager;

producer pa("producera",manager);

producer pb("producerb",manager);

customer ca("customera",manager);

customer cb("customerb",manager);

user\* user\_table\[4\]=\{&pa,&pb,&ca,&cb\};

pthread\_t thread\_table\[4\];

for(int i=0;i<4;++i)\{

pthread\_create(&thread\_table\[i\],0,thread\_func,user\_table\[i\]);

for(int i=0;i<4;++i)\{

pthread\_join(thread\_table\[i\],0);

cout<

多生产者多消费者linux内核,Linux多线程-生产者和消费者

发表评论取消回复

还没有评论，来说两句吧...

相关阅读

相关多线程生产者消费者模型

相关多生产者多消费者linux内核,Linux多线程-生产者和消费者

相关 C#多线程的生产者和消费者

相关多线程-生产者消费者模式（1）

相关多线程生产者和消费者

相关多线程实践-生产者消费者

相关 Java——多生产者多消费者

相关 Java——生产者消费者多线程实现

相关多线程之生产者与消费者

相关多线程_生产者消费者问题