Crearea firelor de execuție paralele pentru procesare

Dezvolți o aplicație de analiză financiară care trebuie să proceseze un număr mare de tranzacții. Fiecare tranzacție necesită calcule intensive la nivel de CPU. În prezent, aplicația folosește o abordare secvențială, însă aceasta este prea lentă. Sarcina ta este să implementezi o soluție multi-threading pentru a îmbunătăți performanța.

Clasa Transaction a fost preîncărcată pentru tine.

Acest exercițiu face parte din cursul

Optimizarea codului în Java

Vezi cursul

Instrucțiuni pentru exercițiu

Creează fire de execuție (Thread) care vor rula processTransaction().
Pornește toate firele de execuție.
Așteaptă finalizarea tuturor firelor de execuție.

Exercițiu interactiv practic

Încearcă acest exercițiu completând acest cod de exemplu.

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;
    }
}

Editează și rulează codul