Тогда такой вопрос: как можно по хорошему этот момент обработать? Я хочу чтобы это логировалось в последнюю очередь

Сделать какую-то проверку на наличие запущенных потоков?

у тебя этот экзекьютор останавливаемый и выполнит роль семафора

логируй после

на встрече людей с Дмитрием Медведевым

Это же победа студентов ИТМО, где Елизаров был.

Это же не "люди" с улицы были

Может мне кто-нибудь пояснить как мы можем у Future забрать состояние для всех засабмиченных задач, даже если их там куча?

у фьючи никак, потому что это только одна задача

А как это можно сделать тогда?

перефразируй для начала, я не въехал что нужно в итоге от кучи тасков

Смотри, я сабмичу кучу заданий по обработке строк через ExecutorService. У меня есть второй метод: он принимает список строчек, которые вылетели с ошибкой в предыдущем коде. Что мне нужно - я хочу, чтобы этот второй метод дождался пока выполнятся куча заданий по обработке строк и только тогда начал выполняться.

давай на скалу перепишем, там это быстро делается из коробки ?

Смотри, я сабмичу кучу заданий по обработке строк через ExecutorService. У меня есть второй метод: он принимает список строчек, которые вылетели с ошибкой в предыдущем коде. Что мне нужно - я хочу, чтобы этот второй метод дождался пока выполнятся куча заданий по обработке строк и только тогда начал выполняться.

собирай в лист, потом фолдом синхронно через .get()

можно опять же два варианта, с блокировкой на каком либо ресурсе (семафор поднять) или асинхронно полностью (как это в java уж не знаю)

собирай в лист, потом фолдом синхронно через .get()

Пардон, не понял про "фолдом синхронно". Это как?

а вот да, третий вариант, однопоточно)

можно опять же два варианта, с блокировкой на каком либо ресурсе (семафор поднять) или асинхронно полностью (как это в java уж не знаю)

Я многопоточностью 2 дня разбираюсь, я ещё не понял как это всё работает)

а вот да, третий вариант, однопоточно)

Есть вариант забить

Я многопоточностью 2 дня разбираюсь, я ещё не понял как это всё работает)

о, свежий! отличный курс есть https://www.coursera.org/learn/parprog1

Есть вариант забить

Подтверди, Ник)

Пока у меня есть лист future, в который я кладу таски, которые сабмичу через экзекьютор. А вот чо дальш делать хз. Foreach забирать каждый элемент из листа? А чо с ним дальше делать?

Подтверди, Ник)

Это не вариант. Я не для этого свой парсер писал, чтоб забить почти в конце)

о, свежий! отличный курс есть https://www.coursera.org/learn/parprog1

А курсера теперь вся платная или как?

курсы почти всегда бесплатны, платные специализации и сертификаты

Хм, видать давно я там не был

курсы почти всегда бесплатны, платные специализации и сертификаты

Не так давно искал интересные себе курсы, больше половины были платные даже для доступа к материалу

Но конечно может это просто так для меня выпало

о, свежий! отличный курс есть https://www.coursera.org/learn/parprog1

Он ж старый, да и ещё и для любителей акцента ))

Там ж профессор этот - поляк?

Пока у меня есть лист future, в который я кладу таски, которые сабмичу через экзекьютор. А вот чо дальш делать хз. Foreach забирать каждый элемент из листа? А чо с ним дальше делать?

уродливый вариант - создаешь шарэбл каунтер, при создании фьючи инкримент, на коллбэке по окончанию декримент если 0 то сделать что нить еще

Он ж старый, да и ещё и для любителей акцента ))

я хз что там из нового Прокопец вроде с нормальным говором

Точно, он. Неее, я слушал и плакал)

Хотя лучше он, чем андрюша нж

там 2ой мужик смешной, как будто француз

Может швейцарец? На самом деле курс этот ну слабоват

хардкора нет, но как элементарный ок

Господа, кто может мне прояснить почему блок finally выполняется в самом начале? https://image.prntscr.com/image/_gcXCvPXSSuiYca_a5K8Vg.png

Короче, уже сказали тебе, но на всякий случай повторим что происходит: Ты что-то там инициализируешь, потом запускаешь АСИНХРОННО таски, они начинают выполняться в своём треде, но тред в котором ты их запускаешь продолжает выполняться дальше (на то оно и асинхронное выполнение. К.О.), а дальше у нас блок finally который должен быть выполнен при любом раскладе исполнения метода(по определению блока finally). Что делать, куда бежать? Ну как минимум погуглить про средства синхронизации в java. Тут тебе нужно дождаться выполниния своих асинхронных тасков. Можно сделать вообще через fork-join-pull и не париться. Можно просто для каждой таски вызвать метод get() (тогда ты залочишься до выполнения всех задач) можно этот список опрашивать isFinish() и редьюсить значения по в одно и пока false показывать пользователю кукиш )

В общем вариантов много. Основное - это интерфейс Future

А есть что-то кроме доки и Гугла, что можно про это прочитать?

Пока я начал делать через while (count !=0), там через гет забираю таски и делаю count-1. Когда будет 0 запустится второй метод. Норм?

