Java同时生成无限数量的对象

Question

所以我需要制作一个电梯模拟器，我想知道如何才能不断地让人们呼叫电梯。我需要这个永远持续下去。所以基本上一个人被创建并呼叫电梯。所有这些电话都会被跟踪，但我想我也需要跟踪实际在电梯上的人。

我有几门课Person、Elevator、ElevatorCall & ElevatorCallQueue。

1. In Person 我有一个 run() 方法，它基本上使用当前楼层和目标楼层进行电梯呼叫，然后我有一个 BlockingQueue 进行呼叫。此 run 方法仅在 true 时运行。

2. 在 ElevatorCall 我只有 getters 和 setters 用于收集和目标楼层

3. 在 ElevatorCallQueue 中，我有 MAX_CALLS 和 numberOfPeople 的变量。 我有一个BlockingQueue<ElevatorCall> queue = new ArrayBlockingQueue<ElevatorCall>(MAX_CALLS) 和List<Person> 我将人员添加到列表中，然后遍历列表并在每个人上启动 run() 方法。最后，我创建了一个电梯并提供了队列，然后运行它。

4. 在电梯里我有BlockingQueue<ElevatorCalls>。我在这里也有一个while(true)，在其中我创建了一个ArrayList<ElevatorCall>，然后我使用BlockingQueues drainTo 方法，使用ArrayList<ElevatorCalls> 作为参数。 run() 方法的其余部分基本上遍历数组列表并执行电梯所做的工作，因此它会转到第一个按下的按钮，检查每个楼层是否有人以及是否是目标楼层。

现在我被卡住了，不知道从这里去哪里。我需要了解人们如何不断添加和呼叫电梯，如果没有更多呼叫，让电梯等待。如果有人能帮助我朝着正确的方向前进，我将不胜感激。 谢谢

编辑

Here is the code to the elevator class 有人说我应该发布一些代码。但是我不确定要发布什么代码，所以我想我应该把整个班级都放进去

Answer 1

我认为每个人都很快就接受了并发这个词——不要让它影响你的判断。我不能代表您的确切问题/标准发言，但电梯会前往楼层，唯一的干扰是新人按下按钮。那么，为什么不给电梯一个方法simulate(int time) 这样做，以及一个方法new_person(person p) 将另一个人添加到队列中。然后只需生成一个随机时间间隔，模拟电梯，添加一个随机楼层目的地和来源的新人，然后重复。

但你说它必须是并发的-

你的问题似乎是电梯呼叫来自哪里？

这是典型的生产者消费者模式的一个例子。你问什么？ 好吧，BlockingQueue 的 oracle 文档提供了一个比我更好的例子

class Producer implements Runnable {
   private final BlockingQueue queue;
   Producer(BlockingQueue q) { queue = q; }
   public void run() {
     try {
       while (true) { queue.put(produce()); }
     } catch (InterruptedException ex) { ... handle ...}
   }
   Object produce() { ... }
 }

 class Consumer implements Runnable {
   private final BlockingQueue queue;
   Consumer(BlockingQueue q) { queue = q; }
   public void run() {
     try {
       while (true) { consume(queue.take()); }
     } catch (InterruptedException ex) { ... handle ...}
   }
   void consume(Object x) { ... }
 }

 class Setup {
   void main() {
     BlockingQueue q = new SomeQueueImplementation();
     Producer p = new Producer(q);
     Consumer c1 = new Consumer(q);
     Consumer c2 = new Consumer(q);
     new Thread(p).start();
     new Thread(c1).start();
     new Thread(c2).start();
   }
 }

嗯.. 你能看出这与你的问题有什么关系吗？你已经解决了一半。

电梯充当电梯呼叫的消费者，您似乎在为谁生产它们而苦苦挣扎。这是运行 ElevatorCall 生产者的新线程的工作。看看你能不能解决剩下的问题。