Semaphore

最新推荐文章于 2024-04-14 11:57:45 发布

朴勇佑

最新推荐文章于 2024-04-14 11:57:45 发布

阅读量137

点赞数

分类专栏： Java

本文链接：https://blog.csdn.net/yongwoozzang/article/details/103604452

版权

Java 专栏收录该内容

65 篇文章

订阅专栏

本文通过一个具体的Java代码示例，展示了Semaphore类在多线程环境中的使用方法。Semaphore可以控制同时访问特定资源的线程数量，适用于需要限制并发访问场景的应用开发。

摘要生成于 C知道，由 DeepSeek-R1 满血版支持，前往体验 >

package com.company.bingfa;

import java.util.concurrent.Semaphore;

class WC extends Thread{

    private Semaphore sem;

    WC(Semaphore sem){
        this.sem = sem;
    }

    @Override
    public void run() {
        if (sem.availablePermits()>0)
            System.out.println(getName()+"发现有空位");
        else
            System.out.println(getName()+"没有位子,等待中..");
        try {
            sem.acquire();
        } catch (InterruptedException e) {
            e.printStackTrace();
        }

        System.out.println(getName()+"开始使用...");

        try {
            sleep(3000);
        } catch (InterruptedException e) {
            e.printStackTrace();
        }

        System.out.println(getName()+"使用完毕---");

        sem.release();
    }
}

public class MySemaphore {
    public static void main(String[] args) throws InterruptedException {
        Semaphore sem = new Semaphore(3);

        Thread[] threads = new Thread[10];
        for (int i = 0; i < threads.length; i++) {
            threads[i] = new WC(sem);
        }

        for (int i = 0; i < threads.length; i++) {
            threads[i].start();
        }

        for (int i = 0; i < threads.length; i++) {
            threads[i].join();
        }

        System.out.println("主线程结束");
    }
}