ants

ants copied to clipboard

Ants + fasthttp

16

Hello, I am using Ants with fasthttp. Is it possible that this both packages are not compatible? My Program fetchs 15000 rows from a MysqlDB and request the HTML code...

T200proX7

add support for Run(ctx) interface

1

--- name: Pull request about: Add support for Run(ctx) interface --- ## 1. Are you opening this pull request for bug-fixs, optimizations or new feature? yes This is a pr...

godcong

关于pool使用的自旋锁的性能问题

2

我看到pool用的是自己实现的自旋锁,而不是mutex,有点好奇性能,然后做了下性能测试: ```go 自旋锁版: goos: linux goarch: amd64 pkg: github.com/panjf2000/ants/v2 cpu: Intel(R) Xeon(R) Platinum 8269CY CPU @ 2.50GHz BenchmarkGoroutines-2 10 113619133 ns/op 8000001 B/op 100000 allocs/op BenchmarkAntsPool-2 9 114800650 ns/op 2349845...

AlespRless

**What is your question about ants?** Please describe your question meticulously. stack或者loopQueue两种结构性能上和功能上都可以改造成一样的效果 为何需要两种数据结构？

geeklingithub

fix issue https://github.com/panjf2000/ants/issues/244

cuishuang

提议：新增 ReleaseWaitAllWorkersExit()，用于等待所有worker都被释放后再返回

5

由于ants中var defaultAntsPool, _ = NewPool(DefaultAntsPoolSize)，会在使用到该库的项目初始化时，先于项目的main.go执行，从而会多出一个协程； 很多项目单测中集成了go.uber.org/goleak，用于检测goroutine泄露，从而会导致测试失败，如下图：  查看ants代码，发现有一个Release()方法，可以释放掉worker，但释放需要一定时间，只能休眠一个足够长的时间(经验值是1s左右)   建议新增一个 ReleaseWaitAllWorkersExit()方法，调用后，确保所有worker都释放后才返回  另外几个可能相关的issue： https://github.com/panjf2000/ants/issues/212 https://github.com/panjf2000/ants/issues/225 --- related pr：https://github.com/panjf2000/ants/pull/245

cuishuang

提个建议: 增加拒绝策略

1

java的 threadPoolExecutor里面有拒绝策略。其中callerRunsPolicy能够让 被池子拒绝的任务交给调用者自己执行 一些比较重要的任务是不希望被池子拒绝后丢弃的 希望ants pool也可以加一个这样的东西

Yballul

Multiple Arguments Pool Function

4

… Invoke function without explicitly creating an array --- name: Pull request about: Propose changes to the code title: 'Multiple arguments pool func' labels: '' assignees: '' --- ## 1....

void-developer

[Bug]: 设置了ants.WithExpiryDuration(5*time.Second) 没起作用，导致pool满后一直未释放worker，阻塞新task

1

### Actions I've taken before I'm here - [X] I've thoroughly read the documentations on this issue but still have no clue. - [X] I've searched the current list of...

wowo666

fix(pool): ensure proper lock handling in retrieveWorker

1

Correct the logic for locking the pool in the retrieveWorker function to prevent potential data races and deadlocks. The lock is now deferred until the end of the function, with...

gou-jjjj