Практикаңызда семафорлармен жұмыс істедіңіз бе…

Иә, мен семафорларды қолдануды қажет етті, әсіресе Android қосымшаларында көп ағынды жұмыс кезінде.

Java-да (java.util.concurrent.Semaphore) семафорлар бір уақытта белгілі бір ресурстарға қол жеткізе алатын ағындардың санын шектеу үшін пайдаланылады. Бұл шектеулі "көлемі" бар ресурстарды пайдалану сценарийлерінде пайдалы, мысалы, қосылымдар пулі немесе қол жетімді слоттардың шектеулі саны.

Мен жұмыс істеген негізгі әдістер:

acquire(): Ағымдағы ағынды блоктайды, рұқсат берілгенше.
acquire(int permits): Ағымдағы ағынды блоктайды, көрсетілген рұқсаттар саны қол жетімді болғанша.
release(): Семофорға рұқсатты қайтарады, қол жетімді рұқсаттардың санын арттырады.
release(int permits): Көрсетілген рұқсаттар санын қайтарады.
tryAcquire(): Ағынды блоктамай рұқсат алуға тырысады.
availablePermits(): Қол жетімді рұқсаттардың ағымдағы санын қайтарады.

Қолдану мысалы:

import java.util.concurrent.Semaphore;

public class ResourcePool {

    private static final int MAX_AVAILABLE = 5;
    private final Semaphore permits = new Semaphore(MAX_AVAILABLE, true); // Әділ семафор

    public void useResource() throws InterruptedException {
        permits.acquire(); // Рұқсат сұраймыз
        try {
            // Ресурсты пайдалану логикасы (мысалы, қосылымдар пулімен жұмыс)
            System.out.println(Thread.currentThread().getName() + " ресурсты пайдаланып жатыр.");
            Thread.sleep(1000); // Ресурспен жұмыс істеуді имитациялау
        } finally {
            permits.release(); // Рұқсатты босату
            System.out.println(Thread.currentThread().getName() + " ресурсты пайдалану аяқталды.");
        }
    }

    public static void main(String[] args) {
        ResourcePool pool = new ResourcePool();
        // Ресурсты пайдалуға тырысатын бірнеше ағындар құру
        for (int i = 0; i < 10; i++) {
            new Thread(() -> {
                try {
                    pool.useResource();
                } catch (InterruptedException e) {
                    e.printStackTrace();
                }
            }).start();
        }
    }
}

Бұл мысалда permits семафоры 5 рұқсатпен инициализацияланған, яғни бір уақытта тек 5 ағын try блогында ресурсты пайдалана алады. acquire() әдісі барлық рұқсаттар алынған кезде ағындарды блоктайды, басқа ағындар release() шақырғанша күтеді.

Семафорлар шектеулі ресурстар пулдарына қол жеткізуді басқару үшін ыңғайлы, бірақ дұрыс басқарылмаса, deadlock сияқты мәселелер туындауы мүмкін. try және finally блогын пайдалану release() шақыруды қамтамасыз ету үшін жақсы тәжірибе болып табылады, тіпті қателер болған жағдайда да ресурстар босатылады.

Практикаңызда семафорлармен жұмыс істедіңіз бе?