编年史队列意外延迟

Question

public class Client {
    public static void main(String[] args) {
    String path = "/dev/shm/queue";
    SingleChronicleQueue queue = SingleChronicleQueueBuilder.binary(path).build();
    ExcerptAppender appender = queue.acquireAppender();
    Scanner read = new Scanner(System.in);
    for (int i = 0;i<1;i++){

        for (int j=0;j<1000000;j++) {
            long time = System.nanoTime();
            appender.writeText(Long.toString(time));
        }
    }
    appender.writeText("end");
    }
}

public class Server {
    public static void main(String[] args) {
    String path = "/dev/shm/queue";
    SingleChronicleQueue queue = SingleChronicleQueueBuilder.binary(path).build();
    ExcerptTailer tailer = queue.createTailer();

    DescriptiveStatistics results = new DescriptiveStatistics();
    while (true) {
        String text = tailer.readText();
        if (text == null) {
            Jvm.pause(10);
        } else if (text.equals("end")) {
            System.out.println("Results: " + results.getMean() / 1000);
            break;
        }
        else {
            long cur = System.nanoTime();
            long recv = Long.parseLong(text);
            long diff = cur - recv;
            results.addValue(diff);
        }
    }
    }
}

Answer 1

延误很可能是真的。如果您尽可能快地编写，编写器可以领先于读取器，显示出运行测试的时间越长，延迟就越长。大多数消息传递系统都有流控制，这会减慢生产者的速度，但这种效果会改变测试，使其看起来更好。顺便说一句，您没有预热代码，尽管这不应该导致如此大的延迟。

我建议你试试

• 向写入器添加忙循环，以将其限制为每微秒一条消息。例如每秒100万。
• 忙等待阅读器或使用thread.yield（）。我建议使用我们的pauser.balanced()
• 尝试忽略预热后要查看的前20K甚至100K结果，并运行测试约10秒或更长时间。
• 尽量不产生任何垃圾。您可以将long作为文本附加到已清除/回收的StringBuilder或字节，也可以将其写入二进制文件。