server.clj中的parse-props抛出ConcurrentModificationException

Question

看起来Java系统属性的迭代版本不是线程安全的。可以使用以下代码进行验证

import java.io.FileWriter;
import java.util.Map;
import java.util.Properties;
import java.util.Random;

public class JavaPropertiesTest {
  public static void main(String[] args) throws Exception {
    new Thread(() -> {
      while (true) {
        Properties properties = System.getProperties();
        try (FileWriter fileOutputWriter = new FileWriter("/dev/null")){
          for (Map.Entry<Object, Object> entry : properties.entrySet()) {
            fileOutputWriter.append(entry.getKey().toString());
          }
        } catch (Exception e) {
          e.printStackTrace();
        }
      }
    }).start();

    new Thread(() -> {
      Random gen = new Random();
      while (true) {
        System.getProperties().setProperty(Integer.toString(gen.nextInt()), Integer.toString(gen.nextInt()));
      }
    }).start();
  }
}

Clojure 1.8.x的堆栈跟踪，并且对于最新版本仍然如此
原因：java.util.ConcurrentModificationException 在 java.util.Hashtable$Enumerator.next(Hashtable.java:1387) at clojure.lang.RT$4.invoke(RT.java:509) at clojure.lang.LazySeq.sval(LazySeq.java:40) at clojure.lang.LazySeq.seq(LazySeq.java:49) at clojure.lang.ChunkedCons.chunkedNext(ChunkedCons.java:59) at clojure.lang.ChunkedCons.next(ChunkedCons.java:43) at clojure.lang.RT.next(RT.java:688) at clojure.core$next4341.invokeStatic(core.clj:64) at clojure.core.protocols$naive_seq_reduce.invokeStatic(protocols.clj:63) at clojure.core.protocols$interface_or_naive_reduce.invokeStatic(protocols.clj:72) at clojure.core.protocols$fn6755.invokeStatic(protocols.clj:168) at clojure.core.protocols$fn6755.invoke(protocols.clj:124) at clojure.core.protocols$fn6710$G6705__6719.invoke(protocols.clj:19) at clojure.core.protocols$seq_reduce.invokeStatic(protocols.clj:31) at clojure.core.protocols$fn6732.invokeStatic(protocols.clj:75) at clojure.core.protocols$fn6732.invoke(protocols.clj:75) at clojure.core.protocols$fn6684$G66796697.invoke(protocols.clj:13) at clojure.core$reduce.invokeStatic(core.clj:6545) at clojure.core.server$parse_props.invokeStatic(server.clj:143) at clojure.core.server$start_servers.invokeStatic(server.clj:154) at clojure.core.server$start_servers.invoke(server.clj:154) at clojure.lang.Var.invoke(Var.java:379) at clojure.lang.RT.doInit(RT.java:482) at clojure.lang.RT.

Answer 1

您是否在Clojure启动过程中看到了这种情况？

在Clojure启动期间由单线程调用，因此我不确定这实际上会如何发生。是哪个线程在修改props属性？

Comments

是的，这确实发生在我使用的EMR作业中，该作业Clojure作为组件使用。在这个情况下，我不知道其他的线程实际上在做些什么，但看起来这与EMRFS（S3客户端）的设置有关。不幸的是，由于编辑器的限制，我无法粘贴完整的堆栈跟踪。

Answer 2

记录于https://clojure.atlassian.net/browse/CLJ-2686