线程问题--（Semaphore线程安全）

╰半橙微兮° 2022-05-22 11:12 309阅读 0赞

package com.mmall.concurrency.example.atomic;  
  
  
import com.mmall.concurrency.annoations.ThreadSafe;  
import lombok.extern.slf4j.Slf4j;  
  
  
import java.util.concurrent.CountDownLatch;  
import java.util.concurrent.ExecutorService;  
import java.util.concurrent.Executors;  
import java.util.concurrent.Semaphore;  
import java.util.concurrent.atomic.AtomicLong;  
  
  
@Slf4j  
@ThreadSafe  
public class AtomicExample2 \{  
  
  
    // 请求总数  
    public static int clientTotal = 5000;  
  
  
    // 同时并发执行的线程数  
    public static int threadTotal = 200;  
  
  
    public static AtomicLong count = new AtomicLong(0);  
  
  
    public static void main(String\[\] args) throws Exception \{  
        ExecutorService executorService = Executors.newCachedThreadPool();  
        final Semaphore semaphore = new Semaphore(threadTotal);  
        final CountDownLatch countDownLatch = new CountDownLatch(clientTotal);  
        for (int i = 0; i < clientTotal ; i++) \{  
            executorService.execute(() -> \{  
                try \{  
                    semaphore.acquire();  
                    add();  
                    semaphore.release();  
                \} catch (Exception e) \{  
                \}  
                countDownLatch.countDown();  
            \});  
        \}  
        countDownLatch.await();  
        executorService.shutdown();  
    \}  
  
  
    private static void add() \{  
        count.incrementAndGet();  
        // count.getAndIncrement();  
    \}  
\}

发表评论取消回复

表情：

评论列表（有 0 条评论，309人围观）

还没有评论，来说两句吧...

相关阅读

相关线程安全问题

我们把⼀段代码想象成⼀个房间，每个线程就是要进⼊这个房间的⼈。如果没有任何机制保证，A进⼊房间之后，还没有出来；B 是不是也可以进⼊房间，打断 A 在房间⾥的隐私。这个就...

绝地灬酷狼/ 2024年04月23日 20:34/ 0 赞/ 125 阅读

相关线程安全问题

作者简介： zoro-1，目前大二，正在学习Java,数据结构,mysql,javaee等作者主页：??。

朴灿烈づ我的快乐病毒、/ 2024年04月20日 04:48/ 0 赞/ 141 阅读

相关【多线程】线程安全问题

文章目录 1. 线程安全 1.1 线程安全的概念 1.2 线程不安全的原因 2. synchronized 关键字 2.

超、凢脫俗/ 2024年04月08日 09:57/ 0 赞/ 168 阅读

相关【多线程】线程安全问题

![b5310858a38c71fb0d8e95483dd1da14.gif][] 1. 一段线程不安全的代码我们先来看一段代码： public class

ゞ浴缸里的玫瑰/ 2024年03月26日 14:31/ 0 赞/ 154 阅读

相关多线程 - Semaphore

Semaphore 是一种用于控制线程并发访问数的同步工具。它通过维护一定数量的许可证来限制对共享资源的访问。许可证的数量就是可以同时访问共享资源的线程数目。当一个线

向右看齐/ 2024年03月22日 03:21/ 0 赞/ 164 阅读

相关 Java多线程 - 线程安全和线程同步解决线程安全问题

文章目录线程安全问题线程同步方式一: 同步代码块方式二: 同步方法方式

秒速五厘米/ 2023年09月23日 13:29/ 0 赞/ 265 阅读

相关线程安全问题

基本概述： ![在这里插入图片描述][watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nL

àì夳堔傛蜴生んèń/ 2022年11月29日 12:21/ 0 赞/ 287 阅读

相关多线程-Semaphore

package cn.stu; import java.util.ArrayList; import java.util.List;

傷城~/ 2022年07月14日 22:21/ 0 赞/ 282 阅读

相关线程问题--（Semaphore线程安全）

package com.mmall.concurrency.example.atomic; import com.mmall.concurrency.annoa

╰半橙微兮°/ 2022年05月22日 11:12/ 0 赞/ 310 阅读

相关线程问题--（Semaphore计数线程不安全）

package com.mmall.concurrency; import com.mmall.concurrency.annoations.NotThread

快来打我*/ 2022年05月22日 11:07/ 0 赞/ 261 阅读