Second Requirement will not pass, even though my code is identical with solution...!!

Question about the task

New

package com.codegym.task.task27.task2712;

import com.codegym.task.task27.task2712.kitchen.Cook;
import com.codegym.task.task27.task2712.kitchen.Order;
import com.codegym.task.task27.task2712.statistics.StatisticsManager;

import java.util.Observable;
import java.util.Observer;
import java.util.Set;
import java.util.concurrent.LinkedBlockingQueue;

public class OrderManager implements Observer {
    private LinkedBlockingQueue<Order> orderQueue = new LinkedBlockingQueue(200);

    public OrderManager() {
        Thread thread = new Thread() {
            @Override
            public void run() {

                Set<Cook> cooks = StatisticsManager.getInstance().getCooks();
                try {
                    while (true) {
                        Thread.sleep(10);
                        if (!orderQueue.isEmpty()) {
                            for (Cook cook : cooks) {
                                if (!cook.isBusy()) {
                                    cook.startCookingOrder(orderQueue.take());
                                }
                            }
                        }
                    }
                } catch (InterruptedException e) {
                }


            }
        };
        thread.setDaemon(true);
        thread.start();
    }

    @Override
    public void update(Observable o, Object order){
        orderQueue.add((Order) order);

    }


}

We continue to fix the bug.

Now all the orders arrive in the queue, but they don't reach the cooks.
We'll make OrderManager find any available cook and give it an order. To implement this logic, we need a deamon thread. It will check for orders in the queue, and then grab available cooks and give them orders.

We're going to need a method that determines whether a cook is busy.
1. In the Cook class, create a boolean busy field with a getter.
2. At the beginning of the startCookingOrder method, set busy to true; and at the end of the method, set it to false.
3. In the startCookingOrder method, simulate the delay resulting from preparing a dish: sleep for 10 times the order's required preparation time. In other words, if an order takes 30 minutes to prepare, then the delay will be 30 * 10 milliseconds.
4. To get a list of all the cooks, in the StatisticsManager class, add a getter for the field that is populated in the register(Cook cook) method.
5. In the OrderManager constructor, create and run a daemon thread. Here's the logic of the run method:
check the queue every 10 milliseconds. If the queue has orders, then look for available cooks and pass them the orders (startCookingOrder method). If there are no available cooks or there are no orders in the queue, then keep waiting.

Requirements:

A boolean busy field and corresponding getter must be created in the Cook class.
The daemon thread described in the task conditions must be created and started in the OrderManager class constructor.
In the startCookingOrder method, the Thread.sleep() method must be called with an argument equal to ten times the order's required preparation time.

package com.codegym.task.task27.task2712; import com.codegym.task.task27.task2712.kitchen.Cook; import com.codegym.task.task27.task2712.kitchen.Waiter; import com.codegym.task.task27.task2712.statistics.StatisticsManager; import java.util.ArrayList; import java.util.List; public class Restaurant { private static final int ORDER_CREATION_INTERVAL = 100; public static void main(String[] args) { Cook cook1 = new Cook("Amigo"); Cook cook2 = new Cook("Pietro"); // create second cook StatisticsManager.getInstance().register(cook1); // register cooks with StatisticsManager StatisticsManager.getInstance().register(cook2); Waiter waiter = new Waiter(); List<Tablet> tabletList = new ArrayList<>(); for (int i = 0; i < 5; i++){ tabletList.add(new Tablet(i + 1)); } Thread menuThread = new Thread(new RandomOrderGeneratorTask(tabletList, ORDER_CREATION_INTERVAL)); menuThread.start(); try { Thread.sleep(1000); menuThread.interrupt(); menuThread.join(); Thread.sleep(1000); } catch (InterruptedException ignored){ } cook1.addObserver(waiter); cook2.addObserver(waiter); ManagerTablet managerTablet = new ManagerTablet(); managerTablet.printAdRevenue(); managerTablet.printCookUtilization(); managerTablet.printActiveVideoSet(); managerTablet.printArchivedVideoSet(); } }

Comments

Popular
New
Old

You must be signed in to leave a comment

This page doesn't have any comments yet