Gemessene Parallelverarbeitung mit Java

Java kann parallel verarbeitet werden, aber ich weiß nicht viel darüber. Deshalb habe ich Parallel Stream und Completable Future ausgeführt, die ich meiner Meinung nach häufig verwende.

Messmethode

Verarbeitung zum individuellen Abrufen von Daten aus der Datenbank in AWS mit findById aus 30 IDs.

Implementierungsumgebung

lokal

MacBook Pro (13-inch, 2018, Four Thunderbolt 3 Ports)
2.3 GHz Intel Core i5
16 GB 2133 MHz LPDDR3
Java1.8
Springboot2

AWS RDS

db.t2.micro
Tokio-Region

Implementierung

Serie

`Serial`


        List<Long> list = createIdList(); //30 Fälle
        List<Currency> currencies = new ArrayList<>();
        list.forEach(id -> currencyService.findById(id)
                .ifPresent(currency -> currencies.add(currency)));

`Ergebnis`


3644ms

ParallelStream

`ParallelStream`


        List<Long> list = createIdList(); //30 Fälle
        List<Currency> currencies = new ArrayList<>();
        list.parallelStream()
                .forEach(id -> currencyService.findById(id)
                                .ifPresent(currency -> currencies.add(currency)));

`Ergebnis`


607ms

CompletableFuture

`CompletableFuture`


        List<Long> list = createIdList(); //30 Fälle
        List<Currency> currencies = new ArrayList<>();
        ExecutorService ex = Executors.newWorkStealingPool();
        List<CompletableFuture<Void>> futures = new ArrayList<>();
        for (long id : list) {
            futures.add(CompletableFuture.runAsync(() -> currencyService
                    .findById(id).ifPresent(c -> currencies.add(c)), ex));
        }
        CompletableFuture.allOf((futures.toArray(new CompletableFuture[futures.size()]))).join();

`Ergebnis`


604ms

Übrigens, als ich versuchte, es mit "Executors.newSingleThreadExecutor ();" zu einem einzigen Thread zu machen, waren es 4123 ms.

Nachtrag

In diesem Experiment werden wir Daten an RDS senden, aber es scheint, dass wir vorsichtig sein müssen, wenn wir eine externe Verbindung mit Parallel Stream herstellen. http://taichiw.hatenablog.com/entry/2018/09/30/224907

Ich habe es auch zur Liste in der Schleife hinzugefügt, aber es scheint nicht gut zu sein, da es sich um einen sogenannten Nebeneffekt handelt.