Tworzenie równoległych wątków do przetwarzania danych

Tworzysz aplikację do analizy finansowej, która musi przetwarzać dużą liczbę transakcji. Każda transakcja wymaga intensywnych obliczeń procesora. Aplikacja korzysta obecnie z podejścia sekwencyjnego, które jest zbyt wolne. Twoim zadaniem jest zaimplementowanie rozwiązania wielowątkowego w celu poprawy wydajności.

Klasa Transaction została wcześniej wczytana.

To ćwiczenie jest częścią kursu

Optymalizacja kodu w Javie

Zobacz kurs

Instrukcje do ćwiczenia

Utwórz wątki (Thread), które będą wykonywać metodę processTransaction().
Uruchom wszystkie wątki.
Poczekaj na zakończenie wszystkich wątków.

Interaktywne ćwiczenie praktyczne

Spróbuj tego ćwiczenia, uzupełniając ten przykładowy kod.

public class TransactionProcessor {
    public static void main(String[] args) throws InterruptedException {
        List transactions = generateTransactions(1000);
        List threads = new ArrayList<>();
        for (int t = 0; t < 4; t++) {
            int start = t * 250;
            int end = (t == 3) ? transactions.size() : (t + 1) * 250;

            // Create thread that will run processTransaction()
            Thread thread = new ____(() -> {
                for (int i = start; i < end; i++) {
                    processTransaction(transactions.get(i));
                }
            });
            threads.add(thread);
            // Start the thread
            thread.____(); 
        }

        // Wait for all threads to complete
        for (Thread thread : threads) {
            thread.____();
        }
    }

    static void processTransaction(Transaction tx) {
        double result = 0;
        for (int i = 0; i < 1000; i++) {
            result += Math.sqrt(tx.amount * i);
        }
        tx.result = result;
    }

    static List generateTransactions(int n) {
        List list = new ArrayList<>();
        for (int i = 0; i < n; i++) {
            list.add(new Transaction(Math.random() * 1000));
        }
        return list;
    }
}

Edytuj i uruchom kod