Подскажите, пожалуйста, как вызвать в java
из одного потока (поток 0) другой поток (поток 1) асинхронно и потом вернуться в поток 0 не используя библиотеки java.util.concurrent
. (Это вопрос с собеседования, самый сложный).
-
Что вообще подразумевается под словами вызвать поток? Вызвать метод в другом потоке и асинхронно получить результат? -- Тогда можно использовать пару очередей (одну для входных аргументов, а другую для результатов и какую-то (зависит от задачи) комбинацию wait-notify).– avp27 июн 2013 в 20:11
2 ответа
// thread 1
Thread2 t = new Thread2();
t.start();
t.join();
// thread 2
// do something
у вас несоответствие в вопросе, если вызов асинхронный, то возвращаться в поток 0 нет смысла, потому что выполнение там не блокировалось на время вызова потока 1
-
Точно подмечено! А при join, "поток 0" выполняющий этот метод на "потоке 1" будет ждать, пока "поток 1" завершит своё выполнение. 27 июн 2013 в 13:18
-
1
-
2
-
вопрос действительно некорректен - при "вызове" потока мы в него не уходим, так что и возвращаться не придется - мы из потока 0 и не уходили.– rfq2 июл 2013 в 10:21
-
1@Barmaley, умник, по поводу
О как! человек который не отличает join() от асинхронности
держи свой неработающий код и никому больше не говори что он правильный ideone.com/l4U1i1 9 июл 2013 в 22:04
Самый простой способ вернуться в основной поток - это в дочернем потоке выкинуть исключение :)), предварительно повесив в основном потоке хэндлер:
setUncaughtExceptionHandler(Thread.UncaughtExceptionHandler eh)
Update
Рабочий пример кода. Собирайте, запускайте и убедитесь, что все работает асинхронно работают параллельно 2 потока и через секунду дочерний поток выкидывает исключение и управление возвращается к основному потоку.
Убирайте минус, иначе :)
public class Main implements Thread.UncaughtExceptionHandler {
public static void main(String[] args) {
Main main=new Main();
Thread childThread=new ChildThread();
childThread.start();
childThread.setUncaughtExceptionHandler(main);
for(int i=0; i < 100; i ++) {
try {
Thread.sleep(100);
System.out.println("Main thread, loop "+i);
}
catch(InterruptedException e) {
break;
}
}
}
public void uncaughtException(Thread t, Throwable e) {
System.out.println("Caught thread "+t.getClass().getName()+" - we're back in main thread!");
}
}
class ChildThread extends Thread {
@Override
public void run() {
int j=0;
while(true) {
try {
Thread.sleep(100);
System.out.println("Child thread, loop "+j++);
if(j>=10) {
throw new RuntimeException("Test!");
}
}
catch(InterruptedException e) {
break;
}
}
}
}
-
-
-
вобщем-то если обработчик вешать не на главный поток, а на дочерний, то его можно использовать в виде сигнализатора о том что поток завершен. Но это не решает проблему блокировки главного потока на время выполнения дочернего, к тому же использовать исключения для передачи сообщений не самое лучшее что можно сделать, для этого вполне хватит
synchronized
,wait
,notify
илиjoin
. Жду код от вас :) 27 июн 2013 в 19:41 -
-