Примерный код


Есть реализованный ThreadPoolExecutor когда произошел submit, метод beforeExecute выдает сообщение Executer`у ( LinkedBlockingDeque = data.take() ) , после выполнения метод afterExecute выдает полученные данные и передает на вторичную обработку, методу parse (т.е. парсить данные)

Так вот вопрос все эти манипуляция надо делать в классе Executer (которые реализованные в методах beforeExecute и afterExecute) ? Или оставить метод beforeExecute как есть, но метод parse перенести в Executer ?

Это сообщение отредактировал(а) Anime - 9.10.2014, 10:10

не очень понятно, что вообще надо.
beforeExecute и afterExecute имеет смысл переопределять в том случае, если это касаеться именно ThreadPoolExecutor. Т.е. если код, который будет в beforeExecute и afterExecute необходим для "правильной" работы самого пула.
а у вас там походу бизнес логика какая-то.

Идея тут такова.
Есть два массива с сообщениями: первый массив сообщений это PriorityBlockingQueue, второй это LinkedBlockingDeque.
Так вот первый массив должен ждать сообщений от второго, т.е. он не выполниться пока во второй массив не придут сообщения.

И так. Класс SuperPool создан на основе PriorityBlockingQueue и имеет приоритет в выполнении сообщений. При поступлении сообщения он выполняется с нормальным приоритетом и в методе beforeExecute выдается ему второе сообщение и счетчик выданного второго сообщения повышается. В методе afterExecute возвращает результат выполнения и если он не выполнился с ошибкой, сабмитится заново но с высоким приоритетом.

Вот псевдо пример запуска

в данном примере он запустит 100 потоков с сообщениями hello, но из них отработают тока 20, так как в data тока 20 сообщений типа world, а все остальные 80 будут ждать прихода сообщений в data.
Подправил малость первый пост...

Правильно ли в методе beforeExecute реализовывать выдачу второстепенного сообщения, а в методе afterExecute  после обработки второстепенного сообщения заново его выбрасывать в массив datas? Или по хорошему это надо делать в самом потоке Executer? Или в каких то отдельных потоках реализовывать?... надеюсь объяснил как-то-)


Это сообщение отредактировал(а) Anime - 9.10.2014, 10:12

А можно описать решаемую задачу? %) Т.е. что вообще надо сделать?
Без всяких там "сообщений" и других слов из программисткого жаргона. Чтобы было понятно даже 7-ми летнему ребенку.
Или это просто надуманная задача и не имеет физического описания?


почему их вообще два? почему нельзя сделать то, что надо сразу? Т.е. почему нельзя иметь только LinkedBlockingDeque? из которого беруться данные и дальше выполняется все, что необходимо.


зачем создавать 100 потоков, если используются из них реально только 20? Это ресурсы, которые таки надо экономить.


Похоже то, что вам надо, должно быть реализовано в самом потоке, но...
С точки зрения философии, так сказать, не правильно в обоих случаях. Задачу реализовывать надо в классах, а не в методах. Каждый класс должен делать одну и только одну работу. И называться соответственно этой работе.
ThreadPoolExecutor - это класс, который занимается тем, что распределяет потоки для предоставленных задач. И это его работа. Другой работы он делать не должен. Наследоваться от этого класса имеет смысл, только если вы хотите делать ту же работу но немного по другому. Ваш код никак не связан с этой работой. Поэтому абсолютно весь код, который у вас написан в методах beforeExecute и afterExecute должен быть где-то в другом месте.


И еще про касты типа:
ComparableFutureTask task = (ComparableFutureTask) runnable;
Если брать java после того, как там появились generics, то можно сказать, что в java кастить нельзя.
А точнее, если вам приходиться кастить, то вы пишите, что-то не так.
Кастить можно только там, где без этого нельзя обойтись. А таких случаев где-то пару штук на милион.
Например, когда приходиться работать через reflection.
Или когда чужой код засавляет это.
Или когда вам прсото лень и вы экономите время.

Это сообщение отредактировал(а) korian - 9.10.2014, 16:36