Java中的信号量semaphore-369IT编程

admin管理员组
文章数量:1032173

Java中的信号量semaphore

1. 概述

在本快速教程中，我们将探讨 Java 中信号量和互斥体的基础知识。

2.信号量

我们将从java.util.concurrent.Semaphore开始。我们可以使用信号量来限制访问特定资源的并发线程数。

在下面的示例中，我们将实现一个简单的登录队列来限制系统中的用户数量：

代码语言：javascript代码运行次数：0运行复制

class LoginQueueUsingSemaphore {

    private Semaphore semaphore;

    public LoginQueueUsingSemaphore(int slotLimit) {
        semaphore = new Semaphore(slotLimit);
    }

    boolean tryLogin() {
        return semaphore.tryAcquire();
    }

    void logout() {
        semaphore.release();
    }

    int availableSlots() {
        return semaphore.availablePermits();
    }

}Copy

请注意我们如何使用以下方法：

tryAcquire（）– 如果许可证立即可用，则返回 true，否则返回 false，但acquire（） 获取许可证并阻止，直到一个许可证可用
release（） – 释放许可证
availablePermits（） – 返回当前可用许可证的数量

为了测试我们的登录队列，我们将首先尝试达到限制并检查下一次登录尝试是否会被阻止：

代码语言：javascript代码运行次数：0运行复制

@Test
public void givenLoginQueue_whenReachLimit_thenBlocked() {
    int slots = 10;
    ExecutorService executorService = Executors.newFixedThreadPool(slots);
    LoginQueueUsingSemaphore loginQueue = new LoginQueueUsingSemaphore(slots);
    IntStream.range(0, slots)
      .forEach(user -> executorService.execute(loginQueue::tryLogin));
    executorService.shutdown();

    assertEquals(0, loginQueue.availableSlots());
    assertFalse(loginQueue.tryLogin());
}Copy

接下来，我们将查看注销后是否有任何插槽可用：

代码语言：javascript代码运行次数：0运行复制

@Test
public void givenLoginQueue_whenLogout_thenSlotsAvailable() {
    int slots = 10;
    ExecutorService executorService = Executors.newFixedThreadPool(slots);
    LoginQueueUsingSemaphore loginQueue = new LoginQueueUsingSemaphore(slots);
    IntStream.range(0, slots)
      .forEach(user -> executorService.execute(loginQueue::tryLogin));
    executorService.shutdown();
    assertEquals(0, loginQueue.availableSlots());
    loginQueue.logout();

    assertTrue(loginQueue.availableSlots() > 0);
    assertTrue(loginQueue.tryLogin());
}Copy

3. 定时信号量

接下来，我们将讨论Apache CommonsTimedSemaphore。TimedSemaphore允许将多个许可证作为简单的信号量，但在给定的时间段内，在此时间段之后，时间重置并释放所有许可证。

我们可以使用TimedSemaphore来构建一个简单的延迟队列，如下所示：

代码语言：javascript代码运行次数：0运行复制

class DelayQueueUsingTimedSemaphore {

    private TimedSemaphore semaphore;

    DelayQueueUsingTimedSemaphore(long period, int slotLimit) {
        semaphore = new TimedSemaphore(period, TimeUnit.SECONDS, slotLimit);
    }

    boolean tryAdd() {
        return semaphore.tryAcquire();
    }

    int availableSlots() {
        return semaphore.getAvailablePermits();
    }

}Copy

当我们使用以一秒作为时间段的延迟队列并在一秒内用完所有插槽后，应该没有一个可用：

代码语言：javascript代码运行次数：0运行复制

public void givenDelayQueue_whenReachLimit_thenBlocked() {
    int slots = 50;
    ExecutorService executorService = Executors.newFixedThreadPool(slots);
    DelayQueueUsingTimedSemaphore delayQueue 
      = new DelayQueueUsingTimedSemaphore(1, slots);
    
    IntStream.range(0, slots)
      .forEach(user -> executorService.execute(delayQueue::tryAdd));
    executorService.shutdown();

    assertEquals(0, delayQueue.availableSlots());
    assertFalse(delayQueue.tryAdd());
}Copy

但是在睡了一段时间后，信号灯应该重置并释放许可证：

代码语言：javascript代码运行次数：0运行复制

