Java并发编程实战：使用Semaphore控制线程

原创水深无声 2024-09-23 07:09 69阅读 0赞

Semaphore是Java中一种多线程同步工具，它允许最多n个不同的线程访问同一资源。当一个线程进入临界区并获取了Semaphore的计数器值后，其他想要进入临界区的线程必须先释放这个Semaphore。

下面是一个使用Semaphore控制线程的例子：

```java
import java.util.concurrent.Semaphore;

public class SemaphoreExample {
    private Semaphore semaphore = new Semaphore(1); // 允许一次访问

public void task() throws InterruptedException {
        System.out.println("Thread: " + Thread.currentThread().getName() + " is trying to acquire semaphore...");

// 获取信号量
        if (semaphore.tryAcquire()) {
            System.out.println("Thread: " + Thread.currentThread().getName() + " successfully acquired semaphore.");
            // 进行任务
            doSomething();
        } else {
            System.out.println("Thread: " + Thread.currentThread().getName() + " couldn't acquire semaphore. Retrying...");
            // 重试
            task();
        }
    }

private void doSomething() {
        try {
            Thread.sleep(2000); // 模拟耗时操作
            System.out.println(Thread.currentThread().getName() + " completed the task.");
        } catch (InterruptedException e) {
            e.printStackTrace();
        }
    }

public static void main(String[] args) throws InterruptedException {
        SemaphoreExample example = new SemaphoreExample();

Thread thread1 = new Thread(example::task);
        Thread thread2 = new Thread(example::task);

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

// 等待所有线程完成
        thread1.join();
        thread2.join();
    }
}
```

在这个例子中，我们创建了一个Semaphore，它允许一次访问。每个任务（由`task`方法表示）都尝试获取Semaphore。如果成功，任务将执行耗时操作，并在完成后释放Semaphore。其他想要执行任务的线程必须等待Semaphore被释放。