feat: apply a thread safe lock over dataloaders (#1838) (#1840)

cherry pick #1838

Author: samuelAndalon

executions/graphql-kotlin-dataloader/src/main/kotlin/com/expediagroup/graphql/dataloader/KotlinDataLoaderRegistry.kt

@@ -1,5 +1,5 @@
 /*
- * Copyright 2022 Expedia, Inc
+ * Copyright 2023 Expedia, Inc
  *
  * Licensed under the Apache License, Version 2.0 (the "License");
  * you may not use this file except in compliance with the License.
@@ -61,17 +61,23 @@ class KotlinDataLoaderRegistry(
      * @return list of current completable futures.
      */
     fun getCurrentFutures(): List<CompletableFuture<*>> =
-        registry.dataLoaders.map { it.cacheMap.all }.flatten()
+        synchronized(registry.dataLoaders) {
+            registry.dataLoaders.map { dataLoader ->
+                dataLoader.cacheMap.all
+            }.flatten()
+        }
 
     /**
      * This will invoke [DataLoader.dispatch] on each of the registered [DataLoader]s,
      * it will start to keep track of the [CompletableFuture]s of each [DataLoader] by adding them to
      * [onDispatchFutures]
      */
     override fun dispatchAll() {
-        onDispatchFutures.clear()
-        onDispatchFutures.addAll(getCurrentFutures())
-        registry.dispatchAll()
+        synchronized(onDispatchFutures) {
+            onDispatchFutures.clear()
+            onDispatchFutures.addAll(getCurrentFutures())
+            registry.dispatchAll()
+        }
     }
 
     /**
@@ -82,12 +88,16 @@ class KotlinDataLoaderRegistry(
      * @return weather or not all futures gathered before [dispatchAll] were handled
      */
     fun onDispatchFuturesHandled(): Boolean =
-        onDispatchFutures.all { it.numberOfDependents == 0 }
+        synchronized(onDispatchFutures) {
+            onDispatchFutures.all { it.numberOfDependents == 0 }
+        }
 
     /**
      * Will signal if more dataLoaders where invoked during the [dispatchAll] invocation
      * @return weather or not futures where loaded during [dispatchAll]
      */
     fun dataLoadersInvokedOnDispatch(): Boolean =
-        getCurrentFutures().size > onDispatchFutures.size
+        synchronized(onDispatchFutures) {
+            getCurrentFutures().size > onDispatchFutures.size
+        }
 }