java - Phaser 实例和 Spring MVC

Question

我有一个带有请求映射的 spring @Controller。 当请求发送给它时，它会创建一个延迟结果并在委托(delegate)者类上运行一个方法。

在 Controller 中:

@ResponseBody
@RequestMapping(MenuModelCodes.MENU_NAME)
DeferredResult<HttpEntity<?>> getModelCodesWithClass(String target) {
    final DeferredResult<HttpEntity<?>> deferredResult = getNewDeferredResult();
    delegator.doStuff(target);
    return deferredResult;
}

委托(delegate)者中的 doStuff 方法带有 @Async 注释 - 因此它在另一个线程中运行。 在此线程中创建一个新的 Phaser 来跟踪它将创建的子线程。 委托(delegate)者线程本身向移相器注册，并触发对“AnotherClass”中也带有 @Async 注释的方法的调用。 IE。委托(delegate)人现在正在生成子代。

委托(delegate)人:

public class Delegator {

    @Async
    public Object doStuff(String requestURI)  {

        Phaser phaser = new Phaser();
        phaser.register();
        Object result = anotherClass.createThreadDoWork(phaser);
        phaser.arriveAndDeregister();

        //Wait until phaser is completed
        while (!phaser.isTerminated()) {}

        return result;
    }
}

通过调用委托(delegate)者中的 createThreadDoWork 创建的每个子生成线程都会在移相器中注册自身，执行一些工作，然后到达并取消注册。

另一个类:

public class AnotherClass {
    @Async
    public void createThreadDoWork(Phaser phaser) throws Throwable {        
        phaser.register();
        //some kind of logic / rest call etc.
        phaser.arriveAndDeregister();
    }
}

当所有子线程完成时，位于这段代码的委托(delegate)者:

while (!phaser.isTerminated()) {}

将继续，设置其延迟结果，委托(delegate)者线程将结束。

所以这是问题:

我希望每个请求都有一个 Phaser - 即每次请求创建一个新的委托(delegate)者线程时我都会创建一个新的 Phaser() 。

如果我收到 5 个对 Controller 的请求，它们每个都会生成一个委托(delegate)者线程，每个委托(delegate)者都会创建一个新的 Phaser 并将其传递给其子级。 但是，一旦其中一个线程完成其处理并且其特定的 Phaser 实例终止，其他委托(delegate)者线程就会继续并返回，而不会完成其任务。

移相器可以这样用吗？难道我做错了什么？我认为这将是跟踪子线程完成并等待它们完成的有用方法？

谢谢。

Answer 1

Can Phasers be used like this?

是的，它可以像这样使用，通常用作同步屏障。

<小时/>

Am I doing something wrong?

是的。不要这样做

while (!phaser.isTerminated()) {}

忙碌的旋转会杀了你。相反，请执行以下操作:

phaser.awaitAdvance();

这会迫使您以稍微不同的方式进行注册。在实际开始运行之前，您必须注册一个线程。

此外，如果您正在推进具有多个阶段的移相器，那么您将必须使用移相器重新评估。

<小时/>

I thought this would be a useful way to track the completion of child threads and wait for them to complete?

如果您确实创建了许多未知线程，那么使用 Phaser 会很有用。