并行执行具有返回类型和输入参数的方法

Question

我有以下代码。在执行 m1 和 m2 时，我想通过 3 个线程并行执行 m3()。

我怎样才能实现它。我正在使用 Spring Boot 和 java 8。是否可以使用执行器服务执行 m3()。

@Service
class Main {
    @Autowired
    Private Other other;
    ExecutorService executorService = Executors.newFixedThreadPool(3);
   
    void test_method() {
        for (int i = 0; i < 201; i++) {
            executorService.submit(() -> other.m1()); // works fine as expected 
            executorService.submit(() -> other.m2()); // works fine as expected 
            executorService.submit(() -> other.m3(i)); // compilation error  as expected
    }
}

错误是

我在封闭范围内定义的局部变量必须是最终的或 有效地最终

方法如下

@Service
class Other {
    void m1() {
    }
    
    String m2() {
        return "Hello";
    }
 
    int m3(int n) {
        return n;
    }
}

Answer 1

在 Java 中，您不能在匿名内部类中使用非最终变量，例如 lambda 表达式。

• final 变量是一个只被实例化一次的变量。
• 有效最终变量是指其值在初始化后永远不会改变的变量。

一种可能的解决方法是使用IntStream.range 和IntStream.forEach 方法：

IntStream.range(0, 201).forEach(i -> {
    executorService.submit(() -> other.m1());
    executorService.submit(() -> other.m2());
    executorService.submit(() -> other.m3(i));
});

Answer 2

试试这个：

void test_method() {
    for (int i = 0; i < 201; i++) {
        executorService.submit(other::m1);
        executorService.submit(other::m2);
        final int i1 = i;
        executorService.submit(() -> other.m3(i1));        
    }
}