Java for Beginner

Пример 3: Счетчик посещений веб-сайта
Представим, что у нас есть веб-сайт, который обрабатывает множество запросов в секунду. Нам нужно вести подсчет посещений сайта, причем из разных потоков одновременно. В этом случае синхронизированные коллекции помогут избежать некорректного подсчета.

Мы можем использовать Collections.synchronizedMap() для создания потокобезопасной карты, где ключом будет страница, а значением — счетчик посещений.

import java.util.Collections;
import java.util.HashMap;
import java.util.Map;

public class VisitCounter {
    private final Map<String, Integer> visitCounts = Collections.synchronizedMap(new HashMap<>());

    public void recordVisit(String page) {
        visitCounts.merge(page, 1, Integer::sum);
    }

    public int getVisitCount(String page) {
        return visitCounts.getOrDefault(page, 0);
    }
}

// Пример использования
VisitCounter visitCounter = new VisitCounter();

// Моделируем посещения страниц
Runnable visitSimulator = () -> {
    for (int i = 0; i < 1000; i++) {
        visitCounter.recordVisit("/index.html");
        visitCounter.recordVisit("/contact.html");
    }
};

Thread thread1 = new Thread(visitSimulator);
Thread thread2 = new Thread(visitSimulator);

thread1.start();
thread2.start();

try {
    thread1.join();
    thread2.join();
} catch (InterruptedException e) {
    e.printStackTrace();
}

System.out.println("Index Page Visits: " + visitCounter.getVisitCount("/index.html"));
System.out.println("Contact Page Visits: " + visitCounter.getVisitCount("/contact.html"));
В этом примере мы используем synchronizedMap для подсчета посещений страниц. Метод merge() безопасен для использования в многопоточной среде, что позволяет корректно увеличивать счетчики.

Пример 4: Синхронизированный доступ к общему ресурсу
Рассмотрим задачу, в которой несколько потоков должны безопасно добавлять элементы в общий список и извлекать их для обработки. Важно, чтобы все операции были синхронизированы, чтобы избежать потери данных.

Задача: Создать потокобезопасную очередь задач.

import java.util.Queue;
import java.util.LinkedList;
import java.util.Collections;

public class SynchronizedTaskQueue {
    private final Queue<String> taskQueue = Collections.synchronizedList(new LinkedList<>());

    public void addTask(String task) {
        synchronized (taskQueue) {
            taskQueue.add(task);
            taskQueue.notify(); // Уведомляем ждущий поток о новой задаче
        }
    }

    public String getTask() throws InterruptedException {
        synchronized (taskQueue) {
            while (taskQueue.isEmpty()) {
                taskQueue.wait(); // Ждем, пока появится новая задача
            }
            return taskQueue.poll();
        }
    }
}

// Пример использования
SynchronizedTaskQueue queue = new SynchronizedTaskQueue();

// Поток для добавления задач
Thread producer = new Thread(() -> {
    for (int i = 0; i < 5; i++) {
        queue.addTask("Task " + i);
    }
});

// Поток для обработки задач
Thread consumer = new Thread(() -> {
    try {
        for (int i = 0; i < 5; i++) {
            String task = queue.getTask();
            System.out.println("Processing " + task);
        }
    } catch (InterruptedException e) {
        Thread.currentThread().interrupt();
    }
});

producer.start();
consumer.start();
В этом примере мы используем синхронизированную очередь задач, где метод addTask() добавляет задачи в очередь и уведомляет ждущие потоки, а метод getTask() ждет появления новой задачи, если очередь пуста. Таким образом, обеспечивается безопасный доступ к общему ресурсу в многопоточной среде.

#Java #Training #Medium #SynchronizedCollections

113 views14:20