Гость
Войти | Профиль | Очистить
Целевая тема:
Создать новую тему:
Автор:
Действия ...
Форумы / Java [игнор отключен] [закрыт для гостей] / Ожидание завершения потока / 12 сообщений из 12, страница 1 из 1
04.09.2012, 18:10:23
    #37943308
denis11111
denis11111
Гость
Скрыть профиль Поместить в игнор-лист Сообщения автора в теме
Ожидание завершения потока
Добрый день люди!
Такая штука:
Есть некий цикл, которий в каждом своем пробеге запускает поток. Пока работает этот поток, то цикл должен ждать его завершения и только потом переходить ко втому пробегу цикла.
Так же этот поток имеет 10с на все свои дела, если не успел, то он останавливается.

Думал что-то такое:
Код: java
1.
2.
3.
4.
5.
6.
7.
8.
9.
10.
 for (int i = 0; i < 10; i++) {
                Thread t = new Thread(new Runnable() {
                    public void run() {
                        // some work...
                    }
                });
                
                t.start();
                t.join(10000);
            }



Но здесь цикл не ждет окончания выполнения потока t, а идет дальше...
...
Рейтинг: 0 / 0
| Ответить | Цитировать | Написать  
04.09.2012, 18:16:02
    #37943316
забыл ник
забыл ник
Участник
Скрыть профиль Поместить в игнор-лист Сообщения автора в теме
Ожидание завершения потока
Код: java
1.
2.
3.
4.
5.
6.
7.
ExecutorService service = Executors.newFixedThreadPool(1);
		
		for(int i =0; i < 10; i++){
			Future<Result> result = service.submit(new Task());
			println(result.get());
		}
		service.shutdownNow();
...
Рейтинг: 0 / 0
| Ответить | Цитировать | Написать  
04.09.2012, 18:21:08
    #37943323
Blazkowicz
Blazkowicz
Участник
Скрыть профиль Поместить в игнор-лист Сообщения автора в теме
Ожидание завершения потока
denis11111Так же этот поток имеет 10с на все свои дела, если не успел, то он останавливается.

С точки зрения best practices, поток нельзя остановить через 10 секунд. Он сам может проверить, а не пора ли выйти, и потом закончить свои дела.
Если же поток блокируется, то можно попробовать метод interrupt()

denis11111Но здесь цикл не ждет окончания выполнения потока t, а идет дальше...
Ждет 10 секунд, или когда поток закончится, что наступит раньше.

Что ваш поток делает-то?
...
Рейтинг: 0 / 0
| Ответить | Цитировать | Написать  
04.09.2012, 18:21:57
    #37943324
забыл ник
забыл ник
Участник
Скрыть профиль Поместить в игнор-лист Сообщения автора в теме
Ожидание завершения потока
А, забыл про таймаут
Код: java
1.
2.
3.
4.
5.
6.
7.
8.
9.
10.
11.
12.
ExecutorService service = Executors.newFixedThreadPool(1);
		
		for(int i =0; i < 10; i++){
			Future<Result> result = service.submit(new Task());
			try{
				Result item = result.get(10, TimeUnit.SECONDS);
				println(item);
			}catch(TimeoutException te){
				result.cancel(true);
			}
		}
		service.shutdownNow();



И Task должен быть запрограммирован так, чтобы реагировать на interrupt
...
Рейтинг: 0 / 0
| Ответить | Цитировать | Написать  
04.09.2012, 18:22:33
    #37943327
Blazkowicz
Blazkowicz
Участник
Скрыть профиль Поместить в игнор-лист Сообщения автора в теме
Ожидание завершения потока
забыл ник,
Да, почти то что нужно, за исключением того, что активные таски не умрут, до своего завершения.
...
Рейтинг: 0 / 0
| Ответить | Цитировать | Написать  
04.09.2012, 18:27:32
    #37943337
schwa
schwa
Участник
Скрыть профиль Поместить в игнор-лист Сообщения автора в теме
Ожидание завершения потока
ExecutorService.html#invokeAll(java.util.Collection, long, java.util.concurrent.TimeUnit)
...
Рейтинг: 0 / 0
| Ответить | Цитировать | Написать  
04.09.2012, 18:28:39
    #37943340
забыл ник
забыл ник
Участник
Скрыть профиль Поместить в игнор-лист Сообщения автора в теме
Ожидание завершения потока
Blazkowiczзабыл ник,
Да, почти то что нужно, за исключением того, что активные таски не умрут, до своего завершения.
Уже поправился:)
авторExecutorService.html#invokeAll(java.util.Collection, long, java.util.concurrent.TimeUnit)
Немного не то - тут надо выполнять таски последовательно
...
Рейтинг: 0 / 0
| Ответить | Цитировать | Написать  
04.09.2012, 18:31:31
    #37943346
