Package tech.muyan.utils

Class AsyncHelper

  • public class AsyncHelper
extends java.lang.Object
    提供异步任务执行的辅助工具类。

    • Constructor Summary

      Constructors 
      Constructor Description
      AsyncHelper()  

    • Method Summary

      All Methods Static Methods Concrete Methods 
      Modifier and Type Method Description
      static java.util.concurrent.ForkJoinPool newForkJoinPool​(int parallelism)  
      static java.lang.Runnable scheduleAtFixRate​(long period, java.lang.Runnable runnable)
      启动定时任务,会包含当前上下文。
      static java.lang.Runnable scheduleAtFixRate​(long period, java.lang.Runnable runnable, boolean newThread)
      启动定时任务,会包含当前上下文。
      static void task​(boolean newThread, java.lang.Runnable runnable)
      异步执行任务,会包含当前上下文,例如租户信息。
      static void task​(java.lang.Runnable runnable)
      使用CompletableFuture默认的线程池启动新线程异步执行任务,会包含当前上下文,例如租户信息。
      static void task​(java.util.concurrent.ExecutorService executorService, java.lang.Runnable runnable)
      使用指定的ExecutorService异步执行任务,会包含当前上下文,例如租户信息。

      • Methods inherited from class java.lang.Object

        clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

    • Constructor Detail

      • AsyncHelper

        public AsyncHelper()

    • Method Detail

      • scheduleAtFixRate

        public static java.lang.Runnable scheduleAtFixRate​(long period,
                                                   java.lang.Runnable runnable)
        启动定时任务,会包含当前上下文。
        Parameters:
        period - 任务执行间隔,单位为毫秒。
        runnable - 要执行的任务,实现了Runnable接口。
        Returns:
        一个Runnable对象,可用于取消定时任务。
        Throws:
        java.lang.IllegalStateException - 如果直接从库中调用该方法,因为该方法的实现将由平台动态提供, 库tech.muyan:api在运行时不应包含在内。

      • scheduleAtFixRate

        public static java.lang.Runnable scheduleAtFixRate​(long period,
                                                   java.lang.Runnable runnable,
                                                   boolean newThread)
        启动定时任务,会包含当前上下文。
        Parameters:
        period - 任务执行间隔,单位为毫秒。
        runnable - 要执行的任务,实现了Runnable接口。
        newThread - 是否启用一个独立的线程执行任务。
        Returns:
        一个Runnable对象,可用于取消定时任务。
        Throws:
        java.lang.IllegalStateException - 如果直接从库中调用该方法,因为该方法的实现将由平台动态提供, 库tech.muyan:api在运行时不应包含在内。

      • task

        public static void task​(java.lang.Runnable runnable)
        使用CompletableFuture默认的线程池启动新线程异步执行任务,会包含当前上下文,例如租户信息。
        Parameters:
        runnable - 要执行的任务,实现了Runnable接口。
        Throws:
        java.lang.IllegalStateException - 如果直接从库中调用该方法,因为该方法的实现将由平台动态提供, 库tech.muyan:api在运行时不应包含在内。

      • task

        public static void task​(boolean newThread,
                        java.lang.Runnable runnable)
        异步执行任务,会包含当前上下文,例如租户信息。
        Parameters:
        newThread - 是否启用一个独立的线程执行任务,如果为false,则会使用CompletableFuture默认的线程池。
        runnable - 要执行的任务,实现了Runnable接口。
        Throws:
        java.lang.IllegalStateException - 如果直接从库中调用该方法,因为该方法的实现将由平台动态提供, 库tech.muyan:api在运行时不应包含在内。

      • task

        public static void task​(java.util.concurrent.ExecutorService executorService,
                        java.lang.Runnable runnable)
        使用指定的ExecutorService异步执行任务,会包含当前上下文,例如租户信息。
        Parameters:
        executorService - 用于执行任务的ExecutorService对象。
        runnable - 要执行的任务,实现了Runnable接口。
        Throws:
        java.lang.IllegalStateException - 如果直接从库中调用该方法,因为该方法的实现将由平台动态提供, 库tech.muyan:api在运行时不应包含在内。

      • newForkJoinPool

        public static java.util.concurrent.ForkJoinPool newForkJoinPool​(int parallelism)