我正在处理一个更复杂的版本(车辆在 X 和 Y 两个方向上移动)

我做这个例子是为了获得更好的方法来完成这个。

1. 我有一辆汽车以 (24.5872 mps) 的速度沿 X 方向行驶
2. 我通过使用执行器每 100 毫秒递增 X 值来对此进行模拟(以使其 X 位置更加准确和实时)
3. 每一秒后，我都会向另一个进程发送一条消息，其中包含我刚刚覆盖的行的 xMin 和 xMax 值
4. 另一个进程将用 JMS 消息(通常是即时的)响应，如果在之前的 X 区域中存在“坑洞”(消息回调消息到 linkedblockingqueue)，告诉我停止。

我遇到的问题是“通常立即”部分。如果我没有足够快地得到响应，我认为它会影响我的算法的整个计时。处理这种情况的更好方法是什么？

这是我正在尝试做的一些基本代码:

public class Mover implements MessageHandler {

    private static final long CAR_UPDATE_RATE_IN_MS = 100;
    private static double currX = 0;
    private static double CONSTANT_SPEED_IN_MPS = 24.5872; // 55 mph
    private static double increment = CONSTANT_SPEED_IN_MPS / (1000 / CAR_UPDATE_RATE_IN_MS);
    static LinkedBlockingQueue<BaseMessage> messageQueue = new LinkedBlockingQueue<BaseMessage>(); // ms

    private static int incrementor = 0;

    public static void main(String[] args) {
        startMoverExecutor();
    }

    private static void startMoverExecutor() {

        ScheduledExecutorService mover = Executors.newSingleThreadScheduledExecutor();
        mover.scheduleAtFixedRate((new Runnable() {

            @Override
            public void run() {
                currX = incrementor * increment;

                if (incrementor % (1000 / CAR_UPDATE_RATE_IN_MS) == 0) {
                    System.out.println(currX);

                    sendMessage(currX - CONSTANT_SPEED_IN_MPS, currX);

                    // do something
                    try {
                        messageQueue.poll(1000, TimeUnit.MILLISECONDS);

                    } catch (InterruptedException e) {
                        // TODO Auto-generated catch block
                        e.printStackTrace();
                    }

                }
                incrementor++;
            }

        }), 0, CAR_UPDATE_RATE_IN_MS, TimeUnit.MILLISECONDS);

    }

    @Override
    public void handleMessage(BaseMessage msg) {
        messageQueue.add(msg);

    }

    protected static void sendMessage(double firstX, double secondX) {
        // sendMessage here

    }

}

最佳答案

我建议按照以下步骤对上述算法进行更改。

JMS调用其他进程

1a.从发送车辆的当前位置开始。

1b。另一个进程将响应 JMS 消息，其中包含车辆位置可见区域中所有“坑洞位置”的列表。将此“可见坑洞位置”列表保存在客户端，以供在以下步骤中使用。

1c。我们将可见区域定义为车辆的邻近区域，这样即使使用 JMS 调用其他进程(1 秒延迟 + 网络延迟)，车辆的移动也不应越过该区域。

1d。每一秒后，重复步骤 1a 和 1b 并替换客户端相对于车辆当前位置的坑洞位置列表。

.

车辆运动观察者

2a。实现可以接收车辆移动通知的观察者模式。

2b。每次生成事件时，观察者都会检查车辆的位置是否与步骤 1b 中获取的可见坑洞列表中的条目之一匹配。

2c。如果找到匹配项，宾果游戏!你必须停下车辆。

.

车辆运动

3a。注册step-2a观察者观察车辆的运动

3b。等到您从步骤 1b 中获得至少第一个可见坑洞列表。

3c。通过每 100 毫秒增加 X 值开始移动车辆。每次移动时，它都应该通知 step-2a 观察者。

.

下图的图例:

o - Instance of each pot hole somewhere on map 
X - Moving vehical
. - Path followed by vehical
Circle - Visible area of the vehical driver

+---------------------------------------------+
|                                             |
|                    o                o       |
|    o                                        |
|                                             |
|                                             |
|                _.-''''`-._                  |
|    o         ,'           `.             o  |
|            ,'  o            `.              |
|           .'    .            `.             |
|           |      . .          |             |
|           |         .         |   o         |
|           |         X         |             |
|   o       \                o  /             |
|            \                 /              |
|             `.             ,'               |
|               `-._     _.-'                 |
|                   `''''                     |
|                                             |
|                  o                          |
|                                    o        |
|                                             |
|                                             |
|     o                        o              |
+---------------------------------------------+

关于java - 以更好的方式设计此算法？，我们在Stack Overflow上找到一个类似的问题： https://stackoverflow.com/questions/2366814/