Mix XWP V1.1 - Go 通用动态协程池 WorkerPool-低调大师

Mix XWP V1.1 - Go 通用动态协程池 WorkerPool

2021-04-26 692

OpenMix 出品：https://openmix.org

Mix XWP

通用的工作池

A common worker pool

Installation

go get github.com/mix-go/xwp

Usage

先创建一个结构体用来处理任务，使用类型断言转换任务数据类型，例如：i := data.(int)

type Foo struct {
}

func (t *Foo) Do(data interface{}) {
    // do something
}

调度任务

也可以使用 RunF 采用闭包来处理任务
如果不想阻塞执行，可以使用 p.Start() 启动

jobQueue := make(chan interface{}, 200)

p := &xwp.WorkerPool{
    JobQueue:       jobQueue,
    MaxWorkers:     1000,
    InitWorkers:    100,
    MaxIdleWorkers: 100,
    RunI:           &Foo{},
}

go func() {
    // 投放任务
    for i := 0; i < 10000; i++ {
        jobQueue <- i
    }

    // 投放完停止调度
    p.Stop()
}()

p.Run() // 阻塞等待

异常处理：Do 方法中执行的代码，可能会出现 panic 异常，我们可以通过 recover 获取异常信息记录到日志或者执行其他处理

func (t *Foo) Do(data interface{}) {
    defer func() {
        if err := recover(); err != nil {
            // handle error
        }
    }()
    // do something
}

查看 Workers 的执行状态：通常可以使用一个定时器，定时打印或者告警处理

go func() {
    ticker := time.NewTicker(1000 * time.Millisecond)
    for {
        <-ticker.C
        log.Printf("%+v", p.Stat()) // 2021/04/26 14:32:53 &{Active:5 Idle:95 Total:100}
    }
}()

License

Apache License Version 2.0, http://www.apache.org/licenses/

微信关注我们

原文链接：https://www.oschina.net/news/139179/mix-wxp-1-1-released

转载内容版权归作者及来源网站所有！

低调大师中文资讯倾力打造互联网数据资讯、行业资源、电子商务、移动互联网、网络营销平台。持续更新报道IT业界、互联网、市场资讯、驱动更新,是最及时权威的产业资讯及硬件资讯报道平台。

erupt 1.6.16 已经发布，通用后台管理框架

erupt 1.6.16 已经发布，这是一个通用后台管理框架。此版本更新内容包括： 1.6.16（2021年04月24日） • 修复Redis Hash缓存不释放的bug，感谢 cycmy2001 提供的Issue #I3J5T7 • 修复多数据源，查询时，连接不释放的bug • 修复CODE_EDITOR在树视图下不能正常使用bug • 修复HTML_EDITOR在树视图下数据脏读的bug 详情查看：https://gitee.com/erupt/erupt/releases/1.6.16

2021-04-26

616

更新内容本周主要新增了部分特性，并修复了一些组件的 🐛Bug，继续提升 Hyperf 的稳定性，发布于 2.1.16 版。建议用户使用以下命令更新此版本。 composer update "hyperf/*" -o 直接访问官网 hyperf.io 或文档 hyperf.wiki 查看更新内容修复 #3510 修复 consul 无法将节点强制离线的问题。 #3513 修复 Nats 因为 Socket 超时时间小于最大闲置时间，导致连接意外关闭的问题。 #3520 修复 @Inject 无法作用于嵌套 Trait 的问题。新增 #3514 新增方法 Hyperf\HttpServer\Request::clearStoredParsedData()。优化 #3517 优化 Hyperf\Di\Aop\PropertyHandlerTrait。关于 Hyperf Hyperf 是基于 Swoole 4.5+ 实现的高性能、高灵活性的 PHP 协程框架，内置协程服务器及大量常用的组件，性能较传统基于 PHP-FPM 的框架有质的提升，提供超高性能的同时，也保持着极...

2021-04-26

667

资源下载

更多资源

Mario

马里奥是站在游戏界顶峰的超人气多面角色。马里奥靠吃蘑菇成长，特征是大鼻子、头戴帽子、身穿背带裤，还留着胡子。与他的双胞胎兄弟路易基一起，长年担任任天堂的招牌角色。

Spring

Spring框架（Spring Framework）是由Rod Johnson于2002年提出的开源Java企业级应用框架，旨在通过使用JavaBean替代传统EJB实现方式降低企业级编程开发的复杂性。该框架基于简单性、可测试性和松耦合性设计理念，提供核心容器、应用上下文、数据访问集成等模块，支持整合Hibernate、Struts等第三方框架，其适用范围不仅限于服务器端开发，绝大多数Java应用均可从中受益。

Rocky Linux

Rocky Linux（中文名：洛基）是由Gregory Kurtzer于2020年12月发起的企业级Linux发行版，作为CentOS稳定版停止维护后与RHEL（Red Hat Enterprise Linux）完全兼容的开源替代方案，由社区拥有并管理，支持x86_64、aarch64等架构。其通过重新编译RHEL源代码提供长期稳定性，采用模块化包装和SELinux安全架构，默认包含GNOME桌面环境及XFS文件系统，支持十年生命周期更新。

WebStorm

WebStorm 是jetbrains公司旗下一款JavaScript 开发工具。目前已经被广大中国JS开发者誉为“Web前端开发神器”、“最强大的HTML5编辑器”、“最智能的JavaScript IDE”等。与IntelliJ IDEA同源，继承了IntelliJ IDEA强大的JS部分的功能。