Demo示例 最簡單的生產者和消費者問題

package treadtest;

/*生產者不斷的生產產品給店員，消費者在店員這裡消費產品，要求是當店員處有最多只能存放20個產品，
*/class
clerk
else
catch
(interruptedexception e)}}
//消費者消費產品
public
synchronized
void
customerproduct()
else
catch
(interruptedexception e)}}
}//生產者
class
product
extends
thread
@override
public
void
run(
)catch
(interruptedexception e)
clerk.
productproduct()
;}}}
//消費者
class
customer
extends
thread
@override
public
void
run(
)catch
(exception e)
clerk.
customerproduct()
;}}}
public
class
producttest
}

消費者1

:開始消費產品
生產者1：開始生產產品
消費者2
:開始消費產品
生產者1生產了第1個產品
生產者1生產了第2個產品
消費者1消費了第2個產品
消費者2消費了第1個產品
生產者1生產了第1個產品
生產者1生產了第2個產品
生產者1生產了第3個產品
消費者1消費了第3個產品
消費者2消費了第2個產品
生產者1生產了第2個產品
生產者1生產了第3個產品
生產者1生產了第4個產品
消費者1消費了第4個產品
消費者2消費了第3個產品
生產者1生產了第3個產品
生產者1生產了第4個產品
生產者1生產了第5個產品
消費者1消費了第5個產品
消費者2消費了第4個產品
生產者1生產了第4個產品
生產者1生產了第5個產品
生產者1生產了第6個產品..
.

生產者消費者 簡單示例

class meal public string tostring class waitperson implements runnable public void run system.out.println waitperson got restaurant.meal synchronized ...

Kafka的生產者消費者Java操作示例

1.首先看下pom依賴 org.apache.kafka kafka clients 2.0.0 log4j log4j 1.2.17 org.slf4j slf4j nop 1.7.22 2.新建producer類，其 如下 public class producer catch interrup...

使用joinablequeue的生產者和消費者模型

import multiprocessing import queue import time def consumer output q print time is format time.ctime while true item output q.get print pull item out...