Directories ¶
Path | Synopsis |
---|---|
chan实现trylock乐观锁
|
chan实现trylock乐观锁 |
* golang nsq消费队列封装,提供如下功能点 1、初始化生产者 2、初始化消费者 3、提供不同方式的消费者消费模式 4、当调用InitProducer,InitConsumer后可以直接调用nsq上底层方法 也可以使用本包提供的方法,其实也是调用nsq底层方法 5、关于优雅退出生产者和消费者,请看nsq_test.go 6、通过直接连接到nsqd进行消费,速度快,但不方便拓展,建议通过lookupd查找节点进行消费
|
* golang nsq消费队列封装,提供如下功能点 1、初始化生产者 2、初始化消费者 3、提供不同方式的消费者消费模式 4、当调用InitProducer,InitConsumer后可以直接调用nsq上底层方法 也可以使用本包提供的方法,其实也是调用nsq底层方法 5、关于优雅退出生产者和消费者,请看nsq_test.go 6、通过直接连接到nsqd进行消费,速度快,但不方便拓展,建议通过lookupd查找节点进行消费 |
package gqueue 通过指定goroutine个数,实现task queue执行器 提交任务到tash chan中,然后不断从chan中取出task执行 结合官方的sync.WaitGroup计数信号等待执行完毕 go goroutine非抢占式的,通过runtime.Gosched()让出cpu给其他goroutine
|
package gqueue 通过指定goroutine个数,实现task queue执行器 提交任务到tash chan中,然后不断从chan中取出task执行 结合官方的sync.WaitGroup计数信号等待执行完毕 go goroutine非抢占式的,通过runtime.Gosched()让出cpu给其他goroutine |
Package grecover catch exec panic.
|
Package grecover catch exec panic. |
Package gresty for go http client support get,post,delete,patch,put,head,file method.
|
Package gresty for go http client support get,post,delete,patch,put,head,file method. |
file 文件相关的一些辅助函数 str_convert 字符串,数字相互转换的一些辅助函数 Package of gutils common function.
|
file 文件相关的一些辅助函数 str_convert 字符串,数字相互转换的一些辅助函数 Package of gutils common function. |
package jsontime fix time.Time json encode/decode bug.
|
package jsontime fix time.Time json encode/decode bug. |
Package logger for log interface logger 基于zap日志库,进行封装的logger库 支持日志自动切割
|
Package logger for log interface logger 基于zap日志库,进行封装的logger库 支持日志自动切割 |
* * Package mutexlock mutex trylock.
|
* * Package mutexlock mutex trylock. |
* Package mysql of gorm library.
|
* Package mysql of gorm library. |
* Package runner 用于按照顺序,执行程序任务操作,可作为cron作业或定时任务 runner 包可用于展示如何使用通道来监视程序的执行时间,如果程序运行时间太长,指定任务执行时间。
|
* Package runner 用于按照顺序,执行程序任务操作,可作为cron作业或定时任务 runner 包可用于展示如何使用通道来监视程序的执行时间,如果程序运行时间太长,指定任务执行时间。 |
利用无缓冲chan创建goroutine池来控制一组task的执行 1.
|
利用无缓冲chan创建goroutine池来控制一组task的执行 1. |
Package workpool for do task in work pool.
|
Package workpool for do task in work pool. |
*Package of xerrors 自定义错误类型,一般用在api/微服务等业务逻辑中,处理错误 支持是否输出堆栈信息,可以把stack信息记录到日志文件中,方便定位问题
|
*Package of xerrors 自定义错误类型,一般用在api/微服务等业务逻辑中,处理错误 支持是否输出堆栈信息,可以把stack信息记录到日志文件中,方便定位问题 |
Click to show internal directories.
Click to hide internal directories.