代码之家 › 专栏 › 技术社区 › duy

在Spring 4中运行并行线程的优雅方式

countdownlatch nonblocking multithreading spring java

duy · 技术社区 · 8 年前

我正在开发一个API。此API需要执行2 DB查询才能获得结果。
我尝试了以下策略:

在控制器中使用可调用作为返回类型。

在服务中创建了2个线程(使用Callable和CountDownLatch)以并行运行2个查询并检测完成时间。

public class PetService {
    public Object getData() {
        CountDownLatch latch = new CountDownLatch(2);
        AsyncQueryDBTask<Integer> firstQuery= new AsyncQueryDBTask<>(latch);
        AsyncQueryDBTask<Integer> secondQuery= new AsyncQueryDBTask<>(latch);
        latch.await();
}

public class AsyncQueryDBTask<T> implements Callable {

   private CountDownLatch latch;

   public AsyncQueryDBTask(CountDownLatch latch) { this.latch = latch;}

   @Override
   public T call() throws Exception {
    //Run query
    latch.countDown();
   }

它工作得很好,但我觉得我在某处打破了弹簧的结构。

我想知道在Spring4中获取数据的最有效方法是什么。
-如何知道运行自己查询的两个线程都完成了它们的任务?
-如何控制线程资源,如使用和释放线程?

提前感谢。

1 回复 | 直到 8 年前

Laplie Anderson 8 年前

您通常不想在ApplicationServer中创建自己的线程,也不想管理线程生命周期。在应用程序服务器中,您可以将任务提交给 ExecutorService 以汇集后台工作线程。

方便的是,Spring具有 @Async 为您处理所有这些的注释。在您的示例中,您将创建两个返回Future的异步方法:

public class PetService {
    public Object getData() {
        Future<Integer> futureFirstResult = runFirstQuery();
        Future<Integer> futureSecondResult = runSecondQuery();

        Integer firstResult = futureFirstResult.get();
        Integer secondResult = futureSecondResult.get();
    }

    @Async
    public Future<Integer> runFirstQuery() {
        //do query
        return new AsyncResult<>(result);
    }

    @Async
    public Future<Integer> runSecondQuery() {
        //do query
        return new AsyncResult<>(result);
    }
}

只要您配置 ThreadPoolTaskExecutor 并启用异步方法,Spring将为您处理提交任务。

注: get() 方法阻塞当前线程,直到工作线程返回结果,但不阻塞其他工作线程。通常建议设置一个超时以防止永远阻塞。

推荐文章

Bass · @Volatile lateinit变量可以在Kotlin中使用DCL模式进行原子初始化吗?

4 月前

bepopov · 无法在继承的Thread类中将值设置为Inheritable ThreadLocal字段

5 月前

Starnec · Anticapte FileHooser关闭以中止正在运行的任务

6 月前

user107586 · 如何处理等待句柄不会导致无限循环?

6 月前

ron burgundy · 获取-释放语义是否跨线程传递?[副本]

6 月前

BenjiFB · C#内存缓存:在一次操作中追加到列表?

6 月前

Adam Rutledge · 让父线程在初始化子线程pthread后等待,直到它从子线程接收到一些信号的最佳方法是什么?

6 月前

András Takács · Python多线程问题

10 月前

András Takács · Python多线程错误

10 月前

eden sson · 使用std::thread和native_handle()设置线程关联掩码

10 月前