Створення паралельних потоків для обробки

Ви розробляєте застосунок для фінансового аналізу, який має обробляти велику кількість транзакцій. Кожна транзакція потребує ресурсоємних обчислень на CPU. Наразі застосунок працює послідовно, і це занадто повільно. Ваше завдання — реалізувати багатопотокове рішення, щоб підвищити продуктивність.

Клас Transaction уже підготовлено для вас.

Ця вправа є частиною курсу

Оптимізація коду в Java

Переглянути курс

Інструкції до вправи

Створіть Thread, які виконуватимуть processTransaction().
Запустіть усі потоки.
Дочекайтеся завершення всіх потоків.

Інтерактивна практична вправа

Спробуйте виконати цю вправу, доповнивши цей зразок коду.

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

Редагувати та запускати код