更新千分尺仪表会阻止调用线程吗？

Question

更新千分尺是否会阻止调用线程（例如执行I/O）？

我相信答案是“不，I/O发生在单独的指标收集线程中”，但想知道这种情况的例外情况，边缘情况，…

谢谢Tarik

Answer 1

这取决于调用线程是什么意思。如果您指的是注册仪表的用户线程，答案是否定的，此时您馈送到仪表的方法甚至没有被调用。

如果您指的是将“运送”指标的线程，那将被阻止。这通常是一个单独的线程（因为大多数注册表都是基于推送的），但是在Prometheus（基于拉动）的情况下，仪表将阻塞Prometheusendpoint和为其提供服务的线程。

因此，在千分尺中，您可以使用一个中间“状态”对象，而不是将阻塞方法注册到量规，您可以从单独的线程（阻塞）定期更新该对象，并从量规读取该对象（非阻塞），例如：

AtomicInteger currentValue = registry.gauge("test.gauge", new AtomicInteger(0));

您可以从另一个线程修改prestValue，请参阅文档

您可以对任意对象执行此操作，例如:

State state = registry.gauge("test.gauge", Collections.emptyList(), new State(), State::getValue);

在< code>getValue不阻塞的情况下，只为您提供最新的值，而在另一个线程上，您可以更新封装在< code>State对象中的值。

这里有几行显示您注册到仪表中的方法是阻塞的：

public class GaugeSample {
    public static void main(String[] args) throws InterruptedException {
        PrometheusMeterRegistry registry = new PrometheusMeterRegistry(PrometheusConfig.DEFAULT);
        System.out.println("registering the gauge...");
        Gauge.builder("test.gauge", GaugeSample::getValue)
                .register(registry);

        System.out.println("scraping...");
        System.out.println(registry.scrape());
    }

    private static double getValue() {
        try {
            Thread.sleep(5_000);
        }
        catch (InterruptedException e) {
            e.printStackTrace();
        }

        return 42;
    }
}