消費者 生產者模型

2022-05-18 09:25:34 字數 3897 閱讀 6954

摘自生產者-消費者的三種實現

public class productorconsumer 

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

}static class productor implements runnable

@override

public void run()

random random = new random();

int i = random.nextint();

system.out.println("生產者" + thread.currentthread().getname() + " 生產資料" + i);

list.add(i);

list.notifyall();

} catch (interruptedexception e) }}

}}static class consumer implements runnable

@override

public void run()

integer element = list.remove(0);

system.out.println("消費者" + thread.currentthread().getname() + " 消費資料:" + element);

list.notifyall();

} catch (interruptedexception e) }}

}}}

輸出如下:

生產者pool-1-thread-1 生產資料-232820990

生產者pool-1-thread-1 生產資料1432164130

生產者pool-1-thread-1 生產資料1057090222

生產者pool-1-thread-1 生產資料1201395916

生產者pool-1-thread-1 生產資料482766516

生產者pool-1-thread-1 list以達到最大容量,進行wait

消費者pool-1-thread-15 退出wait

消費者pool-1-thread-15 消費資料:1237535349

消費者pool-1-thread-15 消費資料:-1617438932

消費者pool-1-thread-15 消費資料:-535396055

消費者pool-1-thread-15 消費資料:-232820990

消費者pool-1-thread-15 消費資料:1432164130

消費者pool-1-thread-15 消費資料:1057090222

消費者pool-1-thread-15 消費資料:1201395916

消費者pool-1-thread-15 消費資料:482766516

消費者pool-1-thread-15 list為空,進行wait

生產者pool-1-thread-5 退出wait

生產者pool-1-thread-5 生產資料1442969724

生產者pool-1-thread-5 生產資料1177554422

生產者pool-1-thread-5 生產資料-133137235

生產者pool-1-thread-5 生產資料324882560

生產者pool-1-thread-5 生產資料2065211573

生產者pool-1-thread-5 生產資料253569900

生產者pool-1-thread-5 生產資料571277922

生產者pool-1-thread-5 生產資料1622323863

生產者pool-1-thread-5 list以達到最大容量,進行wait

消費者pool-1-thread-10 退出wait

由於blockingqueue內部實現就附加了兩個阻塞操作。即當佇列已滿時,阻塞向佇列中插入資料的執行緒,直至佇列中未滿;當隊列為空時,阻塞從佇列中獲取資料的執行緒,直至佇列非空時為止。

public class productorconsumer 

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

}static class productor implements runnable

@override

public void run()

} catch (interruptedexception e) }}

static class consumer implements runnable

@override

public void run()

} catch (interruptedexception e) }}

}

輸出如下:

消費者pool-1-thread-7正在消費資料1520577501

生產者pool-1-thread-4生產資料-127809610

消費者pool-1-thread-8正在消費資料504316513

生產者pool-1-thread-2生產資料1994678907

消費者pool-1-thread-11正在消費資料1967302829

生產者pool-1-thread-1生產資料369331507

消費者pool-1-thread-9正在消費資料1994678907

生產者pool-1-thread-2生產資料-919544017

消費者pool-1-thread-12正在消費資料-127809610

生產者pool-1-thread-4生產資料1475197572

消費者pool-1-thread-14正在消費資料-893487914

生產者pool-1-thread-3生產資料906921688

消費者pool-1-thread-6正在消費資料-1292015016

生產者pool-1-thread-5生產資料-652105379

生產者pool-1-thread-5生產資料-1622505717

生產者pool-1-thread-3生產資料-1350268764

消費者pool-1-thread-7正在消費資料906921688

生產者pool-1-thread-4生產資料2091628867

消費者pool-1-thread-13正在消費資料1475197572

消費者pool-1-thread-15正在消費資料-919544017

生產者pool-1-thread-2生產資料564860122

生產者pool-1-thread-2生產資料822954707

消費者pool-1-thread-14正在消費資料564860122

消費者pool-1-thread-10正在消費資料369331507

生產者pool-1-thread-1生產資料-245820912

消費者pool-1-thread-6正在消費資料822954707

生產者pool-1-thread-2生產資料1724595968

生產者pool-1-thread-2生產資料-1151855115

消費者pool-1-thread-12正在消費資料2091628867

生產者pool-1-thread-4生產資料-1774364499

生產者pool-1-thread-4生產資料2006106757

消費者pool-1-thread-14正在消費資料-1774364499

生產者pool-1-thread-3生產資料-1070853639

消費者pool-1-thread-9正在消費資料-1350268764

消費者pool-1-thread-11正在消費資料-1622505717

生產者pool-1-thread-5生產資料355412953

生產者消費者模型

1.生產者消費者問題 producer consumer 有限緩衝,多執行緒同步。生產者執行緒和消費者執行緒共享固定大小緩衝區。2.關鍵是保證生產者不會再緩衝區滿時加入資料,消費者不會在緩衝區空時消耗資料。3.解決辦法 讓生產者在緩衝區滿時休眠,等下次消費者消耗緩衝區中的資料的時候,生產者才能被喚醒...

生產者消費者模型

生產者與消費者 3,2,1 三種關係 生產者與消費者 互斥,同步 消費者與消費者 互斥 生產者與生產者 互斥 條件變數 int pthread cond destroy pthread cond t cond int pthread cond init pthread cond t restrict...

生產者消費者模型

當佇列滿時,生產者需要等待佇列有空間才能繼續往裡面放入商品,而在等待的期間內,生產者必須釋放對臨界資源 即佇列 的占用權。因為生產者如果不釋放對臨界資源的占用權,那麼消費者就無法消費佇列中的商品,就不會讓佇列有空間,那麼生產者就會一直無限等待下去。因此,一般情況下,當佇列滿時,會讓生產者交出對臨界資...