45 रिपॉजिटरी
Coordination of shared resource access within asynchronous handlers using locks or semaphores.
Distinct from Concurrent Execution Managers: Distinct from Concurrent Execution Managers: focuses on resource-level locking within handlers rather than general workflow concurrency.
Explore 45 awesome GitHub repositories matching software engineering & architecture · Asynchronous Concurrency Managers. Refine with filters or upvote what's useful.
PrivateGPT is a private AI document assistant and local knowledge base manager designed for querying private files and documents using retrieval-augmented generation. It functions as a local language model application and API gateway, allowing users to obtain cited answers from unstructured data without sending information to external servers. The system differentiates itself by acting as a tool integrator that connects language models to external functions, including web search, tabular data analysis, and custom action extensions. It provides a standardized API layer that allows local infere
Processes long-running model tasks concurrently using asynchronous patterns to maintain application responsiveness.
Guava is a Java standard library extension and utility toolkit that provides optimized data structures, concurrency tools, and core extensions. It serves as a comprehensive set of helpers for Java development, focusing on reducing repetitive boilerplate logic. The project is distinguished by its specialized implementations of immutable collections, which ensure thread safety and data consistency by preventing accidental modification. It also includes a dedicated graph data structure library for modeling and traversing networks of interconnected nodes and edges, alongside advanced collection t
Implements high-level utilities for managing shared resources and coordinating asynchronous tasks using futures.
This project is a software engineering educational resource providing a collection of canonical system implementations. It serves as a library of computer science case studies and polyglot code examples designed to demonstrate architectural tradeoffs and design patterns through concise versions of fundamental software components. The repository focuses on studying the implementation of core concepts such as consensus algorithms, interpreters, and database engines. It provides minimal versions of complex systems to facilitate the analysis of language design, data structure implementation, and
Utilizes asynchronous patterns to process concurrent HTTP requests through a minimal server.
Headroom is an AI gateway proxy and token optimizer designed to reduce the cost and latency of large language model interactions. It functions as an intermediary that intercepts traffic between clients and providers to apply context compression, request routing, and format translation. The system differentiates itself through a Model Context Protocol server implementation that delivers compression and retrieval tools to compatible AI hosts. It employs a content-aware compression pipeline and tiered importance scoring to trim redundant data from logs and tool outputs while preserving essential
Implements a concurrency cap to prevent request storms from interfering with system health checks.
Rollup is an ES module bundler and JavaScript module transpiler. It functions as a build tool that combines JavaScript modules into optimized files and converts modern JavaScript and JSX into various output formats for different runtime environments. The project is distinguished by its static-analysis tree shaking engine, which removes unused code and dead exports to minimize bundle size. It also acts as a code splitting orchestrator, partitioning modules into separate chunks to optimize network requests and load times. The tool provides a hook-based plugin system for extending build logic,
Implements mechanisms to limit simultaneous file system operations to prevent resource exhaustion during the build process.
proxyee-down is an HTTP proxy download manager and multi-threaded download client. It is designed to route file download requests through an HTTP proxy server to accelerate data retrieval and bypass network restrictions. The tool increases transfer speeds by splitting large files into smaller chunks and downloading them concurrently across multiple TCP connections. It features the ability to update expired or changed source URLs for existing tasks, allowing interrupted downloads to recover and resume without losing previously downloaded segments. The system provides controls for manual downl
Implements an asynchronous event loop to handle multiple network streams concurrently for high-throughput data retrieval.
Hystrix is a latency and fault tolerance library designed to prevent cascading failures in distributed systems. It functions as a circuit breaker implementation that monitors failure thresholds and opens circuits to isolate remote calls when downstream services degrade. The project distinguishes itself by providing multiple isolation mechanisms, utilizing dedicated thread pools and semaphores to ensure that latency in one dependency does not saturate the entire system. It also features a request collapsing and batching engine that groups concurrent calls into single executions to reduce the t
Optimizes throughput by executing requests in parallel and collapsing concurrent calls into single batches.
Vector is a high-performance observability data pipeline designed to collect, transform, and route logs, metrics, and traces across distributed infrastructure. It functions as a modular engine that decouples data ingestion from processing and transmission, utilizing a component-based architecture to connect diverse sources to multiple destinations. The project distinguishes itself through a focus on reliability and flow control. It implements backpressure-aware data movement to prevent data loss during traffic spikes and utilizes disk-backed event buffering to ensure durability during network
Optimizes throughput by automatically adjusting request concurrency based on downstream service feedback.
Temporal is a distributed workflow orchestration engine designed to manage fault-tolerant, stateful, and long-running background processes. It functions as a platform for coordinating complex cross-service operations, ensuring consistency and reliability in distributed environments by decoupling workflow orchestration from task execution. The platform distinguishes itself through a deterministic, event-sourced execution model that reconstructs workflow state by re-executing code from an immutable event log. This approach isolates non-deterministic side effects into managed activities, allowin
Coordinates access to shared resources within asynchronous handlers using locks or semaphores to prevent race conditions during execution.
This project is an educational framework designed to teach the fundamentals of building core distributed systems and web services from scratch in Go. It provides a collection of modular implementations that demonstrate how to construct essential infrastructure components, including web servers, remote procedure call systems, distributed caches, and database abstraction layers. The framework distinguishes itself by focusing on the internal mechanics of these systems rather than providing a high-level abstraction for production use. It covers the implementation of complex architectural patterns
The framework handles multiple simultaneous requests from clients using asynchronous processing to maintain high throughput and responsiveness during network communication.
This project is a comprehensive framework for engineering financial data pipelines, designed to automate the collection, cleaning, and synchronization of large-scale market datasets. It functions as a quantitative trading data engine, providing the infrastructure necessary to manage historical and real-time asset pricing information for research and machine learning workflows. The system distinguishes itself through a configuration-driven approach to orchestration, allowing users to manage complex data acquisition tasks across multiple financial providers. It features resilient middleware tha
Downloads financial data for multiple assets simultaneously using asynchronous batch processing.
Akka Core is an actor model framework and asynchronous concurrency library used for building scalable and resilient distributed systems. It provides a distributed computing platform and fault tolerant runtime that manages communication and state across networked nodes. The system uses location-transparent messaging and a cluster management system to organize nodes into high-availability architectures. This allows for the creation of elastic clusters that scale resources on demand and coordinate distributed workloads. The platform handles concurrent state management and distributed systems or
Implements lock-free state management using sequential message processing to handle multi-threaded logic safely.
Akka is an actor model framework and distributed systems platform used to build concurrent and distributed applications. It provides a toolkit for managing multi-threaded state and behavior through asynchronous message passing, allowing developers to create concurrent applications without manual locks or synchronization. The system functions as a cluster management and event sourcing framework, automating the scaling and coordination of high-availability clusters. It enables the deployment of elastic services that coordinate workloads across multiple network nodes and ensures fault tolerance
Manages multi-threaded state through asynchronous message passing to eliminate manual locks and memory visibility issues.
CrowdSec is a collaborative, distributed security engine designed for threat detection and infrastructure protection. It functions as an intrusion detection system that parses logs and network traffic to identify malicious patterns, utilizing a bucket-based threshold detection model to aggregate events and trigger alerts. The platform is built on a modular architecture that includes a centralized local API server for managing security signals and a relational database for persistent storage of remediation decisions. What distinguishes the project is its decoupled enforcement model, which offl
Inspects complex threats asynchronously to identify malicious intent without introducing latency to user sessions.
F Prime एक कंपोनेंट-आधारित फ्रेमवर्क है जिसे एम्बेडेड और स्पेसफ्लाइट सॉफ्टवेयर के विकास और परिनियोजन (deployment) के लिए डिज़ाइन किया गया है। यह एक मॉड्यूलर आर्किटेक्चर प्रदान करता है जो सॉफ्टवेयर लॉजिक को कम्युनिकेशन इंटरफेस से अलग करता है, जिससे डेवलपर्स को डोमेन-विशिष्ट मॉडलिंग भाषा के माध्यम से सिस्टम संरचनाओं को परिभाषित करने की अनुमति मिलती है। यह मॉडल-आधारित दृष्टिकोण स्वचालित कोड जनरेशन को सक्षम बनाता है, जो जटिल सिस्टम टोपोलॉजी में निरंतरता सुनिश्चित करता है और सॉफ्टवेयर मॉड्यूल के बीच सख्त इंटरफेस अनुबंधों को बनाए रखता है। यह फ्रेमवर्क अपने एकीकृत बिल्ड सिस्टम और ग्राउंड डेटा ऑपरेशंस सूट के माध्यम से खुद को अलग करता है। यह एम्बेडेड सॉफ्टवेयर के पूरे जीवनचक्र को स्वचालित करता है, क्रॉस-कंपाइलेशन और डिपेंडेंसी मैनेजमेंट से लेकर टेलीमेट्री और कमांड इंटरफेस के जनरेशन तक। ऑनबोर्ड फ्लाइट सॉफ्टवेयर और ग्राउंड-आधारित मॉनिटरिंग दोनों के लिए एक एकीकृत वातावरण प्रदान करके, यह विविध हार्डवेयर प्लेटफॉर्मों पर वितरित एम्बेडेड सिस्टम के निर्बाध एकीकरण, परीक्षण और कमांड-एंड-कंट्रोल की सुविधा प्रदान करता है। अपने मुख्य आर्किटेक्चर से परे, इस प्रोजेक्ट में सिस्टम ऑब्जर्वेबिलिटी के लिए व्यापक उपकरण शामिल हैं, जिनमें रीयल-टाइम टेलीमेट्री विज़ुअलाइज़ेशन, इवेंट लॉगिंग और डायग्नोस्टिक ट्रेसिंग शामिल हैं। यह बेयर-मेटल वातावरण से लेकर रीयल-टाइम ऑपरेटिंग सिस्टम तक, परिनियोजन परिदृश्यों की एक विस्तृत श्रृंखला का समर्थन करता है, और मेमोरी मैनेजमेंट, स्टेट-ड्रिवन व्यवहार मॉडलिंग, और एसिंक्रोनस टास्क निष्पादन के लिए तंत्र प्रदान करता है। यह प्रोजेक्ट एक C++ रिपॉजिटरी के रूप में बनाए रखा गया है, जिसमें व्यापक डॉक्यूमेंटेशन और क्रॉस-प्लेटफॉर्म विकास के लिए बिल्ड-सिस्टम सपोर्ट शामिल है।
Separates requests from responses using distinct ports to allow asynchronous processing.
Micro is a Node.js HTTP microservices framework used to build asynchronous web servers. It enables the creation of lightweight services that handle requests and responses through single-purpose functions to reduce operational footprint and latency. The framework functions as a JSON API backend and a WebSocket communication server, allowing for the establishment of bidirectional socket connections for real-time data updates and instant messaging. Its capability surface covers HTTP request processing, including the parsing of JSON and URL-encoded request bodies. It also supports external API i
Provides asynchronous request handlers to process multiple client requests concurrently for high throughput.
KEDA is a Kubernetes event-driven autoscaler and cloud event scaling engine. It functions as a custom metrics provider that monitors external event sources—including message brokers, databases, and cloud metrics—to dynamically adjust the replica counts of containerized workloads. The project is distinguished by its scale-to-zero workflow, which reduces workloads to zero replicas during inactivity and automatically restarts them when new events are detected. It operates as a multi-cloud event trigger system, using a pluggable scaler interface to integrate with a wide array of third-party servi
Optimizes processing throughput by limiting the number of concurrent reconciliation loops.
Warp is a Rust HTTP web framework designed for building high-performance web servers. It provides a system for managing request pipelines, implementing WebSocket servers for bidirectional communication, and serving static assets from the local filesystem. The framework is characterized by its use of type-safe request pipelines and routing. It utilizes a filter-based approach to extract and validate metadata from headers, query strings, and request bodies before they reach the application handler. Broad capability areas include HTTP API development, asynchronous task execution, and state-base
Processes concurrent HTTP requests and WebSocket connections using non-blocking asynchronous tasks via the Tokio runtime.
Falcon is a minimalist Python web API framework and high-performance microservices framework. It serves as a resource-oriented API toolkit designed for building RESTful APIs and data plane services that prioritize low overhead, reliability, and scale. The framework implements an ASGI web server interface to handle both synchronous and asynchronous HTTP requests and WebSockets. It features a dedicated HTTP middleware system for intercepting network traffic and executing shared processing logic across multiple API endpoints. Its capability surface covers resource-based routing, HTTP specificat
Handles concurrent connections and WebSocket communications using asynchronous request handlers to improve throughput.
Actix is a Rust actor framework and concurrent programming toolkit designed for building applications that manage state through an asynchronous messaging system. It provides a model where independent actors serve as autonomous units of state and logic, communicating via strongly typed messages sent to unique addresses. The framework distinguishes itself by isolating state within these actors, allowing internal data to be mutated safely during message handling without the use of locks or mutexes. It employs an asynchronous mailbox system to buffer incoming requests and uses supervision strateg
Manages shared state across asynchronous tasks using message passing to eliminate manual locking primitives.