ExecutorService를 사용하는 동시성

저는 ThreadPool과 ExecutorService를 사용하여 1에서 9까지의 숫자를 세는 간단한 프로그램을 가지고 있습니다. 각 스레드는 1 초 동안 실행을 기다리고 있습니다. 그러나 아래의 프로그램은 각 실행마다 임의의 결과를 제공합니다. 나는이 문제를 해결하는 방법을 잘 모르겠습니다 항상 45ExecutorService를 사용하는 동시성

어떤 도움을주십시오을 생산!

public static void main(String[] args) throws InterruptedException { 
    AtomicLong count = new AtomicLong(0); 
    ExecutorService executor = Executors.newFixedThreadPool(10); 
    List<Integer> list = Arrays.asList(1, 2, 3, 4, 5, 6, 7, 8, 9); 
    for(Integer i : list) { 
     executor.execute(new Runnable() { 
      @Override 
      public void run() { 
       try { 
        Thread.sleep(1000); 
       } catch (InterruptedException e) { 
        e.printStackTrace(); 
       } 
       count.set(count.get() + i); 
      } 
     }); 
    } 

    System.out.println("Waiting..."); 

    executor.shutdown(); 
    executor.awaitTermination(Long.MAX_VALUE, TimeUnit.MINUTES); 
    System.out.println("Total::"+count.get()); 

    System.out.println("Done"); 
}

출처

2017-12-30 Veera

가능한 복제 [경쟁 조건이 무엇입니까?] (https://stackoverflow.com/questions/34510/what-is-a-race-condition) –

은 원자 값을 추가하지만 순차적 는를 얻을 는이 원자 작동하지 않습니다 설정합니다. 의

출처

2017-12-30 17:00:18

AtomicLong에는 원자 적 방식의 특별한 방법이 있습니다. 사용시 원자 보증 만받습니다 (add() 및 get()에 대한 호출은 이 아니며이 아톰 임). AtomicLong에는 원자 값 방식으로 현재 값을 "추가"하는 메소드가 있습니다. 대신 addAndGet

count.set(count.get() + i);

사용

count.addAndGet(i);

방법의

출처

2017-12-30 15:11:52 jtahlborn

ExecutorService를 사용하는 동시성

답변

관련 문제