Blazkowicz
Blazkowicz
Участник
Скрыть профиль Поместить в игнор-лист Сообщения автора в теме
Ожидание завершения потока
забыл никНемного не то - тут надо выполнять таски последовательно
Так если пул на 1 поток, то и будут последовательно. Не очень понял из доки как тут таймаут влияет. Возможно он глобальный. Поэтому метод не подходит.
...
Рейтинг: 0 / 0
| Ответить | Цитировать | Написать  
04.09.2012, 18:43:28
    #37943361
забыл ник
забыл ник
Участник
Скрыть профиль Поместить в игнор-лист Сообщения автора в теме
Ожидание завершения потока
Blazkowiczзабыл никНемного не то - тут надо выполнять таски последовательно
Так если пул на 1 поток, то и будут последовательно. Не очень понял из доки как тут таймаут влияет. Возможно он глобальный. Поэтому метод не подходит.

Таймаут глобальный, да и invokeAll не передает мысль что таски должны быть выполнены последовательно, да и таски обычно зависят следующий от предыдущего, иначе зачем их выполнять последовательно? И следовательно на момент запуска invokeAll еще не известны. А так вообще способ конечно оригинальный:)
...
Рейтинг: 0 / 0
| Ответить | Цитировать | Написать  
04.09.2012, 18:46:11
    #37943364
Blazkowicz
Blazkowicz
Участник
Скрыть профиль Поместить в игнор-лист Сообщения автора в теме
Ожидание завершения потока
забыл никinvokeAll не передает мысль что таски должны быть выполнены последовательно

Почему? С пулом в 1 поток порядок должен быть фиксирован.


забыл никда и таски обычно зависят следующий от предыдущего, иначе зачем их выполнять последовательно? И следовательно на момент запуска invokeAll еще не известны. А так вообще способ конечно оригинальный:)
Это правильно подмечено. Интересно, можно ли наполнять коллекцию по мере выполнение тасков. :)
...
Рейтинг: 0 / 0
| Ответить | Цитировать | Написать  
04.09.2012, 19:02:41
    #37943387
забыл ник
забыл ник
Участник
Скрыть профиль Поместить в игнор-лист Сообщения автора в теме
Ожидание завершения потока
Blazkowiczзабыл никinvokeAll не передает мысль что таски должны быть выполнены последовательно

Почему? С пулом в 1 поток порядок должен быть фиксирован.

Ну кто-то может случайно изменить размер пула, и это неочевидно отразится на выполнении программы, имхо такого нельзя допускать. А когда намерение явно выражено в коде, 5 раз подумаешь прежде, чем менять. Ну это мое мнение.
Blazkowiczзабыл никда и таски обычно зависят следующий от предыдущего, иначе зачем их выполнять последовательно? И следовательно на момент запуска invokeAll еще не известны. А так вообще способ конечно оригинальный:)
Это правильно подмечено. Интересно, можно ли наполнять коллекцию по мере выполнение тасков. :)

Нельзя, жавадок прямо об этом говорит

The results of this method are undefined if the given collection is modified while this operation is in progress.
...
Рейтинг: 0 / 0
| Ответить | Цитировать | Написать  
04.09.2012, 19:16:27
    #37943404
Blazkowicz
Blazkowicz
Участник
Скрыть профиль Поместить в игнор-лист Сообщения автора в теме
Ожидание завершения потока
забыл никНу кто-то может случайно изменить размер пула, и это неочевидно отразится на выполнении программы, имхо такого нельзя допускать. А когда намерение явно выражено в коде, 5 раз подумаешь прежде, чем менять. Ну это мое мнение.

Ну, это я тоже всё в порядке бреда. Твой вариант, более читаемый, конечно.
...
Рейтинг: 0 / 0
| Ответить | Цитировать | Написать  
Форумы / Java [игнор отключен] [закрыт для гостей] / Ожидание завершения потока / 12 сообщений из 12, страница 1 из 1
Найденые пользователи ...
Разблокировать пользователей ...
Читали тему (0):
Читали форум (0):
Пользователи онлайн (0):
Польз. соглашение  
Полит. конфиден.  
созд. / загр.: 484ms
Закрыть
start [/forum/topic.php?fid=59&tablet=1&tid=2131017]:
 0ms
get settings:
 13ms
get forum list:
 16ms
check forum access:
 4ms
check topic access:
 4ms
track hit:
 52ms
get topic data:
 12ms
get forum data:
 3ms
get page messages:
 44ms
get tp. blocked users:
 1ms
others: 335ms
total:  484ms
x
x
Закрыть


Просмотр
0 / 0
Close
Debug Console [Select Text]