java – 设计这个算法一个更好的方法？

我做了这个例子,以获得更好的方法来实现这一点.

>我有一辆车以X方向移动(24.5872公里)
>我通过使用执行器每100ms递增X值来模拟这个(为了保持其X位置更准确和实时)
>每秒之后,我发送一个消息到另一个进程与我刚刚覆盖的行的xMin和xMax值
>另一个进程将响应一个JMS消息(通常是立即)告诉我停止,如果在前一个X区域(消息回调msg到一个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++;
            }

        }),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

    }

}