Ну у тебя же список есть и есть шикарные стримы

get - блокирует текущий тред до завершения таски

Так что если у тебя хотя бы по разу для каждой отработал гет, то значит всё завершилось

Так, а как​ вообще бегает этот гет по списку? Один раз прошёл и всё или постоянно опрашивает?

Гет же должен тогда постоянно обновлять состояние списка

гет блочит фьючи до результата, по факту ты извращенно написал однопоточное решение

Смотри, я сабмичу кучу заданий по обработке строк через ExecutorService. У меня есть второй метод: он принимает список строчек, которые вылетели с ошибкой в предыдущем коде. Что мне нужно - я хочу, чтобы этот второй метод дождался пока выполнятся куча заданий по обработке строк и только тогда начал выполняться.

Шаришь между всеми тасками Countdownlatch, затем забмитишь ещё одну таску, которая ждёт, когда счётчик будет 0, дальше делает своё грязное дело

Проблема будет только, если кто-то не сделает декремент лэтчу

На этот случай можно тайм-аут сделать

Нужно попить водички и почитать про потоки. А то сложно, етить

http://javarevisited.blogspot.co.uk/2012/07/countdownlatch-example-in-java.html?m=1

Вот простой пример

Хм. Проблема в том, что про потоки я знаю только то, что вычитал/наработал за пару дней написания приложения. Пока не хватает знаний как работает конкретно работает семафор и прочие штуки

Но спасибо, буду осваивать

Concurrency in practice в руки. Там там как раз первые главы про примитивы синхронизации

Оке

Посмотри еще ExecutorService::invokeAll

Возможно, это то, что тебе нужно

ERROR: S client not available

И проще чем шареный счетчик

Для того, чтобы его запустить, разве не надо как-то отдельно собирать таски?

Надо

Но если ты можешь их собрать, почему бы и нет

Так если я их запускаю через submit, то invoke никак не использовать, нет?

Просто прочтите книгу, которую вам посоветовали и часть вопросов сразу отпадёт

Просто прочтите книгу, которую вам посоветовали и часть вопросов сразу отпадёт

Уже скачал и начал читать

А что за книга, если не секрет?

А, увидел. Спс)

где искать работу Spring+ORM/JDBC Angular/React разработчику?

Ребят, в связи с закрытием сайта kenai, куда теперь ходить за недостающими либами?

Хотел потюнить jvm, выдало такое : Could not load hsdis-amd64.dylib; library not loadable; PrintAssembly is disabled

Пошел за ней в Kenai, а он закрыт

где искать работу Spring+ORM/JDBC Angular/React разработчику?

можно хотя бы чятик с джававакансиями?

можно хотя бы чятик с джававакансиями?

ну плз!

ну плз!

https://t.me/jvmjobs

https://t.me/jvmjobs

Спасибо

Господа, подскажите ещё. Я вообще никак не понимаю из submit сделать invokeAll. Нашёл пример как должно выглядеть, но всё равно не получается. http://programador.ru/invokeall/

Я не понимаю как 2 метода в сабмите заменить на 1 callable

Короче, уже сказали тебе, но на всякий случай повторим что происходит: Ты что-то там инициализируешь, потом запускаешь АСИНХРОННО таски, они начинают выполняться в своём треде, но тред в котором ты их запускаешь продолжает выполняться дальше (на то оно и асинхронное выполнение. К.О.), а дальше у нас блок finally который должен быть выполнен при любом раскладе исполнения метода(по определению блока finally). Что делать, куда бежать? Ну как минимум погуглить про средства синхронизации в java. Тут тебе нужно дождаться выполниния своих асинхронных тасков. Можно сделать вообще через fork-join-pull и не париться. Можно просто для каждой таски вызвать метод get() (тогда ты залочишься до выполнения всех задач) можно этот список опрашивать isFinish() и редьюсить значения по в одно и пока false показывать пользователю кукиш )

Ремарочка: форк-джойн лучше подходит для обработки данных, а тут обычные потоки.

Я не понимаю как 2 метода в сабмите заменить на 1 callable

https://image.prntscr.com/image/rWK_t0TPS1uMT6sQdmrupg.png

@shnapsx какая задача то?

@shnapsx какая задача то?

Вот есть этот кусок кода в стриме. Нужно поменять его с instance.submit на instance.invokeAll. А чтоб внутри каллабл выпонялись методы download и countplus.

То-бишь, чтобы это выполнилось и только тогда поток убежал дальше

Есть чат линуксоидов?

Есть чат линуксоидов?

если есть – меня закиньте, пожалуйста)

pro.linux

Взамен старой доброй группы pro.linux, с которой и началась вся серия групп pro.*, т.к. создатель её покинул нас Invite: https://t.me/joinchat/Be4rsT7VI1LxrHaMR3pezQ

Взамен старой доброй группы pro.linux, с которой и началась вся серия групп pro.*, т.к. создатель её покинул нас Invite: https://t.me/joinchat/Be4rsT7VI1LxrHaMR3pezQ

В каком смысле покинул?