腾讯云开发者社区-腾讯云

开发者社区

文档建议反馈控制台

最新优惠活动

文章/答案/技术大牛

发布

码匠的流水账

专栏作者

2402

文章

1903685

阅读量

65

订阅数

聊聊xxl-job-executor-go

linux android go 任务调度

xxl-job-executor-go的Executor定义了Init、LogHandler、RegTask、RunTask、KillTask、TaskLog、Run方法；executor实现了Executor接口，并提供了http的api接口。

2021-04-29

9620

聊聊go.cqrs的EventHandler

android 编程算法 html

go.cqrs的EventHandler定义了Handle方法；InternalEventBus的PublishEvent方法会遍历指定event.EventType()的handlers，挨个执行handler.Handle(event)方法。

2021-04-16

4640

聊聊go.cqrs的Dispatcher

编程算法 android

go.cqrs的Dispatcher接口定义了Dispatch、RegisterHandler方法；InMemoryDispatcher定义了map[string]CommandHandler属性，其Dispatch方法根据command.CommandType()获取handler，然后执行handler.Handle(command)；其RegisterHandler方法遍历commands，然后获取command的type，挨个注册到map[string]CommandHandler中。

2021-04-16

3020

聊聊machinery的TaskProcessor

machinery的TaskProcessor接口定义了Process、CustomQueue、PreConsumeHandler方法。Worker实现了TaskProcessor接口，其Process方法先通过worker.server.GetRegisteredTask获取taskFunc，然后通过signature更新state为RECEIVED，之后设置为STARTED，之后执行task.Call()，最后根据结果更新task为failed或者success。

2021-04-16

5600

聊聊eventhorizon的EventBus

eventhorizon的EventBus接口内嵌了EventHandler接口，定义了AddHandler、Errors、Wait方法。

2021-04-16

5180

聊聊eventhorizon的Aggregate

eventhorizon/aggregatestore/model/aggregatestore.go

2021-04-16

4450

聊聊cheddar的MessageHandlerExecutor

android java jquery processing

Cheddar/cheddar/cheddar-messaging/src/main/java/com/clicktravel/cheddar/infrastructure/messaging/pooled/listener/MessageHandlerExecutor.java

2021-04-16

2340

聊聊cheddar的PendingResult

java android jquery 网站

Cheddar/cheddar/cheddar-application/src/main/java/com/clicktravel/cheddar/application/pending/result/PendingResult.java

2021-04-16

2270

聊聊cheddar的DomainEvent

android java jquery 面向对象编程

Cheddar/cheddar/cheddar-domain/src/main/java/com/clicktravel/cheddar/domain/event/DomainEvent.java

2021-04-16

2760

聊聊cheddar的events

java jquery android

Cheddar/cheddar/cheddar-events/src/main/java/com/clicktravel/cheddar/event/Event.java

2021-03-27

3640

聊聊cortex的Ingester

android go vr 视频解决方案 api 网络安全

cortex的Ingester接口内嵌了client.IngesterServer，定义了FlushHandler、ShutdownHandler、Push方法；Ingester实现了Ingester接口。

2021-02-08

5800

聊聊RespServer

java 云数据库 Redis android github git

resp-server-0.16.0/src/main/java/com/github/tonivade/resp/Resp.java

2020-08-21

2900

聊聊dubbo-go的TpsLimitFilter

dubbo go android php

dubbo-go-v1.4.2/filter/filter_impl/tps_limit_filter.go

2020-07-21

2210

聊聊dubbo-go的gracefulShutdownFilter

dubbo android go bash bash 指令

dubbo-go-v1.4.2/filter/filter_impl/graceful_shutdown_filter.go

2020-07-21

2740

聊聊kingbus的startRaftPeer

android go php raft

startRaftPeer方法根据peerURLs通过s.raftNode.NewPeerListener开启listener，之后执行s.raftNode.SetPeerHandler()、s.raftNode.PeerHandlerServe()

2020-06-18

2420

聊聊kingbus的startAdminServer

go android api php 网站

startAdminServer方法主要是执行api.NewAdminServer；NewAdminServer创建adminServer，并设置了MembershipHandler、BinlogSyncerHandler、BinlogServerHandler

2020-06-17

3000

聊聊kingbus的startAdminServer

android go api php 网站

startAdminServer方法主要是执行api.NewAdminServer；NewAdminServer创建adminServer，并设置了MembershipHandler、BinlogSyncerHandler、BinlogServerHandler

2020-06-15

4040

聊聊kingbus的startRaftPeer

android go php raft

startRaftPeer方法根据peerURLs通过s.raftNode.NewPeerListener开启listener，之后执行s.raftNode.SetPeerHandler()、s.raftNode.PeerHandlerServe()

2020-06-14

2720

聊聊puma的DefaultTaskExecutor

mac os java unix android 网络安全

puma/puma/src/main/java/com/dianping/puma/taskexecutor/TaskExecutor.java

2020-06-09

5790

聊聊puma的DefaultDataHandler

android mac os java 数据库一体机 TData 网络安全

puma/puma/src/main/java/com/dianping/puma/datahandler/DataHandler.java

2020-06-09

3580

点击加载更多

社区活动

腾讯技术创作狂欢月

“码”上创作 21 天，分 10000 元奖品池！

Python精品学习库

代码在线跑，知识轻松学

博客搬家 | 分享价值百万资源包

自行/邀约他人一键搬运博客，速成社区影响力并领取好礼

技术创作特训营·精选知识专栏

往期视频·千货材料·成员作品最新动态