Skip to content

Commit 57d2332

Browse files
committed
protect FileStore.deadChunks against race codition
1 parent 1fbf735 commit 57d2332

1 file changed

Lines changed: 2 additions & 2 deletions

File tree

h2/src/main/org/h2/mvstore/FileStore.java

Lines changed: 2 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -14,7 +14,6 @@
1414
import java.io.IOException;
1515
import java.nio.ByteBuffer;
1616
import java.nio.channels.FileChannel;
17-
import java.util.ArrayDeque;
1817
import java.util.ArrayList;
1918
import java.util.Arrays;
2019
import java.util.BitSet;
@@ -33,6 +32,7 @@
3332
import java.util.TreeMap;
3433
import java.util.concurrent.ArrayBlockingQueue;
3534
import java.util.concurrent.ConcurrentHashMap;
35+
import java.util.concurrent.ConcurrentLinkedDeque;
3636
import java.util.concurrent.ConcurrentMap;
3737
import java.util.concurrent.ExecutionException;
3838
import java.util.concurrent.Future;
@@ -194,7 +194,7 @@ public abstract class FileStore<C extends Chunk<C>>
194194
*/
195195
private MVMap<String, String> layout;
196196

197-
private final Deque<C> deadChunks = new ArrayDeque<>();
197+
private final Deque<C> deadChunks = new ConcurrentLinkedDeque<>();
198198

199199
/**
200200
* Reference to a background thread, which is expected to be running, if any.

0 commit comments

Comments
 (0)