Как распараллелить работу с мапой?

Question

[SankaSanka]

есть метод который принимает сет, работает с ним, получает два результата и записывает их в мапу.
хочу его разбить процесс получения результатов на два потока.
вот что у меня есть сейчас:

public class IndexedThread implements Runnable {
	private final Set<String> strSet;

	public IndexedThread(Set<String> strSet) {
		this.strSet = strSet;
	}
	@Override
	public void run() {
		for (String s : strSet) {
         //работаем работу
}
    map.put(str, newstr);
    }
}

private Map<String, String> makework(Set<String> wordFromFile) {
        Map<String, String> map = new ConcurrentHashMap<String, String>();
IndexedThread thread = new IndexedThread(str);
               thread.start();

 for (String str : wordFromFile) {
//работаем другую работу
map.put(str, newstr2);
}
return map;
}

как это по человечески доделать подскажите пожалуйста.
2 "работы" в методе между собой никак не связанны.
2 разных действия нужно сделать с каждым элементом сета.

Answer 1

[Dmitry Roo]

В java 8+ многопоточность достигается гораздо более понятным и простым способом:

// Java 11
public class ParallelMapDemo {

    public static void main(String[] args) {
        var inputSet = Set.of(1, 2, 3, 4, 5);

        var result = inputSet.parallelStream()
                .collect(Collectors.toMap(Function.identity(), ParallelMapDemo::doSomething));
    }

    static String doSomething(Integer i) {
        //  Do Something
        return i.toString();
    }

}

Comments

[Dmitry Roo]

SankaSanka Ну лааааадно.

public class ParallelMapDemo2 {

    public static void main(String[] args) throws InterruptedException {
        var inputSet1 = Set.of("a", "b", "c");
        var inputSet2 = Set.of("e", "f", "g");

        var result = new ConcurrentHashMap<String, String>();

        new Thread(new Worker(inputSet1, result)).start(); // Так делать не надо. Это только для примера.
        new Thread(new Worker(inputSet2, result)).start();

        Thread.sleep(1000);

        System.out.println(result);
    }

    static class Worker implements Runnable {

        private Set<String> task;
        private Map<String, String> outputMap;

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

        @Override
        public void run() {
            for (var s: task) {  // так тоже, конечно, никто не пишет
                // Do something
                outputMap.put(s, s.toUpperCase());
            }
        }
    }
}

Теперь вам осталось только решить вопрос как раздать каждому воркеру свой кусочек сета с исходными данными.

[SankaSanka]

Dmitry Roo, спасибо огромное :-)