如何用java开发一个类似生产者消费者的应用？

发布于 2024-12-06 14:38:43 字数 370 浏览 0 评论 0原文

我必须开发一个类似于java中的生产者-消费者问题的应用程序。

不过我对java不太了解，有几个问题想请教一下。

生产者和消费者都是不同的线程，并且它们都需要访问相同的缓冲区。如果它们都是不同的类（扩展线程类或实现可运行接口），我如何编码它们以使用完全相同的缓冲区（这个假定的缓冲区是某个对象的数组）？

我还想阅读一些有关整体架构以及我应该如何实现它们的建议。我需要对它们进行编码，以便两个线程不会同时消耗相同的缓冲区位置，两个生产者线程不会同时插入完全相同的值，生产者无法在缓冲区已经填满，并且当缓冲区为空时，任何消费者都不应该消费。

在这个例子中，必须有多个消费者和多个生产者同时工作。

我在java中查找了一些示例，但它们与我需要的都不同。

原文

分享到QQ

分享到微博

如果你对这篇内容有疑问，欢迎到本站社区发帖提问参与讨论，获取更多帮助，或者扫码二维码加入 Web 技术交流群。

发布评论

需要登录才能够评论，你可以免费注册一个本站的账号。

流殇 2024-12-13 14:38:43

您可以通过构造函数将数组或列表的同一实例传递给消费者和生产者。

Array a = new Array();
Consumer c = new Consumer(a);
Producer p = new Producer(a);

对于第二个问题，您想了解（google一下！）Java中的同步。您可以再次将相同的 private Object lock1 = new Object(); 传递给消费者和生产者，他们可以将其用作共享锁。

http://download.oracle.com/javase/tutorial/essential/concurrency /locksync.html

每当消费者或生产者访问共享数组时，他们都需要首先获取锁。其他条件要求，例如“数组已满时不插入元素”或“数组为空时不消耗元素”可以在同步块内实现。

public void add(Object someObject){
    synchronized (lock1) {
        if(a.size()>limit) {
            System.out.println("Array is full");
        } else {
           a.add(someObject)
        }
    }
}

You can pass in a same instance of array or list to both consumer and producer by passing it through their constructor.

Array a = new Array();
Consumer c = new Consumer(a);
Producer p = new Producer(a);

For the second question, you would like to learn about (google it!) for synchronization in Java. You can again pass in the same private Object lock1 = new Object(); to both consumer and producer and they can use it as a shared lock.

http://download.oracle.com/javase/tutorial/essential/concurrency/locksync.html

Whenever a consumer or a producer access the shared array, they would need to acquire lock first. Other conditional requirements such as 'not inserting elements when the array is full' or 'not consuming elements when the array is empty' can be implemented inside the synchronized block.

public void add(Object someObject){
    synchronized (lock1) {
        if(a.size()>limit) {
            System.out.println("Array is full");
        } else {
           a.add(someObject)
        }
    }
}

回复收藏 0 原文