방법 (CompletableFuture를 사용하여 만든) 각 asynchronus 호출 여기

Question

에 대한 클래스의 새로운 인스턴스를 생성하는 것은 내 코드입니다 :

class A{ 
    @Autowired 
    B objB; 

    public method1(){ 
     List<String> ids = new ArrayList<String>(); 
     ids.add("1"); 
     ids.add("2"); 
     ids.add("3"); 
     List<CompletableFuture<String>> listOfFuture ids.stream() 
         .map(id -> CompletableFuture.supplyAsync(() -> 
            objB.method2(id)).collect(toList()); 
    } 
} 

    class B{ 
    @Inject 
    D objD; 
    @Inject 
    E objE 

    public String method2(String id){ 
     String transformedId = objD.method3(id); 
     return objE.method4(transformedId); 
    } 
} 

클래스 B는 방법 2를 가지고하는 것은 스레드로부터 안전하지 않은 개체가 있습니다. method2를 실행하는 동안 각 스레드가 고유 한 객체를 갖도록 B의 새 인스턴스를 만들고 싶습니다. 나는 method2에 대한 스프링의 비동기 유틸리티를 사용할 수 있으며 클래스 A에서 CompletableFuture 대신 A에서 비동기 적으로이 메서드를 호출 할 수 있습니다. 그러면 method2 스레드를 안전하게 만들 수 있습니다. CompletableFuture를 사용하면 method2 스레드를 안전하게 만들 수 있습니까? 클래스 B는 스레드로부터 안전하지 않으므로 thread2를 호출하기 위해 스레드를 생성 할 때마다 클래스 B에 대해 다른 객체가 필요하다는 가정이 맞습니까? 여기

Answer 1

나는 당신이 그것을 할 것을 권 해드립니다 방법은 다음과 같습니다 더 공유 가변 데이터가 없기 때문에

class A{ 


    public method1(B objB){ 
     List<String> ids = new ArrayList<String>(); 
     ids.add("1"); 
     ids.add("2"); 
     ids.add("3"); 
     List<CompletableFuture<String>> listOfFuture ids.stream() 
         .map(id -> CompletableFuture.supplyAsync(() -> 
            objB.method2(id)).collect(toList()); 
    } 
} 

이 안전 스레드입니다. 각 메소드에 전달 된 매개 변수는 독립적입니다.

Answer 2

빈의 범위를 프로토 타입으로 설정하는 또 다른 방법입니다. 가장 좋은 방법은 아니지만 이렇게 할 수도 있습니다.

@Component 
class A implements ApplicationContextAware { 
     ApplicationContext applicationContext; 
     public void method1() { 
      List<String> ids = new ArrayList<String>(); 
      ids.add("1"); 
      ids.add("2"); 
      ids.add("3"); 
      List<CompletableFuture<String>> listOfFuture = ids.stream() 
        .map(id -> CompletableFuture.supplyAsync(() -> applicationContext.getBean(B.class).method2(id))) 
        .collect(Collectors.toList()); 
     } 

     @Override 
     public void setApplicationContext(ApplicationContext applicationContext) throws BeansException { 
      this.applicationContext = applicationContext; 

     } 
    } 

    @Component("beanB") 
    @Scope(ConfigurableBeanFactory.SCOPE_PROTOTYPE) 
    class B { 
     public String method2(String id) { 
      // Your code 
     } 
    }