生产者——消费者(生产国和消费国)问题,也称作有界缓冲区(有界限的缓冲区)问题,两个进程共享一个公共的固定大小的缓冲区。其中一个是生产者,用于将消息放入缓冲区;另外一个是消费者,用于从缓冲区中取出消息。问题出现在当缓冲区已经满了,而此时生产者还想向其中放入一个新的数据项的情形,其解决方法是让生产者此时进行休眠,等待消费者从缓冲区中取走了一个或者多个数据后再去唤醒它。同样地,当缓冲区已经空了,而消费者还想去取消息,此时也可以让消费者进行休眠,等待生产者放入一个或者多个数据时再唤醒它。
<强>一,首先定义公共资源类,其中的变量数量是保存的公共数据。
并且定义两个方法,增加数量的值和减少数量的值,由于多线程的原因,必须加上同步关键字,注意而判断的条件。
Java代码,,
<强>二,分别定义生产
/* *
*公共资源类
*/公开课PublicResource {
私人int数=0;/* *
*增加公共资源
*/公共同步空白increace () {
而(号码!=0){
尝试{
wait ();
}捕捉(InterruptedException e) {
e.printStackTrace ();
}
}
+ +;
System.out.println(数量);
notify ();
}/* *
*减少公共资源
*/公共同步空白decreace () {
虽然(数量==0){
尝试{
wait ();
}捕捉(InterruptedException e) {
e.printStackTrace ();
}
}
数,;
System.out.println(数量);
notify ();
}
}
者线程和消费者线程,并模拟多次生产和消费,即增加和减少公共资源的数量值
Java代码,,
/* *
*生产者线程,负责生产公共资源
*/公共类ProducerThread实现Runnable {
私人PublicResource资源;
公共ProducerThread (PublicResource资源){
这一点。资源=资源;
}
@Override
公共空间run () {
for (int i=0;我& lt;10;我+ +){
尝试{
thread . sleep((长)(math . random () * 1000));
}捕捉(InterruptedException e) {
e.printStackTrace ();
}
resource.increace ();
}
}
}/* *
*消费者线程,负责消费公共资源
*/公共类ConsumerThread实现Runnable {
私人PublicResource资源;
公共ConsumerThread (PublicResource资源){
这一点。资源=资源;
}
@Override
公共空间run () {
for (int i=0;我& lt;10;我+ +){
尝试{
thread . sleep((长)(math . random () * 1000));
}捕捉(InterruptedException e) {
e.printStackTrace ();
}
resource.decreace ();
}
}
}
<强>三、模拟多个生产者和消费者操作公共资源的情形,结果须保证是在允许的范围内。
Java代码,,
公开课ProducerConsumerTest {
公共静态void main (String [] args) {
PublicResource资源=new PublicResource ();
新线程(新ProducerThread(资源)).start ();
新线程(新ConsumerThread(资源)).start ();
新线程(新ProducerThread(资源)).start ();
新线程(新ConsumerThread(资源)).start ();
新线程(新ProducerThread(资源)).start ();
新线程(新ConsumerThread(资源)).start ();
}
}
以上所述是小编给大家介绍的Java生产者和消费者例子,希望对大家有所帮助,如果大家有任何疑问请给我留的言,小编会及时回复大家的。在此也非常感谢大家对网站的支持!
