PoolBoy

PoolBoy

大家好,又见面了,我是全栈君,今天给大家准备了Idea注册码。

PoolBoy

 source code :

https://github.com/devinus/poolboy

PoolBoy

Checkout

ready({checkout, Block, Timeout}, {FromPid, _}=From, State) -> #state{supervisor = Sup, workers = Workers, monitors = Monitors, max_overflow = MaxOverflow} = State, case queue:out(Workers) of {{value, Pid}, Left} -> Ref = erlang:monitor(process, FromPid), true = ets:insert(Monitors, {Pid, Ref}), NextState = case queue:is_empty(Left) of true when MaxOverflow < 1 -> full; true -> overflow; false -> ready end, {reply, Pid, NextState, State#state{workers=Left}}; {empty, Empty} when MaxOverflow > 0 -> {Pid, Ref} = new_worker(Sup, FromPid), true = ets:insert(Monitors, {Pid, Ref}), {reply, Pid, overflow, State#state{workers=Empty, overflow=1}}; {empty, Empty} when Block =:= false -> {reply, full, full, State#state{workers=Empty}}; {empty, Empty} -> Waiting = add_waiting(From, Timeout, State#state.waiting), {next_state, full, State#state{workers=Empty, waiting=Waiting}} end; 

Checkout出一个workerworker Queue中,假设有,则monitor(ets)这个worker,然后依据队列的容量和MaxOverflow的值来确定下一状态为full。overflow,ready (ready + overflow <= full);假设没有。而MaxOverFlow的值大于0,则新建一个worker,并将其增加monitor。最后重置状态项worker = emptyoverflow = 1;假设没有,而且MaxOverflow 小于1, Block == false,则{reply, full, full, State#state{workers=Empty}};如过没有。MaxOverflow < 1Block == true,则 {next_state, full, State#state{workers=Empty, waiting=Waiting}}

Checkin

ready({checkin, Pid}, State) -> Monitors = State#state.monitors, case ets:lookup(Monitors, Pid) of [{Pid, Ref}] -> true = erlang:demonitor(Ref), true = ets:delete(Monitors, Pid), Workers = queue:in(Pid, State#state.workers), {next_state, ready, State#state{workers=Workers}}; [] -> {next_state, ready, State} end; 

Monitor中剔除相应的worker。然后回收到worker queue中去。

状态转变

状态转变的计算:

worker_queue_size(当前size) + maxoverflow 。

ready仅仅与当前worker_queque_size有关,overflow 和worker_queue_size(0)maxoverflow>0有关。full 和work_queue_size(0), overfllow = maxoverflow有关。

worker的来源

全部的worker要么在初始化时创建平;要么调用checkout时。经过poolboy创建。但此时创建的worker没有进到worker queue。要想进到worker queue,仅仅能调用checkin

work pid 回收到worker_queue中

checkin_while_full –》{empty, Empty} when MaxOverflow < 1 ->

版权声明:本文博主原创文章,博客,未经同意不得转载。

版权声明:本文内容由互联网用户自发贡献,该文观点仅代表作者本人。本站仅提供信息存储空间服务,不拥有所有权,不承担相关法律责任。如发现本站有涉嫌侵权/违法违规的内容, 请发送邮件至 举报,一经查实,本站将立刻删除。

发布者:全栈程序员-用户IM,转载请注明出处:https://javaforall.cn/117047.html原文链接:https://javaforall.cn

【正版授权,激活自己账号】: Jetbrains全家桶Ide使用,1年售后保障,每天仅需1毛

【官方授权 正版激活】: 官方授权 正版激活 支持Jetbrains家族下所有IDE 使用个人JB账号...

(0)
blank

相关推荐

  • java 中高级面试题_Java中高级面试题

    java 中高级面试题_Java中高级面试题一.基础知识:1)集合类:List和Set比较,各自的子类比较(ArrayList,Vector,LinkedList;HashSet,TreeSet);2)HashMap的底层实现,之后会问ConcurrentHashMap的底层实现;3)如何实现HashMap顺序存储:可以参考LinkedHashMap的底层实现;4)HashTable和ConcurrentHashMap的区别;5)Strin…

  • python中int的取值范围_int32的取值范围是多少?

    python中int的取值范围_int32的取值范围是多少?int32的数值取值范围为“-2147483648”到“2147483647”;而int64的数值取值范围为“-9223372036854775808”到“9223372036854775808”。int32的取值范围计算机中32位int类型变量的范围,其中int类型是带符号整数。正数在计算机中表示为原码,最高位为符号位:1的原码为000000000000000000000000000…

  • 笔记内容

    笔记内容

  • 面试被问到CAS原理,触及知识盲区,脸都绿了!

    面试被问到CAS原理,触及知识盲区,脸都绿了!CAS底层原理想要了解CAS底层原理,那么我们先来了解一下JUC包的一个类即:AtomicInteger。那么这个AtomicInteger有什么用呢?我们平时开发或多或少都会使用到i++这个操作,那么稍微了解多线程的同学都会知道,在多线程环境下,i++操作是线程不安全的操作,譬如下面这段代码:publicclassMain{privateinti=0;publicvoidaddI(){i++;}..

    2022年10月17日
  • Loadrunner教程–常用操做流程

    Loadrunner教程–常用操做流程Loadrunner教程–常用操做流程作者博客:vps精选网1loadrunner压力测试一般使用流程1.1loadrunner压力测试原理本质就是在loadrunner上模拟多个用户同时按固定行为访问web站点。其中固定行为在loadrunner中是通过录制脚本定义的,多个用户同时访问的策略是在loadrunner的场景中定义的。1.2压测思路…

  • win10 directshow无法释放_windowmode

    win10 directshow无法释放_windowmode现在单独的directshowsdk包已经没有了,从directx9.0c开始directshow和directx分开发布,现在的directshow已经集成到windowsSDK当中了,不需要单独安装。

    2022年10月12日

发表回复

您的电子邮箱地址不会被公开。

关注全栈程序员社区公众号