Frühjahr async funktioniert nicht, wenn implementiert AsyncConfigurer

EDIT: ich eingereicht haben ein bug-report (SPR-14630).

Ich war am Rande der du einen bug-report zu Spring issue-tracker, aber wenn ich beschäftigt war, eine kleine app für die Reproduktion der Fehler, die ich gefunden und das problem behoben.

Zunächst alle, bei Verwendung ThreadPoolTaskExecutor, sollten Sie rufen Ihre initialize() Methode, bevor er es wieder:

@Override
public Executor getAsyncExecutor() {
    ThreadPoolTaskExecutor executor = new ThreadPoolTaskExecutor();
    executor.setMaxPoolSize(1);
    executor.setCorePoolSize(1);
    executor.setThreadNamePrefix("CUSTOM-");

    //Initialize the executor
    executor.initialize();

    return executor;
}

Auch aus irgendeinem Grund, wenn ich eine Bohne in ein @PostConstruct - Methode definiert, in der gleichen Konfiguration Klasse, es wird nicht laufen asynchron. Der Grund dafür ist, dass die @PostConstruct Methode wird ausgeführt, bevor getAsyncExecutor() und getAsyncUncaughtExceptionHandler() ausgeführt werden:

AsyncBean.java:

@Component
public class AsyncBean implements IAsyncBean {

    @Override
    @Async
    public void whoAmI() {
        final String message =
                String.format("My name is %s and I am running in %s", getClass().getSimpleName(), Thread.currentThread());

        System.out.println(message);
    }
}

AsyncDemoApp.java:

@SpringBootApplication
@EnableAsync
public class AsyncDemoApp implements AsyncConfigurer {

    @Autowired
    private IAsyncBean asyncBean;

    public static void main(String[] args) {
        SpringApplication.run(AsyncDemoApp.class, args);
    }

    @Override
    public Executor getAsyncExecutor() {
        System.out.println("AsyncDemoApp.getAsyncExecutor");

        ThreadPoolTaskExecutor executor = new ThreadPoolTaskExecutor();
        executor.setThreadNamePrefix("CUSTOM-");
        executor.initialize();

        return executor;
    }

    @Override
    public AsyncUncaughtExceptionHandler getAsyncUncaughtExceptionHandler() {
        System.out.println("AsyncDemoApp.getAsyncUncaughtExceptionHandler");
        return (throwable, method, objects)
                -> throwable.printStackTrace();
    }

    @PostConstruct
    public void start() {
        System.out.println("AsyncDemoApp.start");
        asyncBean.whoAmI();
    }
}

Ausgabe:

AsyncDemoApp.start
My name is AsyncBean and I am running in Thread[main,5,main]
AsyncDemoApp.getAsyncExecutor
AsyncDemoApp.getAsyncUncaughtExceptionHandler

Jedoch, wenn Sie Ihre Bohnen nach der Anwendungskontext ist gebrauchsfertig, es sollte alles wie erwartet funktionieren:

@SpringBootApplication
@EnableAsync
public class AsyncDemoApp implements AsyncConfigurer {

    public static void main(String[] args) {
        final ConfigurableApplicationContext context = SpringApplication.run(AsyncDemoApp.class, args);

        final IAsyncBean asyncBean = context.getBean(IAsyncBean.class);

        asyncBean.whoAmI();
    }

    @Override
    public Executor getAsyncExecutor() {
        System.out.println("AsyncDemoApp.getAsyncExecutor");

        ThreadPoolTaskExecutor executor = new ThreadPoolTaskExecutor();
        executor.setThreadNamePrefix("CUSTOM-");
        executor.initialize();

        return executor;
    }

    @Override
    public AsyncUncaughtExceptionHandler getAsyncUncaughtExceptionHandler() {
        System.out.println("AsyncDemoApp.getAsyncUncaughtExceptionHandler");
        return (throwable, method, objects)
                -> throwable.printStackTrace();
    }
}

Weiteres komisches Verhalten ist, dass, wenn Sie autowire die asynchrone bean in der gleichen configuration-Klasse, das auto-Bordnetz ist passiert, bevor die benutzerdefinierten async Testamentsvollstrecker ist so konfiguriert, dass die Bohne nicht asynchron laufen soll und es läuft im Haupt-thread. Dies kann überprüft werden, indem ein @PostConstruct zu AsyncBean und mit einem CommandLineRunner zum ausführen der app (ich persönlich denke, das ist ein bug. Das Verhalten ist sehr verwunderlich, um das Mindeste zu sagen):

AsyncBean mit @PostConstruct:

@Component
public class AsyncBean implements IAsyncBean {

    @Override
    @Async
    public void whoAmI() {
        final String message =
                String.format("My name is %s and I am running in %s", getClass().getSimpleName(), Thread.currentThread());

        System.out.println(message);
    }

    @PostConstruct
    public void postConstruct() {
        System.out.println("AsyncBean is constructed");
    }
}

AsyncDemoApp Umsetzung CommandLineRunner:

@SpringBootApplication
@EnableAsync
public class AsyncDemoApp implements AsyncConfigurer, CommandLineRunner {

    @Autowired
    private IAsyncBean asyncBean;

    public static void main(String[] args) {
        SpringApplication.run(AsyncDemoApp.class, args);
    }

    @Override
    public Executor getAsyncExecutor() {
        System.out.println("AsyncDemoApp.getAsyncExecutor");

        ThreadPoolTaskExecutor executor = new ThreadPoolTaskExecutor();
        executor.setThreadNamePrefix("CUSTOM-");
        executor.initialize();

        return executor;
    }

    @Override
    public AsyncUncaughtExceptionHandler getAsyncUncaughtExceptionHandler() {
        System.out.println("AsyncDemoApp.getAsyncUncaughtExceptionHandler");
        return (throwable, method, objects)
                -> throwable.printStackTrace();
    }

    @Override
    public void run(String... args) throws Exception {
        System.out.println("AsyncDemoApp.run");
        asyncBean.whoAmI();
    }
}

Ausgabe:

AsyncBean is constructed
AsyncDemoApp.getAsyncExecutor
AsyncDemoApp.getAsyncUncaughtExceptionHandler
AsyncDemoApp.run
My name is AsyncBean and I am running in Thread[main,5,main]

Noch eins! 🙂 Wenn Sie ThreadPoolTaskExecutor je nach Ihren Anforderungen möchten Sie vielleicht, um Ihre daemon-Eigenschaft auf true, andernfalls wird Ihre app am laufen halten ewig (das ist nicht ein großes problem für Web/Worker-apps). Hier ist, was die JavaDoc von setDaemon(boolean) sagt:

Festlegen, ob dieses Werk soll zum erstellen von daemon-threads, nur
ausführen, solange die Anwendung ausgeführt wird. Standard ist
"false": Betonwerke in der Regel unterstützen die explizite Aufhebung.
Daher, wenn die Anwendung heruntergefahren, Runnables wird standardmäßig finish
Ihre Hinrichtung. Geben Sie "true" für die eifrigen Herunterfahren von threads, die
immer noch aktiv ausführen einer Lauffähigen an der Zeit, dass die Anwendung
selbst heruntergefahren.