Alawn/Chronicle-Map
1
0
Fork 0
mirror of https://github.com/OpenHFT/Chronicle-Map.git synced 2021-09-13 01:26:12 +00:00
Code Releases Activity

Use temporary file in Issue24ChronicleSetTest

Browse Source
This commit is contained in:
leventov
2016-01-08 05:42:54 +03:00
parent 9dc5c6c8d7
commit ce61bd1887
1 changed files with 7 additions and 11 deletions
Download Patch File Download Diff File Expand all files Collapse all files
src/test/java/net/openhft/chronicle/set/Issue24ChronicleSetTest.java
+7 -11
View File
@@ -18,7 +18,6 @@ package net.openhft.chronicle.set;
import net.openhft.chronicle.hash.ChronicleHash;
import net.openhft.chronicle.hash.ChronicleHashBuilder;
import org.junit.Ignore;
import org.junit.Test;
import java.io.File;
@@ -34,13 +33,9 @@ import static com.samskivert.util.CollectionUtil.selectRandomSubset;
public class Issue24ChronicleSetTest {
public static <K, H extends ChronicleHash<K, ?, ?, ?>, B extends ChronicleHashBuilder<K, H, B>>
H init(B builder, int entrySize, int averageKeySize, String fileName) {
H init(B builder, int entrySize, int averageKeySize) throws IOException {
String tmp = System.getProperty("java.io.tmpdir");
String pathname = tmp + "/" + fileName;
File file = new File(pathname);
if (file.exists())
file.delete();
File file = File.createTempFile("stringSet", ".dat");
file.deleteOnExit();
try {
H result = builder.entries(entrySize)
@@ -52,13 +47,14 @@ public class Issue24ChronicleSetTest {
}
public synchronized static <A> ChronicleSet<A> initSet(
Class<A> entryClass, int entrySize, int averageKeySize, String fileName) {
return init(ChronicleSetBuilder.of(entryClass), entrySize, averageKeySize, fileName);
Class<A> entryClass, int entrySize, int averageKeySize)
throws IOException {
return init(ChronicleSetBuilder.of(entryClass), entrySize, averageKeySize);
}
@Test
public void issue24ChronicleSetTest() {
ChronicleSet<String> set = initSet(String.class, 1_000_000, 30, "stringSet.dat");
public void issue24ChronicleSetTest() throws IOException {
ChronicleSet<String> set = initSet(String.class, 1_000_000, 30);
ExecutorService executor = Executors.newFixedThreadPool(5);
for (int i = 0; i < 10; i++) {
Runnable worker = new WorkerThread(set);