Создание параллельных потоков для обработки данных
Вы разрабатываете приложение для финансового анализа, которое должно обрабатывать большое количество транзакций. Каждая транзакция требует ресурсоёмких вычислений. Сейчас приложение работает последовательно, и это слишком медленно. Ваша задача — реализовать многопоточное решение для повышения производительности.
Класс 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;
}
}