From 2c970924a1e14ecc347ea392eede381fbbd3e180 Mon Sep 17 00:00:00 2001 From: Andreas Marek Date: Tue, 14 Oct 2025 07:04:16 +1000 Subject: [PATCH] remove unnecessary synchronized --- .../graphql/schema/DataLoaderWithContext.java | 34 ++++++++----------- 1 file changed, 14 insertions(+), 20 deletions(-) diff --git a/src/main/java/graphql/schema/DataLoaderWithContext.java b/src/main/java/graphql/schema/DataLoaderWithContext.java index 329412938..2e779476b 100644 --- a/src/main/java/graphql/schema/DataLoaderWithContext.java +++ b/src/main/java/graphql/schema/DataLoaderWithContext.java @@ -47,18 +47,16 @@ public CompletableFuture> loadMany(List keys, List keyContext assertNotNull(keyContexts); CompletableFuture> result; - synchronized (this) { - List> collect = new ArrayList<>(keys.size()); - for (int i = 0; i < keys.size(); i++) { - K key = keys.get(i); - Object keyContext = null; - if (i < keyContexts.size()) { - keyContext = keyContexts.get(i); - } - collect.add(delegate.load(key, keyContext)); + List> collect = new ArrayList<>(keys.size()); + for (int i = 0; i < keys.size(); i++) { + K key = keys.get(i); + Object keyContext = null; + if (i < keyContexts.size()) { + keyContext = keyContexts.get(i); } - result = Async.allOf(collect); + collect.add(delegate.load(key, keyContext)); } + result = Async.allOf(collect); newDataLoaderInvocation(); return result; } @@ -68,15 +66,13 @@ public CompletableFuture> loadMany(Map keysAndContexts) { assertNotNull(keysAndContexts); CompletableFuture> result; - synchronized (this) { - Map> collect = new HashMap<>(keysAndContexts.size()); - for (Map.Entry entry : keysAndContexts.entrySet()) { - K key = entry.getKey(); - Object keyContext = entry.getValue(); - collect.put(key, delegate.load(key, keyContext)); - } - result = Async.allOf(collect); + Map> collect = new HashMap<>(keysAndContexts.size()); + for (Map.Entry entry : keysAndContexts.entrySet()) { + K key = entry.getKey(); + Object keyContext = entry.getValue(); + collect.put(key, delegate.load(key, keyContext)); } + result = Async.allOf(collect); newDataLoaderInvocation(); return result; } @@ -95,6 +91,4 @@ private void newDataLoaderInvocation() { } - - }