@Test
public void givenDelayQueue_whenTimePass_thenSlotsAvailable() throws InterruptedException {
    int slots = 50;
    ExecutorService executorService = Executors.newFixedThreadPool(slots);
    DelayQueueUsingTimedSemaphore delayQueue = new DelayQueueUsingTimedSemaphore(1, slots);
    IntStream.range(0, slots)
      .forEach(user -> executorService.execute(delayQueue::tryAdd));
    executorService.shutdown();

    assertEquals(0, delayQueue.availableSlots());
    Thread.sleep(1000);
    assertTrue(delayQueue.availableSlots() > 0);
    assertTrue(delayQueue.tryAdd());
}Copy

4. 信号量与互斥体

互斥体的作用类似于二进制信号量，我们可以使用它来实现互斥。

在以下示例中，我们将使用简单的二进制信号量来构建计数器：

代码语言：javascript代码运行次数：0运行复制

class CounterUsingMutex {

    private Semaphore mutex;
    private int count;

    CounterUsingMutex() {
        mutex = new Semaphore(1);
        count = 0;
    }

    void increase() throws InterruptedException {
        mutex.acquire();
        this.count = this.count + 1;
        Thread.sleep(1000);
        mutex.release();

    }

    int getCount() {
        return this.count;
    }

    boolean hasQueuedThreads() {
        return mutex.hasQueuedThreads();
    }
}Copy

当许多线程尝试同时访问计数器时，它们只会在队列中被阻止：

代码语言：javascript代码运行次数：0运行复制

@Test
public void whenMutexAndMultipleThreads_thenBlocked()
 throws InterruptedException {
    int count = 5;
    ExecutorService executorService
     = Executors.newFixedThreadPool(count);
    CounterUsingMutex counter = new CounterUsingMutex();
    IntStream.range(0, count)
      .forEach(user -> executorService.execute(() -> {
          try {
              counter.increase();
          } catch (InterruptedException e) {
              e.printStackTrace();
          }
      }));
    executorService.shutdown();

    assertTrue(counter.hasQueuedThreads());
}Copy

当我们等待时，所有线程都将访问计数器，队列中没有线程：

代码语言：javascript代码运行次数：0运行复制

@Test
public void givenMutexAndMultipleThreads_ThenDelay_thenCorrectCount()
 throws InterruptedException {
    int count = 5;
    ExecutorService executorService
     = Executors.newFixedThreadPool(count);
    CounterUsingMutex counter = new CounterUsingMutex();
    IntStream.range(0, count)
      .forEach(user -> executorService.execute(() -> {
          try {
              counter.increase();
          } catch (InterruptedException e) {
              e.printStackTrace();
          }
      }));
    executorService.shutdown();

    assertTrue(counter.hasQueuedThreads());
    Thread.sleep(5000);
    assertFalse(counter.hasQueuedThreads());
    assertEquals(count, counter.getCount());
}Copy

5. 结论

在本文中，我们探讨了 Java 中信号量的基础知识。

本文参与腾讯云自媒体同步曝光计划，分享自作者个人站点/博客。原始发表：2023-02-14，如有侵权请联系 cloudcommunity@tencent 删除javasemaphore登录队列线程

Java中的信号量semaphore

1. 概述

在本快速教程中，我们将探讨 Java 中信号量和互斥体的基础知识。

2.信号量

我们将从java.util.concurrent.Semaphore开始。我们可以使用信号量来限制访问特定资源的并发线程数。

在下面的示例中，我们将实现一个简单的登录队列来限制系统中的用户数量：

代码语言：javascript代码运行次数：0运行复制

class LoginQueueUsingSemaphore {

    private Semaphore semaphore;

    public LoginQueueUsingSemaphore(int slotLimit) {
        semaphore = new Semaphore(slotLimit);
    }

    boolean tryLogin() {
        return semaphore.tryAcquire();
    }

    void logout() {
        semaphore.release();
    }

    int availableSlots() {
        return semaphore.availablePermits();
    }

}Copy

请注意我们如何使用以下方法：

tryAcquire（）– 如果许可证立即可用，则返回 true，否则返回 false，但acquire（） 获取许可证并阻止，直到一个许可证可用
release（） – 释放许可证
availablePermits（） – 返回当前可用许可证的数量

为了测试我们的登录队列，我们将首先尝试达到限制并检查下一次登录尝试是否会被阻止：

