안녕하세요. 자바 스레드 질문이 있습니다.

Question

안녕하세요 혼자 공부하는 학생입니다. 이해가 되지 않아 이렇게 여쭙습니다.아래 코드는 java SE 8 for the really impatient에 나오는 병행성 첫번째 코드입니다. 이 소스를 전부 붙여야 할 것 같아서 이리 붙였습니다. 바로 복사를 하셔서 실행해보실 수 있습니다.아래 문제는 주석에도 써있다시피 race condition이 일어나서 999999가 나와야 하는데 종종 안나온다.라는 말인 것 같습니다. 그런데 저는 계속 실행을 하고 실행이 끝나기 전에도 실행하는 등 연속적인 실행을하여도 해당 값에서 틀린 값이 나온 적이없습니다. 그리고 집행자라는 threadpool을 사용하면 이게 lock을 건 것과 비슷한 행위를 하는 것으로 생각되는데...어째서 999999가 아닌 값이 나온다는 것인지 이해가 되지 않습니다. import java.util.concurrent.*;import java.util.concurrent.atomic.*; public class AtomicUpdates { public static int ntasks = 1000; public static int iterations = 1000; public static AtomicLong nextNumber = new AtomicLong(ntasks * iterations / 2); public static AtomicLong largest = new AtomicLong(); public static void main(String[] args) throws InterruptedException { ExecutorService pool = Executors.newCachedThreadPool(); for (int t = 0; t < ntasks; t++) pool.submit(() -> { long start = nextNumber.incrementAndGet(); for (int i = 0; i < iterations; i++) { long observed = (start + ntasks * i) % (ntasks * iterations); // Error - race condition! largest.set(Math.max(largest.get(), observed)); } }); pool.shutdown(); pool.awaitTermination(10, TimeUnit.SECONDS); System.out.println(largest); // Should be 999999, but ever so often, it isn't }} 그리고 문제는 그 다음입니다. 저 윗코드의 문제가 스레드들이 각자 일을 하는 것이 아니라 서로 상호작용을 하는 스레드라서 문제가 있을 수 있다는 것 같은데 (원서내용: Suppose you want to keep track of the largest value that is observed by different threads.) 그 해결책으로 위의 코드 중 pool의 내용을pool.submit(() -> { long start = nextNumber.incrementAndGet(); for (int i = 0; i < iterations; i++) { long observed = (start + ntasks * i) % (ntasks * iterations); long oldValue, newValue; do { oldValue = largest.get(); newValue = Math.max(oldValue, observed);//?왜 이렇게 해야 하는거지? } while (!largest.compareAndSet(oldValue, newValue)); } });이렇게 바꾸었습니다. do while문을 사용하였는데요. 이것이 무엇때문에 해결책이 되는지 알고 싶습니다.

jslovers · Answer

발생 조건이 맞는건진 확신 할 수 없지만long observed &#61; (start &#43; ntasks * i) % (ntasks * iterations);위의 코드 라인에 브레이크 포인트를 걸고 for문을 천천히 순환시키다 보면 999999값을 가지지 않은 쓰레드가 간섭해서 결과값이 999999가 아닌경우가 발생하는 것을 확인할 수 있습니다.결국 race condition이 발생하는 코드는 원자성이 보장되지 않는 코드여서 보장되는 코드로 바꿔준겁니다.

안녕하세요. 자바 스레드 질문이 있습니다.

1개의 답변

#executor 목록