diff --git a/src/main/java/com/aerospike/mapper/tools/AeroMapper.java b/src/main/java/com/aerospike/mapper/tools/AeroMapper.java index 7900761..3d570d2 100644 --- a/src/main/java/com/aerospike/mapper/tools/AeroMapper.java +++ b/src/main/java/com/aerospike/mapper/tools/AeroMapper.java @@ -398,7 +398,9 @@ public List scan(@NotNull Class clazz) { public List scan(ScanPolicy policy, @NotNull Class clazz) { List result = new ArrayList<>(); Processor resultProcessor = record -> { - result.add(record); + synchronized(result) { + result.add(record); + } return true; }; scan(policy, clazz, resultProcessor);