java信号量实现对象池

- 日理万妓 2022-12-31 10:25 91阅读 0赞

import java.util.List;
    import java.util.Vector;
    import java.util.concurrent.Semaphore;
    import java.util.function.Function;
    
    public class ObjectPool<T, R> {
        //对象池
        final List<T> pool;
        //用信号量实现限流器
        final Semaphore sem;
    
        public ObjectPool(int size, T t) {
            pool = new Vector<>();
            for(int i = 0; i < size; i++) {
                pool.add(t);
            }
            sem = new Semaphore(size);
        }
    
        //利用对象池的对象，调用func
        R exec(Function<T, R> func) {
            T t = null;
            R r = null;
            try {
                sem.acquire();
                t = pool.remove(0);
                r = func.apply(t);
            } catch (InterruptedException e) {
                e.printStackTrace();
            } finally {
                pool.add(t);
                sem.release();
            }
            return r;
        }
    
        public static void main(String[] args) {
            //创建对象池
            ObjectPool<String, String> pool = new ObjectPool<>(10, "demo");
            System.out.println(pool.exec(t-> System.currentTimeMillis() + t));
        }
    }

发表评论取消回复

表情：

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

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

相关阅读

相关 POSIX信号量——命名信号量

目录 1、Open 2、Wait 3、Post 4、Close 5、Delete -------------------- > POSIX 信号量有两种类型

冷不防/ 2023年01月03日 04:29/ 0 赞/ 108 阅读

相关 java信号量实现对象池

import java.util.List; import java.util.Vector; import java.util.concurrent.

- 日理万妓/ 2022年12月31日 10:25/ 0 赞/ 92 阅读

相关有名信号量，无名信号量

一、同步互斥方式 -- 有名信号量。 1、有名信号量特性？有名信号量与学习过的信号量非常相似，但是信号量的值只能是0或者1，而是有名信号量可以0~正无穷。信号量

ゝ一世哀愁。/ 2022年12月11日 13:56/ 0 赞/ 212 阅读

相关 SylixOS信号量（二进制信号量、计数型信号量、互斥信号量（简称互斥量）、读写信号量）

目录二进制信号量互斥信号量计数器信号量读写信号量 -------------------- SylixOS 信号量多个线程在读写某个共享数据（全局变

àì夳堔傛蜴生んèń/ 2022年12月05日 10:00/ 0 赞/ 364 阅读

相关 Hystrix 隔离策略：线程池、信号量

记一次被问到的面试题：Hystrix系列之信号量、线程池 -------------------- Hystrix内部，提供了两种模式隔离策略：`信号量`、`线程池`。

朴灿烈づ我的快乐病毒、/ 2022年11月26日 06:51/ 0 赞/ 118 阅读

相关线程池和信号量

当我们需要执行一个异步任务时，通常会创建一个线程并启动它，通常任务执行完，线程会被回收，这的确很方便。但我们有大量的任务需要去执行，高并发的情况下，我们都需要不断的创建线程，创

快来打我*/ 2022年07月16日 03:19/ 0 赞/ 166 阅读

相关 Windows线程同步——信号量对象

1. 概述信号量内核对象用来对资源计数。与其他所有内核对象相同，它们也包含一个使用计数，但它们还包含另外两个32位值：一个最大资源和一个当前资源计数。最大资源计数表示信

分手后的思念是犯贱/ 2022年06月14日 10:56/ 0 赞/ 278 阅读

相关 C++ 11实现信号量

// / 文件名：CSemaphore.h / / 功能：C++11信号量 / // ifndef _

谁践踏了优雅/ 2022年04月13日 02:31/ 0 赞/ 239 阅读

相关内核对象之信号量

转载自：[http://blog.csdn.net/morewindows/article/details/7481609][http_blog.csdn.net_morewi

怼烎@/ 2021年12月20日 08:37/ 0 赞/ 169 阅读

相关 Java 信号量实战

一点睛它的作用是限流，可以允许多个线程同时执行。二代码 import java.util.concurrent.Semaphore;

青旅半醒/ 2021年07月24日 22:17/ 0 赞/ 338 阅读