Skip to content

Commit 3702de3

Browse files
authored
Remove copy of ConcurrentLinkedDeque (#956)
* Rely on java.util.concurrent.ConcurrentLinkedDeque instead * Change ConcurrentPool#prune to use an algorithm that doesn't depend on changes to our ConcurrentLinkedDeque copy JAVA-4630
1 parent d5d1450 commit 3702de3

File tree

7 files changed

+27
-1064
lines changed

7 files changed

+27
-1064
lines changed

driver-core/src/main/com/mongodb/connection/TlsChannelStreamFactoryFactory.java

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -22,7 +22,6 @@
2222
import com.mongodb.diagnostics.logging.Logger;
2323
import com.mongodb.diagnostics.logging.Loggers;
2424
import com.mongodb.internal.connection.AsynchronousChannelStream;
25-
import com.mongodb.internal.connection.ConcurrentLinkedDeque;
2625
import com.mongodb.internal.connection.ExtendedAsynchronousByteChannel;
2726
import com.mongodb.internal.connection.PowerOfTwoBufferPool;
2827
import com.mongodb.internal.connection.tlschannel.BufferAllocator;
@@ -44,6 +43,7 @@
4443
import java.nio.channels.SocketChannel;
4544
import java.security.NoSuchAlgorithmException;
4645
import java.util.Iterator;
46+
import java.util.concurrent.ConcurrentLinkedDeque;
4747
import java.util.concurrent.Future;
4848
import java.util.concurrent.TimeUnit;
4949

driver-core/src/main/com/mongodb/internal/connection/BaseCluster.java

Lines changed: 1 addition & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -44,6 +44,7 @@
4444
import java.util.Deque;
4545
import java.util.Iterator;
4646
import java.util.List;
47+
import java.util.concurrent.ConcurrentLinkedDeque;
4748
import java.util.concurrent.CountDownLatch;
4849
import java.util.concurrent.ThreadLocalRandom;
4950
import java.util.concurrent.atomic.AtomicReference;

0 commit comments

Comments
 (0)