카테고리 없음
[Effective Java] Item79. 과도한 동기화는 피하라
niniz
2022. 9. 18. 11:45
과도한 동기화는 성능을 떨어뜨리고, 교착상태에 빠뜨리고, 심지어 예측할 수 없는 동작을 낳기도 합니다.
응답 불가와 안전 실패를 피하려면 동기화 메서드나 동기화 블록 안에서는 제어를 절대로 클라이언트에 양도하면 안 됩니다.
외부에서 제어 가능한 메서드를 외계인 메서드(alien methoe)라 합니다.
public class ObservableSet<E> extends ForwardingSet<E> {
public ObservableSet(Set<E> set) {
super(set);
}
private final List<SetObserver<E>> observers
= new ArrayList<>();
public void addObserver(SetObserver<E> observer) {
synchronized(observers) {
observers.add(observer);
}
}
public boolean removeObserver(SetObserver<E> observer) {
synchronized(observers) {
return observers.remove(observer);
}
}
private void notifyElementAdded(E element) {
synchronized (observers) {
for (SetObserver<E> observer : observers) {
observer.added(this, element);
}
}
}
@Override
public boolean add(E element) {
boolean added = super.add(element);
if (added)
notifyElementAdded(element);
return added;
}
@Override
public boolean addAll(Collection<? extends E> c) {
boolean result = false;
for (E element : c)
result |= add(element);
return result;
}
}
@FunctionalInterface
public interface SetObserver<E> {
// ObservableSet에 원소가 추가되면 호출된다.
void added(ObservableSet<E> set, E element);
}
public static void main(String[] args) {
ObservableSet<Integer> set = new ObservableSet<>(new HashSet<>());
set.addObserver(new SetObserver<>() {
public void added(ObservableSet<Integer> s, Integer e) {
System.out.println(e);
if(e == 23) {
s.removeObserver(this);
}
}
});
for(int i = 0; i < 100; i++) {
set.add(i);
}
}
23까지 출력 후 종료할 것으로 예상했지만 ConcurrentModificationException예외가 발생합니다. added
메서드가 호출되는 시점에 notifyElementAdded
메서드가 락을 걸고 순회하고 있었기 때문에 발생하는 문제입니다.
이때는 외계인 메서드를 동기화 블록 바깥으로 옮기거나 CopyOnWriteArrayList
를 사용해 문제를 해결합니다.
반응형