Repository navigation

#

disruptor

High Performance Inter-Thread Messaging Library

Java
17948
5 个月前

Flux is a high-performance message transport library for Rust that implements patterns inspired by LMAX Disruptor and Aeron. It provides lock-free inter-process communication (IPC), UDP transport, and reliable UDP with optimized memory management for applications with low latency requirements.

Rust
746
23 天前

NetDiscovery 是一款基于 Vert.x、RxJava 2 等框架实现的通用爬虫框架/中间件。

Java
644
5 年前

Disruptor BlockingQueue

Java
317
6 个月前

Basic implementation of Disruptor for Unity3d

C#
200
8 年前

分布式多租户的支持流程编排的任务调度平(QQ群:1029617143,预览地址账号preview密码123456)

Java
176
2 年前

High performance game server framework by netty and disruptor

Java
165
7 年前

A disruptor thread-synchronisation data structure for C++11.

C++
134
2 年前

A port of the LMAX Disruptor to Rust

Rust
110
2 年前

Vibur Object Pool - general-purpose concurrent Java object pool

Java
79
7 个月前

Example LMAX Disruptor spring-boot project that uses disruptor-spring-manager framework

Java
70
8 年前

个人java/csharp公共包,集合库,并发库,行为树,Dson文本...

C#
42
8 小时前

即时通信聊天 基于netty+disruptor构建

Java
35
3 年前

采用Reactor模式,注册readycreate, readyfinish事件到更新服务UpdateService,通过处理后进行模型缓存,然后将消息转化为 dispatchThread消息分配模型需要的create, update, finish的事件进行单线程循环调度 。调度过程使用了系统预置锁模型,来进行多线程唤醒机制,将所有的update循环检测进行多 线程调度,多线程更新服务使用future-listener机制,在完成调度后,根据模型状态,如果模型存活重新将消息转化为update 事件注册到dispatchThread消息分配模型进行循环处理。如果模型死亡将消息转化为readyfinish事件注册到更新服务UpdateServic进行销毁 。这个系统实现了模型自动缓存,多线程异步循环调度模型更新,自动处理模型死亡事件进行销毁。 支持将多个updater绑定到同一个更新线程上,减少线程调度。

Java
32
8 年前

disruptor c++ implementation for IPC

C++
32
7 个月前

分布式的,可靠的,实时的,可扩展的, 易用的,轻量级的 基于本地消息实现的EventBus事件总线(Distributed, reliable, real-time, scalable, easy-to-use, lightweight, EventBus event bus implemented based on local messages)

Java
24
23 天前