CodeCow/querydsl
1
0
Fork 0
mirror of https://github.com/querydsl/querydsl.git synced 2026-06-27 21:01:15 +08:00
Code Issues Actions Packages Projects Releases Wiki Activity

Extract class for Thread Safety checks

Browse Source
This commit is contained in:
Ruben Dijkstra 2016-07-19 15:03:02 +02:00
parent 64a05e7b1f
commit 0d2a6e4eba
2 changed files with 41 additions and 8 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

14
querydsl-core/src/test/java/com/querydsl/core/CycleClassInitDependencyTest.java
View File

@ -9,6 +9,8 @@ import org.junit.BeforeClass;
import org.junit.Test;
import org.reflections.util.ClasspathHelper;
import com.querydsl.core.testutil.ThreadSafety;
public class CycleClassInitDependencyTest {
private static ClassLoader loader;
@ -27,16 +29,12 @@ public class CycleClassInitDependencyTest {
}
@Test(timeout = 2000)
public void test() throws InterruptedException {
public void test() {
// each thread wants to load one part of the dependency circle
Thread t1 = new Thread(new LoadClassRunnable("com.querydsl.core.types.dsl.NumberExpression"));
Thread t2 = new Thread(new LoadClassRunnable("com.querydsl.core.types.dsl.Expressions"));
t1.start();
t2.start();
t1.join();
ThreadSafety.check(
new LoadClassRunnable("com.querydsl.core.types.dsl.NumberExpression"),
new LoadClassRunnable("com.querydsl.core.types.dsl.Expressions"));
}
private static class LoadClassRunnable implements Runnable {

35
querydsl-core/src/test/java/com/querydsl/core/testutil/ThreadSafety.java Normal file
View File

@ -0,0 +1,35 @@
package com.querydsl.core.testutil;
import java.util.Collection;
import java.util.List;
import java.util.concurrent.*;
import com.google.common.collect.Lists;
import com.google.common.util.concurrent.Futures;
import com.google.common.util.concurrent.MoreExecutors;
public final class ThreadSafety {
private ThreadSafety() { }
public static void check(Runnable... runnables) {
Collection<Callable<Object>> callables = Lists.newArrayListWithCapacity(runnables.length);
ExecutorService executor = MoreExecutors.getExitingScheduledExecutorService(
new ScheduledThreadPoolExecutor(runnables.length));
for (Runnable runnable : runnables) {
callables.add(Executors.callable(runnable));
}
List<Future<Object>> result;
try {
result = executor.invokeAll(callables);
} catch (InterruptedException ex) {
throw new RuntimeException(ex);
}
for (Future<Object> each : result) {
// all need to complete successfully
Futures.getUnchecked(each);
}
}
}