Решение Александра Бломскёльда не работало для меня для параметризованных тестов @RunWith(Parameterized.class)
при использовании Maven. Тесты были названы правильно, а также там, где они были найдены, но не выполнены:
-------------------------------------------------------
T E S T S
-------------------------------------------------------
Running some.properly.named.test.run.with.maven.SomeTest
Tests run: 0, Failures: 0, Errors: 0, Skipped: 0, Time elapsed: 0.123 sec
Я сделал работу со следующим отрывом, который был вдохновлен комментарием Дэвида Пэрссона на ответ Александра Бломскёльда:
Reflections reflections = new Reflections(new ConfigurationBuilder()
.setScanners(new SubTypesScanner(false /* don't exclude Object.class */), new ResourcesScanner())
.addUrls(ClasspathHelper.forJavaClassPath())
.filterInputsBy(new FilterBuilder()
.include(FilterBuilder.prefix(basePackage))));
Set> subTypesOf = reflections.getSubTypesOf(Object.class);
Насколько я знаю, Java не имеет никакой аналогичной структуры к WaitHandle.WaitAny
метод.
мне кажется, что это могло быть достигнуто через декоратора "WaitableFuture":
public WaitableFuture<T>
extends Future<T>
{
private CountDownLatch countDownLatch;
WaitableFuture(CountDownLatch countDownLatch)
{
super();
this.countDownLatch = countDownLatch;
}
void doTask()
{
super.doTask();
this.countDownLatch.countDown();
}
}
, Хотя это только работало бы, если бы это может быть вставлено перед кодом выполнения, с тех пор иначе, код выполнения не имел бы нового doTask()
метод. Но я действительно не вижу способа сделать это, не опрашивая, если Вы не можете так или иначе получить контроль над будущим объектом перед выполнением.
Или если будущее всегда работает в его собственном потоке, и можно так или иначе получить тот поток. Тогда Вы могли породить новый поток для присоединения друг к другу поток, затем обработать механизм ожидания после возвратов соединения... Это было бы действительно ужасно и вызовет много издержек все же. И если некоторые будущие объекты не заканчиваются, у Вас могло бы быть много заблокированных потоков в зависимости от мертвых потоков. Если Вы не осторожны, это могло бы пропустить ресурсы памяти и системные ресурсы.
/**
* Extremely ugly way of implementing WaitHandle.WaitAny for Thread.Join().
*/
public static joinAny(Collection<Thread> threads, int numberToWaitFor)
{
CountDownLatch countDownLatch = new CountDownLatch(numberToWaitFor);
foreach(Thread thread in threads)
{
(new Thread(new JoinThreadHelper(thread, countDownLatch))).start();
}
countDownLatch.await();
}
class JoinThreadHelper
implements Runnable
{
Thread thread;
CountDownLatch countDownLatch;
JoinThreadHelper(Thread thread, CountDownLatch countDownLatch)
{
this.thread = thread;
this.countDownLatch = countDownLatch;
}
void run()
{
this.thread.join();
this.countDownLatch.countDown();
}
}
простой, проверьте ExecutorCompletionService.
Почему не только создают очередь результатов и ожидают на очереди? Или проще, используйте CompletionService с тех пор вот что это значит: ExecutorService + очередь результата.
Это на самом деле довольно легко с ожиданием () и notifyAll ().
Первый, определите объект блокирования. (Можно использовать любой класс для этого, но мне нравится быть явным):
package com.javadude.sample;
public class Lock {}
Затем, определяют Ваш рабочий поток. Он должен уведомить, что объект блокирования, когда он закончен со своей обработкой. Обратите внимание, что уведомление должно быть в синхронизируемом блоке, соединяющем объект блокирования.
package com.javadude.sample;
public class Worker extends Thread {
private Lock lock_;
private long timeToSleep_;
private String name_;
public Worker(Lock lock, String name, long timeToSleep) {
lock_ = lock;
timeToSleep_ = timeToSleep;
name_ = name;
}
@Override
public void run() {
// do real work -- using a sleep here to simulate work
try {
sleep(timeToSleep_);
} catch (InterruptedException e) {
interrupt();
}
System.out.println(name_ + " is done... notifying");
// notify whoever is waiting, in this case, the client
synchronized (lock_) {
lock_.notify();
}
}
}
Наконец, можно записать клиенту:
package com.javadude.sample;
public class Client {
public static void main(String[] args) {
Lock lock = new Lock();
Worker worker1 = new Worker(lock, "worker1", 15000);
Worker worker2 = new Worker(lock, "worker2", 10000);
Worker worker3 = new Worker(lock, "worker3", 5000);
Worker worker4 = new Worker(lock, "worker4", 20000);
boolean started = false;
int numNotifies = 0;
while (true) {
synchronized (lock) {
try {
if (!started) {
// need to do the start here so we grab the lock, just
// in case one of the threads is fast -- if we had done the
// starts outside the synchronized block, a fast thread could
// get to its notification *before* the client is waiting for it
worker1.start();
worker2.start();
worker3.start();
worker4.start();
started = true;
}
lock.wait();
} catch (InterruptedException e) {
break;
}
numNotifies++;
if (numNotifies == 4) {
break;
}
System.out.println("Notified!");
}
}
System.out.println("Everyone has notified me... I'm done");
}
}
Так как Вы не заботитесь, какой заканчивается, почему не только имеют единственный WaitHandle для всех потоков и ожидают на этом? Какой бы ни каждый приходит первым, может установить дескриптор.
Посмотрите эту опцию:
public class WaitForAnyRedux {
private static final int POOL_SIZE = 10;
public static <T> T waitForAny(Collection<T> collection) throws InterruptedException, ExecutionException {
List<Callable<T>> callables = new ArrayList<Callable<T>>();
for (final T t : collection) {
Callable<T> callable = Executors.callable(new Thread() {
@Override
public void run() {
synchronized (t) {
try {
t.wait();
} catch (InterruptedException e) {
}
}
}
}, t);
callables.add(callable);
}
BlockingQueue<Runnable> queue = new ArrayBlockingQueue<Runnable>(POOL_SIZE);
ExecutorService executorService = new ThreadPoolExecutor(POOL_SIZE, POOL_SIZE, 0, TimeUnit.SECONDS, queue);
return executorService.invokeAny(callables);
}
static public void main(String[] args) throws InterruptedException, ExecutionException {
final List<Integer> integers = new ArrayList<Integer>();
for (int i = 0; i < POOL_SIZE; i++) {
integers.add(i);
}
(new Thread() {
public void run() {
Integer notified = null;
try {
notified = waitForAny(integers);
} catch (InterruptedException e) {
e.printStackTrace();
} catch (ExecutionException e) {
e.printStackTrace();
}
System.out.println("notified=" + notified);
}
}).start();
synchronized (integers) {
integers.wait(3000);
}
Integer randomInt = integers.get((new Random()).nextInt(POOL_SIZE));
System.out.println("Waking up " + randomInt);
synchronized (randomInt) {
randomInt.notify();
}
}
}