Дали задачу, но чего-то никак не могу понять как ее реализовать.
Есть producer
, например, 25 потоков должно быть.
Есть consumer
, например, 5 потоков должно быть.
producer посылает в очередь сообщение, получает оттуда String
возвращается в producer.
consumer должен вычитывать эту очередь.
Размер сообщений, который будет оправлен, например, 500, после чего, видимо, ExecutorService/ThreadPool
должен умереть для producer
. Для consumer
он должен работать до того момента, пока очередь не будет пуста.
Я всё не могу понять, как сделать так, чтобы 1) все потоки стартовали одновременно 2) как запустить новые потоки в consumer
Вот так у меня примерно в main
public class Main{
private ExecutorService prodService= Executors.newFixedThreadPool(25, prodFactory);
private ExecutorService conService= Executors.newFixedThreadPool(5, conFactory);
public static void main(String[] args) {
ApplicationContext context = new ClassPathXmlApplicationContext("beans.xml");
Starter bean = (Starter) context.getBean("starter");
bean.doit();
}
private void doit() {
for (int i = 0; i < 10; i++) {
prodService.execute(() -> {
for (int i = 0; i < 10; i++) {
System.out.println(Thread.currentThread().getName());
makeSmth();
}
});
conService.execute(() -> {doSmthTo();});
}
}
}
По факту, там у меня еще много чего страшного и не понятного, но я не знаю куда это всё внедрять)
producer посылает в очередь сообщение, получает оттуда String возвращается в producer.
не понятно как и зачем producer'у что то получать