Как использовать ExecutorService?

Question

[SankaSanka]

Пытаюсь передать в 24 потока сет и оттуда на выходе получить map с результатом работы всех этих потоков. Не работает. Что я делаю не так? Подскажите пожалуйста.

В идеале надо как-то сделать чтобы эта программа могла загрузить любой процессор до 100% независимо от кол-ва ядер. (вместо str+str там будут огромные расчеты)

package used;

import java.util.HashSet;
import java.util.Map;
import java.util.Set;
import java.util.concurrent.*;

public class ExecutorServiceExample {
	
	public static Map<String, String> adresWhisW = new ConcurrentHashMap();
	CountDownLatch []cdl = new CountDownLatch[24];
	
	public static void main(String args[]) {
		Set<String> ss=new HashSet();
		
		ss.add("вася");
		ss.add("петя");
	 new ExecutorServiceExample(ss);
		
		for (Map.Entry<String, String> entry : adresWhisW.entrySet()) {
			System.out.println(entry.getKey() + " " + entry.getValue());
		}
		
	}


	ExecutorServiceExample(Set<String> ss) {

		for (int tr = 1; tr < 24; tr++) {
			cdl[tr] = new CountDownLatch(24);
		}

		ExecutorService executor;
		executor = Executors.newFixedThreadPool(24);

		for (int tr = 1; tr < 24; tr++) {
			executor.execute(new MyThread(ss));
		}


			for (int tr = 1; tr < 24; tr++) {
				try {
					cdl[tr].await();
				} catch (InterruptedException e) {
					e.printStackTrace();
				}
			}

	
		executor.shutdown();

	}

	public class MyThread implements Runnable {
		private Set<String> strSet;
		private Map<String, String> outputMap;

		public MyThread(Set<String> strSet) {
			this.strSet = strSet;
			this.outputMap = outputMap;
		}

		@Override
		public void run() {
			for (String str : strSet) {
				str=str+str;
				outputMap.put(str, str);
			}
		
		}
	}

}

Exception in thread "pool-1-thread-2" Exception in thread "pool-1-thread-7" java.lang.NullPointerException
at used.ExecutorServiceExample$MyThread.run(ExecutorServiceExample.java:72)
at java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1149)
at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:624)
at java.lang.Thread.run(Thread.java:748)
java.lang.NullPointerException
at used.ExecutorServiceExample$MyThread.run(ExecutorServiceExample.java:72)
at java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1149)
at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:624)
at java.lang.Thread.run(Thread.java:748)
Exception in thread "pool-1-thread-5" Exception in thread "pool-1-thread-3" java.lang.NullPointerException
at used.ExecutorServiceExample$MyThread.run(ExecutorServiceExample.java:72)
at java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1149)
at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:624)
at java.lang.Thread.run(Thread.java:748)
java.lang.NullPointerException

Comments

[Sand]

А где у Вас outputMap создается?

[SankaSanka]

Sand, по моей задумке он а создается в потоке. потом когда потоки возвращают все наработанное получается Map adresWhisW
добавила ее в конструктор:

package used;

import java.util.HashSet;
import java.util.Map;
import java.util.Set;
import java.util.concurrent.*;

public class ExecutorServiceExample {
	
	public static Map<String, String> adresWhisW = new ConcurrentHashMap();
	CountDownLatch []cdl = new CountDownLatch[24];
	
	public static void main(String args[]) {
		Set<String> ss=new HashSet();
		
		ss.add("вася");
		ss.add("петя");
	 new ExecutorServiceExample(ss);
	 System.out.println(1);
	 
		for (Map.Entry<String, String> entry : adresWhisW.entrySet()) {
			 System.out.println(2);
			System.out.println(entry.getKey() + " " + entry.getValue());
		}
		
	}


	ExecutorServiceExample(Set<String> ss) {

		for (int tr = 1; tr < 24; tr++) {
			cdl[tr] = new CountDownLatch(24);
		}

		ExecutorService executor;
		executor = Executors.newFixedThreadPool(24);

		for (int tr = 1; tr < 24; tr++) {
			executor.execute(new MyThread(ss,adresWhisW));
		}


			for (int tr = 1; tr < 24; tr++) {
				try {
					cdl[tr].await();
				} catch (InterruptedException e) {
					e.printStackTrace();
				}
			}

	
		executor.shutdown();

	}

	public class MyThread implements Runnable {
		private Set<String> strSet;
		private Map<String, String> outputMap;

		public MyThread(Set<String> strSet, Map<String, String> outputMap) {
			this.strSet = strSet;
			this.outputMap = outputMap;
		}

		@Override
		public void run() {
			for (String str : strSet) {
				
				str=str+str;
				outputMap.put(str, str);
			}
		
		}
	}

}

но так тоже не работает

[Sand]

SankaSanka, ошибка та же? Или вопрос уже не в ошибке?

[SankaSanka]

Sand, сейчас оно просто висит и ничего не показывает. Вопрос в том как сделать мое творение работоспособным)) Я впервые с этим экзекьютором связалась и подозреваю дело в каких-то принципиальных его основах(

[Сергей Горностаев]

[SankaSanka]

Сергей Горностаев, обидеть художника может каждый. Подскажите лучше как сделать))

[Sand]

SankaSanka,
Вы пишите программу которая будет: ...
На входе программа получает следующее: ...
На выходе должно быть вот что: ...
Для реализации идеи Вы решили использовать следующий набор инструментов (библиотек): ...
Так как именно они ...
Логика работы следующая: ...
В ходе написания программы Вы наткнулись на следующую непонятную штуку: ...
Вот код и ошибка: ...

[SankaSanka]

Sand,
на вход мне подается сет Set (String) на выходе из него путем длительных и сложных преобразований получится мапа (String String) которую надо вернуть чтоб работать с ней дальше.
Это все прекрасно работало на 2х ядрах и обычном Thread implements Runnable . Теперь ядер стало много, а скорость не изменилась. Пытаюсь переделать. Посоветовали использовать ExecutorServise
я с ним никогда не работала. Сваяла вот такое убожество. Оно не работает. Я не понимаю почему. Помогите пожалуйста. ExecutorServise не принципиально использовать, но надо чтоб работало Java8

[Sand]

SankaSanka,
Вы пишите программу которая будет: ...
На входе программа получает следующее: Set
На выходе должно быть вот что: Map
Для реализации идеи Вы решили использовать следующий набор инструментов (библиотек): ExecutorService, Thread
Так как именно они ...
Логика работы следующая: ...
В ходе написания программы Вы наткнулись на следующую непонятную штуку: на 2х ядрах работало, на большем количестве не работает
Вот код и ошибка: ...