Potrzebujesz do semafore.relase() czy semaphore.acquire() dostaje wyjątek InterruptedException?

Question

Z dokumentacji Java java.util.concurrent.Semaphore nie było dla mnie jasne, co się stanie, jeśli semafore.acquire() blokuje wątek, a później zostaje przerwany przez wyjątek InterruptedException. Czy wartość semafora została zmniejszona i czy istnieje potrzeba zwolnienia semafora?

Obecnie używam kodu:

try { 
    // use semaphore to limit number of parallel threads 
    semaphore.acquire(); 
    doMyWork(); 
} 
finally { 
    semaphore.release(); 
} 

lub nie powinny raczej wywołać uwolnienie(), gdy wystąpi InterruptedException podczas nabywać()?

Answer 1

wywołanie połączenia(), gdy wystąpi wyjątek InterruptedException podczas nabywania()?

Nie powinieneś. Jeśli .acquire() zostanie przerwane, semafor nie zostanie pozyskany, więc prawdopodobnie nie powinien go zwolnić.

Kod powinien być

// use semaphore to limit number of parallel threads 
semaphore.acquire(); 
try { 
    doMyWork(); 
} 
finally { 
    semaphore.release(); 
} 

Answer 2

Jeśli nić zostanie przerwany przed metoda nabyć połączenia lub podczas oczekiwania na uzyskanie pozwoleniu InterruptedException zostanie wyrzucony i nie pozwolenie będzie trzymać, więc nie ma potrzeby, aby zwolnić. Tylko wtedy, gdy masz pewność, że pozwolenie zostało nabyte (po wywołaniu metody nabycia), musisz zwolnić zezwolenie. Więc lepiej nabyć przed rozpoczęciem swojego bloku try, coś jak:

sem.acquire(); 
try{ 
    doMyWork(); 
}finally{ 
    sem.release(); 
} 

Answer 3

NOS zaakceptował odpowiedź jest częściowo poprawny, z wyjątkiem semaphore.acquire() rzuca również InterruptedException. Aby uzyskać 100% poprawności, kod powinien wyglądać następująco:

try { 
    semaphore.acquire(); 
    try { 
     doMyWork(); 
    } catch (InterruptedException e) { 
     // do something, if you wish 
    } finally { 
     semaphore.release(); 
    } 
} catch (InterruptedException e) { 
    // do something, if you wish 
}