代码语言：javascript代码运行次数：0运行复制

@Test
public void givenLoginQueue_whenReachLimit_thenBlocked() {
    int slots = 10;
    ExecutorService executorService = Executors.newFixedThreadPool(slots);
    LoginQueueUsingSemaphore loginQueue = new LoginQueueUsingSemaphore(slots);
    IntStream.range(0, slots)
      .forEach(user -> executorService.execute(loginQueue::tryLogin));
    executorService.shutdown();

    assertEquals(0, loginQueue.availableSlots());
    assertFalse(loginQueue.tryLogin());
}Copy

接下来，我们将查看注销后是否有任何插槽可用：

代码语言：javascript代码运行次数：0运行复制

@Test
public void givenLoginQueue_whenLogout_thenSlotsAvailable() {
    int slots = 10;
    ExecutorService executorService = Executors.newFixedThreadPool(slots);
    LoginQueueUsingSemaphore loginQueue = new LoginQueueUsingSemaphore(slots);
    IntStream.range(0, slots)
      .forEach(user -> executorService.execute(loginQueue::tryLogin));
    executorService.shutdown();
    assertEquals(0, loginQueue.availableSlots());
    loginQueue.logout();

    assertTrue(loginQueue.availableSlots() > 0);
    assertTrue(loginQueue.tryLogin());
}Copy

3. 定时信号量

我们可以使用TimedSemaphore来构建一个简单的延迟队列，如下所示：

代码语言：javascript代码运行次数：0运行复制

class DelayQueueUsingTimedSemaphore {

    private TimedSemaphore semaphore;

    DelayQueueUsingTimedSemaphore(long period, int slotLimit) {
        semaphore = new TimedSemaphore(period, TimeUnit.SECONDS, slotLimit);
    }

    boolean tryAdd() {
        return semaphore.tryAcquire();
    }

    int availableSlots() {
        return semaphore.getAvailablePermits();
    }

}Copy

当我们使用以一秒作为时间段的延迟队列并在一秒内用完所有插槽后，应该没有一个可用：

代码语言：javascript代码运行次数：0运行复制

public void givenDelayQueue_whenReachLimit_thenBlocked() {
    int slots = 50;
    ExecutorService executorService = Executors.newFixedThreadPool(slots);
    DelayQueueUsingTimedSemaphore delayQueue 
      = new DelayQueueUsingTimedSemaphore(1, slots);
    
    IntStream.range(0, slots)
      .forEach(user -> executorService.execute(delayQueue::tryAdd));
    executorService.shutdown();

    assertEquals(0, delayQueue.availableSlots());
    assertFalse(delayQueue.tryAdd());
}Copy

但是在睡了一段时间后，信号灯应该重置并释放许可证：

代码语言：javascript代码运行次数：0运行复制

@Test
public void givenDelayQueue_whenTimePass_thenSlotsAvailable() throws InterruptedException {
    int slots = 50;
    ExecutorService executorService = Executors.newFixedThreadPool(slots);
    DelayQueueUsingTimedSemaphore delayQueue = new DelayQueueUsingTimedSemaphore(1, slots);
    IntStream.range(0, slots)
      .forEach(user -> executorService.execute(delayQueue::tryAdd));
    executorService.shutdown();

    assertEquals(0, delayQueue.availableSlots());
    Thread.sleep(1000);
    assertTrue(delayQueue.availableSlots() > 0);
    assertTrue(delayQueue.tryAdd());
}Copy

4. 信号量与互斥体

互斥体的作用类似于二进制信号量，我们可以使用它来实现互斥。

在以下示例中，我们将使用简单的二进制信号量来构建计数器：

代码语言：javascript代码运行次数：0运行复制

class CounterUsingMutex {

    private Semaphore mutex;
    private int count;

    CounterUsingMutex() {
        mutex = new Semaphore(1);
        count = 0;
    }

    void increase() throws InterruptedException {
        mutex.acquire();
        this.count = this.count + 1;
        Thread.sleep(1000);
        mutex.release();

    }

    int getCount() {
        return this.count;
    }

    boolean hasQueuedThreads() {
        return mutex.hasQueuedThreads();
    }
}Copy

当许多线程尝试同时访问计数器时，它们只会在队列中被阻止：

代码语言：javascript代码运行次数：0运行复制

