6 Repos
Awesome GitHub RepositoriesMessaging Queues
Mechanisms for passing data between execution units using thread-safe or process-safe messaging structures.
Distinct from Shared Memory Data Exchange: Distinct from Shared Memory Data Exchange: focuses on message-passing coordination rather than raw memory buffer sharing.
Explore 6 awesome GitHub repositories matching data & databases · Messaging Queues. Refine with filters or upvote what's useful.
Awesome Messaging Queues GitHub Repositories
Finde die besten Repos mit KI.Wir suchen mit KI nach den am besten passenden Repositories.
- walter201230/python
walter201230/Python
26,516Auf GitHub ansehenPython is a high-level, interpreted programming language designed for readability and versatility. It operates via a bytecode-based virtual machine and manages memory automatically through reference-counting garbage collection. The language supports multiple programming paradigms, including object-oriented, imperative, and functional styles, and provides a comprehensive standard library for system operations, networking, and data handling. The language is distinguished by its dynamic nature, allowing for runtime object introspection and metaclass-driven class creation. It utilizes protocol-ba
Python facilitates data exchange between threads or processes using messaging mechanisms to coordinate work and share results across execution units.
Pythonpythonpython3 - mastra-ai/mastra
mastra-ai/mastra
21,221Auf GitHub ansehenMastra is an orchestration framework designed for building, deploying, and managing autonomous AI agents and multi-agent systems. It provides a comprehensive suite of primitives for creating resilient AI applications, including durable workflow orchestration, event-driven agent loops, and semantic memory management. By integrating these core components, the platform enables developers to build complex, multi-step processes that can reason about goals and execute tasks without manual intervention. The framework distinguishes itself through its focus on observability and secure, isolated execut
Provides mechanisms for queuing and sequencing agent messages to ensure orderly task execution on shared threads.
TypeScriptagentsaichatbots - codebasics/py
codebasics/py
7,262Auf GitHub ansehenThis project is a Python data science curriculum and programming tutorial collection. It provides a structured set of educational notebooks and scripts designed to teach data analysis, machine learning, and deep learning. The repository serves as a learning path for building and tuning predictive models, including regression, decision trees, and neural networks. It includes a data visualization guide for creating financial time-series plots and a multiprocessing reference for implementing parallel task execution and shared memory synchronization. The curriculum covers broader capability area
Implements thread-safe and process-safe messaging structures for passing data between execution units.
Jupyter Notebookjupyterjupyter-notebookjupyter-notebooks - loopbackio/loopback-next
loopbackio/loopback-next
5,095Auf GitHub ansehenLoopBack Next is a Node.js API framework used for building REST and multi-protocol APIs. It functions as an OpenAPI server implementation that can either generate machine-readable specifications from code or produce implementation controllers and models from existing specifications. The framework distinguishes itself through a central dependency injection container and a repository-pattern data access layer. This architecture decouples application logic from component construction and persistent storage, allowing for a pluggable system where data sources and business logic are isolated throug
Provides producers and consumers to exchange data asynchronously via message queues.
TypeScript - zio/zio
zio/zio
4,347Auf GitHub ansehenZIO is a functional effect system for the JVM that models asynchronous and concurrent programs as pure, composable values with typed error handling and dependency injection. Its core identity is built on fiber-based concurrency, where lightweight, non-blocking fibers execute millions of concurrent tasks with structured lifecycle management, and a dual-channel error model that separates expected business failures from unexpected system defects at compile time. The system provides effect-typed dependency injection through a layer-based dependency graph, pull-based reactive stream processing with
ZIO transfers data between concurrent producers and consumers using an asynchronous, non-blocking queue.
Scalaasynchronicityasynchronousasynchronous-programming - davyxu/cellnet
davyxu/cellnet
4,061Auf GitHub ansehenCellnet ist ein Go-Netzwerk-Framework, das für den Aufbau verteilter Systeme und Peer-to-Peer-Netzwerke entwickelt wurde. Es bietet einen Multi-Protokoll-Transport-Layer, der den Nachrichtenaustausch über TCP, UDP und WebSockets standardisiert, und nutzt ein binäres Nachrichten-Codec-System, um Nachrichtentypen auf eindeutige Identifikatoren für die Netzwerkübertragung abzubilden. Das Framework zeichnet sich durch seine Remote-Procedure-Call-Bibliothek aus, die die Ausführung von Funktionen auf Remote-Peers unter Verwendung synchroner oder asynchroner Request-Muster ermöglicht. Es differenziert sich zudem durch einen asynchronen Event-Dispatcher, der Netzwerk-Callbacks über ein sequentielles Ausführungsmodell verarbeitet, um Nebenläufigkeit und Thread-Sicherheit zu verwalten. Zu seinen breiteren Fähigkeiten gehören die Entwicklung benutzerdefinierter Netzwerkprotokolle durch steckbare Serialisierungs-Codecs, automatisiertes Peer-Verbindungsmanagement mit Session-Tracking und Wiederverbindungslogik sowie ein handlerbasiertes Routing-System zur Steuerung des Netzwerkverkehrs. Es integriert zudem Tools für das Monitoring der Peer-Gesundheit, das Logging des Netzwerkverkehrs und das Bereitstellen von Dateien über HTTP.
Implements thread-safe message queues that block receiving processes until data is available.
Go
