Spring 和同步方法，以保证同时执行特定数量的方法

Question

我正在使用 Spring，我想知道会话、类和方法是如何工作的（我拥有一个类的多少个实例以及为什么）。 在我的例子中，我有一个带有 async 方法的 Component 类，该方法调用另一个内部带有 ProcessBuilder 的类：

@Component
@PropertySource(value = { "classpath:application.properties" })
public class ZipAndMat {
.....
......
    @Async
    public void createZipAndMat(User currentUser, String originalFileName){
        conversion(path, name, timeSample, timeout):
    }

    private void conversion(String path, String name, String timeSample, String timeout) throws Exception {        
        ProcessBuilder pb = new ProcessBuilder("java", "-XX:-UseParallelGC", "-Xss512k", "-jar", env.getRequiredProperty(PROPERTY_NAME_CONVERSION_PATH), path, name, timeSample, timeout);        
        pb.inheritIO();        
        Process p = pb.start();        
        int error = p.waitFor();           
        if (error !=0) {            
            if (p.isAlive()) {                
                p.destroyForcibly();           
            }                        
            throw new MCRException("Error with conversion");        
        }    
    }
}

这是我的 TaskExecutor 配置：

@Override
public Executor getAsyncExecutor() {
    ThreadPoolTaskExecutor executor = new ThreadPoolTaskExecutor();
    executor.setCorePoolSize(10);
    executor.setMaxPoolSize(100);
    executor.setQueueCapacity(100);
    executor.initialize();
    return executor;
}

我想控制进程数，否则服务器可能会宕机。我想知道如何使用同步来实现这一点？例如，我应该执行 10 个进程，之后其他请求必须等待至少一个进程结束。也许一个愚蠢的解决方案可能是一个静态变量和一个while(i>10) this.sleep(10000)...的主动等待 谢谢

Answer 1

您可以使用spring @Async 配置池（ThreadPoolTask​​Executor）

https://spring.io/guides/gs/async-method/

保证最大线程数和引入进程数。

Answer 2

我相信Semaphore 正是您所追求的。如果您一次最多需要运行 10 个进程，请尝试以下原始 sn-p：

@Component
@PropertySource(value = { "classpath:application.properties" })
public class ZipAndMat {

    private final Semaphore processes = new Semaphore(10);

    @Async
    public void createZipAndMat(User currentUser, String originalFileName){
        processes.acquire();
        conversion(path, name, timeSample, timeout);
        processes.release();
    }
}

更新：

不过，这种方法可能存在问题。考虑到 Semaphore.acquire() 是阻塞的，如果你正在提交数百个这样的进程并且这些进程需要很长时间才能完成，那么 ThreadPoolTask​​Executor 中的所有线程可能会阻塞等待许可。我认为记住这一点很重要。