Set remove 작업에서의 ConcurrentModificationException

Question

심심해서 만들고 있는 프로그램에서의 코드입니다.public class LoggerThread extends Thread { private PrintWriter logTo; private LinkedBlockingQueue loggerQueue; private Set children = Collections.synchronizedSet(new HashSet()); public Logger getALogger() { Logger l = new Logger() { //some modifications.. @Override public void close() { children.remove(this); } } children.add(l); } public Logger getBLogger() { Logger l = new Logger() { //some modifications.. @Override public void close() { outputStream.close(); children.remove(this); } } children.add(l); } public void closeThread() { logTo.close(); children.parallelStream().forEach(Logger::close); } // @Override public void run() { /* getALogger() 및 getBLogger()를 통해서 생성된 Logger들이 로그를 loggerQueue에 queue하면, 여기서 하나하나 빼와 logTo에 println합니다. */ } }(Logger 클래스는 아파치나 자바에서 제공하는 클래스가 아니라 제가 만든 클래스입니다)closeFactory() 메소드를 호출하니 java.util.ConcurrentModificationException 이 던져집니다. Logger.close() 메소드가 Set을 순회하는 도중에 remove 작업을 하기 때문으로 보입니다.set에서 지우는 작업이 close 메소드에서 이루어져야 하고, close가 set에서 지우는 것뿐만 아니라 다른 리소스 정리와 같은 작업도 병행하기 때문에 Iterator.remove() 나 Set.removeIf()를 쓰기는 어려운 상황입니다.CopyOnWrite 방식의 collection을 쓰는 것도 생각해 봤지만, set을 읽는 작업보다는 넣고 빼는 작업이 더 많은지라 오버헤드가 상당히 많아질 것 같습니다.해결할 수 있는 좋은 방법이 있을까요?

adduci · Answer

Logger 인스턴스가 자신을 해제하는데 외부 리소스(여기선 팩토리)를 건드리는것 자체가 잘못된겁니다Logger 의 close는 인스턴스 내부에서 사용한 리소스를 정리해야하고, 팩토리에서 인스턴스를 remove하는건 팩토리의 close에서 진행해야죠셋에서 remove하는걸 Logger에서 진행해야만 하는 이유가 있나요?

Set remove 작업에서의 ConcurrentModificationException

1개의 답변

#collection 목록