Java中的并发控制工具Semaphore使用示例

原创待我称王封你为后i 2024-11-21 11:33 5阅读 0赞

Semaphore是Java中的一种同步工具，它是一个可以限制特定数量的共享资源。在多线程环境下，我们可以通过Semaphore来控制对某种资源（如打印机、文件锁等）的访问。

以下是一个简单的Semaphore使用示例：

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

public class SemaphoreExample {
    private Semaphore printer; // 创建一个打印机的Semaphore

public SemaphoreExample() {
        printer = new Semaphore(1); // 初始化，允许一次打印
    }

// 写一个线程来模拟打印过程
    public void printThread() throws InterruptedException {
        printer.acquire(); // 请求使用打印机
        System.out.println("Print thread is printing..."); // 执行打印操作
        printer.release(); // 使用完后归还
    }

// 主函数，创建线程并执行
    public static void main(String[] args) {
        SemaphoreExample example = new SemaphoreExample();

Thread printThread = new Thread(example::printThread);
        printThread.start(); // 启动打印线程

try {
            // 等待打印线程完成任务
            printThread.join();
        } catch (InterruptedException e) {
            e.printStackTrace();
        }

System.out.println("Semaphore example finished.");
    }
}
```

在这个示例中，我们创建了一个`Semaphore`来模拟一个打印机。当一个线程请求使用打印机时，它需要先获得`printer`对象的许可（即调用`acquire()`方法）。打印完成后，它需要释放这个许可（即调用`release()`方法）。

通过这种方式，我们可以控制多线程对共享资源的访问。