I am getting a concurrent modification exception when executing the following code:
mymap is a global variable and is a HashMap
Callable<String> task = new Callable<String>() {
@Override
public String call() {
mymap.put("myid", "id2");
mymap.put("myname", "joe");
String id = mymap.get("myid");
System.out.println("id is: "+ id+ ", mymap BEFORE: "+mymap.toString());
mymap.remove("myid");
System.out.println("id is: "+ id+ ", mymap AFTER: "+mymap.toString());
return id;
}
};
List<Callable<String>> tasks = Collections.nCopies(7, task);
ExecutorService executorService = Executors.newFixedThreadPool(7);
List<Future<String>> futures = executorService.invokeAll(tasks);
List<String> resultList = new ArrayList<String>(futures.size());
for (Future<String> future: futures){
resultList.add(future.get());
}
The exception is thrown by the lines:
resultList.add(future.get());
and
System.out.println("id is: "+ id+ ", mymap AFTER: "+mymap.toString());
However if I try
System.out.println("srcNode AFTER: "+srcNode.toString()+ ", id: "+id);
instead the error seems to disappear. Any clues on whats going on?