@Test
public void whenMutexAndMultipleThreads_thenBlocked()
 throws InterruptedException {
    int count = 5;
    ExecutorService executorService
     = Executors.newFixedThreadPool(count);
    CounterUsingMutex counter = new CounterUsingMutex();
    IntStream.range(0, count)
      .forEach(user -> executorService.execute(() -> {
          try {
              counter.increase();
          } catch (InterruptedException e) {
              e.printStackTrace();
          }
      }));
    executorService.shutdown();

    assertTrue(counter.hasQueuedThreads());
}Copy

当我们等待时，所有线程都将访问计数器，队列中没有线程：

代码语言：javascript代码运行次数：0运行复制

@Test
public void givenMutexAndMultipleThreads_ThenDelay_thenCorrectCount()
 throws InterruptedException {
    int count = 5;
    ExecutorService executorService
     = Executors.newFixedThreadPool(count);
    CounterUsingMutex counter = new CounterUsingMutex();
    IntStream.range(0, count)
      .forEach(user -> executorService.execute(() -> {
          try {
              counter.increase();
          } catch (InterruptedException e) {
              e.printStackTrace();
          }
      }));
    executorService.shutdown();

    assertTrue(counter.hasQueuedThreads());
    Thread.sleep(5000);
    assertFalse(counter.hasQueuedThreads());
    assertEquals(count, counter.getCount());
}Copy

5. 结论

在本文中，我们探讨了 Java 中信号量的基础知识。

本文参与腾讯云自媒体同步曝光计划，分享自作者个人站点/博客。原始发表：2023-02-14，如有侵权请联系 cloudcommunity@tencent 删除javasemaphore登录队列线程

本文标签： Java中的信号量semaphore

版权声明：本文标题：Java中的信号量semaphore 内容由热心网友自发贡献，该文观点仅代表作者本人，转载请联系作者并注明出处：http://it.en369.cn/jiaocheng/1747914342a2227001.html，本站仅提供信息存储空间服务，不拥有所有权，不承担相关法律责任。如发现本站有涉嫌抄袭侵权/违法违规的内容，一经查实，本站将立刻删除。

369IT编程

Java中的信号量semaphore

Java中的信号量semaphore

1. 概述

2.信号量

3. 定时信号量

4. 信号量与互斥体

5. 结论

Java中的信号量semaphore

1. 概述

2.信号量

3. 定时信号量

4. 信号量与互斥体

5. 结论

更多相关文章

Java中的信号量semaphore

发表评论

推荐文章

三张图看懂为什么redis这么快

3款本周高潜力开源AI工具（多模态集成

聊聊强化学习发展这十年

魔改AlphaZero后，《我的世界》AI老玩家问世，干活不用下指令

哈希函数值如何还原

热门文章

实时分析利器

OpenAI 推出了全新的 GPT

UMIT：统一多模态多任务视觉

win10激活 错误代码0x80070424

GitHub MCP Server v0.2.0重磅发布！多项全新功能革新，助你高效管理开源项目！

Go 语言常见错误——单元测试

拒绝停服，随时回退：Sybase 到 PostgreSQL 的无缝数据库双向迁移方案

prometheus部署教程（一）

预训练还没终结！港中文清华等提出「三位一体」框架，持续自我进化

RetentionPolicy 枚举类型介绍

最新文章

详解供应链中的一品多码

深入浅出ChatGPT

前馈神经网络层（Feed

前馈神经网络层和全连接神经网络层有什么区别

编码器

程序员刚毕业，先去大厂镀金还是先去小厂攒经验？

万象2008清空boss账户密码

【Tools】GitBook简明教程

oracle exadata celldisk 闪存盘受损导致性能下降

SDUT 2138 图结构练习——BFSDFS——判断可达性

javascript - Type &#39;undefined&#39; is not assignable to type &#39;menuItemProps[]&#39; - Stack Overflow

javascript - VS 2015 Angular 2 import modules cannot be resolved - Stack Overflow

javascript - Get the JSON objects that are not present in another array - Stack Overflow

javascript - How to dismiss a phonegap notification programmatically - Stack Overflow

c - Solaris 10 make Error code 1 Fatal Error when trying to build python 2.7.16 - Stack Overflow

win10激活错误代码0x80070424

javascript - Type 'undefined' is not assignable to type 'menuItemProps[]' - Stack Overflow