| | |
| | | if (0 == openingFlag.get()) |
| | | return; |
| | | |
| | | // TODO |
| | | log.info("map " + mapBedVsQueue.size() + " priority " + priorityQueue.size()); |
| | | if (mapBedVsQueue.size() != priorityQueue.size()) { |
| | | log.error("map " + mapBedVsQueue.size() + " priority " + priorityQueue.size()); |
| | | } |
| | | |
| | | // 处理 过号-回来 的人 |
| | | for (BedQueueBO bedQueueBO : mapBedVsQueue.values()) { |
| | | while (bedQueueBO.queueNum.get() < bedQueueBO.maxQueueNum) { |
| | |
| | | return updateNum; |
| | | } |
| | | |
| | | @Override |
| | | public void monitorInfo() { |
| | | log.info("map " + mapBedVsQueue.size() + " priority " + priorityQueue.size() |
| | | + " opening " + openingFlag.get()); |
| | | } |
| | | |
| | | private void startHurryUp() { |
| | | singleThreadExecutor.execute( () -> { |
| | | hurryup(); |