awesome-repositories.com

Descoperă cele mai bune repository-uri open source cu căutare AI.

ExploreazăCăutări recomandateOpen-source alternativesSelf-hosted softwareBlogHartă site
ProiectDespreHow we rankPresăServer MCP
LegalConfidențialitateTermeni
© 2026 Bringes Technology SRL·VAT RO45896025·hello@awesome-repositories.com
·
awesome-repositories.comBlog
Categorii

25 repository-uri

Awesome GitHub RepositoriesHigh-Throughput Task Processing

Architectures designed to process a massive volume of asynchronous jobs with minimal resource overhead.

Distinct from High-Throughput Data Streaming: Existing candidates are too domain-specific (audio, indexing, financial) rather than general-purpose task processing.

Explore 25 awesome GitHub repositories matching software engineering & architecture · High-Throughput Task Processing. Refine with filters or upvote what's useful.

Awesome High-Throughput Task Processing GitHub Repositories

Găsește cele mai bune repo-uri cu AI.Vom căuta cele mai potrivite repository-uri folosind AI.
  • panjf2000/antsAvatar panjf2000

    panjf2000/ants

    14,436Vezi pe GitHub↗

    Ants is a goroutine pool library for Go that functions as a concurrent task orchestrator and resource consumption limiter. Its primary purpose is to manage and reuse a pool of goroutines to limit concurrency and reduce the memory allocation overhead associated with frequent thread creation. The system provides a runtime worker manager capable of adjusting pool capacity dynamically to respond to fluctuating workloads. To maintain stability, it includes panic recovery mechanisms that intercept runtime failures within worker threads to prevent a single failing task from crashing the entire appli

    Runs a large volume of asynchronous jobs through a reusable pool of workers to reduce memory allocation overhead.

    Goantsgogoroutine
    Vezi pe GitHub↗14,436
  • an-tao/drogonAvatar an-tao

    an-tao/drogon

    13,993Vezi pe GitHub↗

    Drogon is a high-performance C++ HTTP web framework and asynchronous web server designed for building web applications and REST APIs. It utilizes an event-driven, non-blocking architecture to handle concurrent HTTP and WebSocket connections, and it implements a model-view-controller structure to separate business logic from presentation. The framework includes an integrated C++ object-relational mapping system and database client for performing asynchronous operations with relational databases and Redis key-value stores. It supports real-time, full-duplex communication via WebSockets and prov

    Uses a non-blocking event-driven architecture to process a large volume of concurrent network requests efficiently.

    C++
    Vezi pe GitHub↗13,993
  • snapchat/keydbAvatar Snapchat

    Snapchat/KeyDB

    12,487Vezi pe GitHub↗

    KeyDB is a multithreaded in-memory key-value store and distributed cache. It functions as a NoSQL database utilizing multi-version concurrency control to execute non-blocking queries and scans. The project is a multithreaded fork of Redis that maintains protocol compatibility while utilizing a multithreaded architecture to scale across multi-core hardware. It distinguishes itself with flash-tiered storage, allowing the system to offload data from primary RAM to SSD or flash storage to increase total capacity. The system supports high availability through active-active mesh replication and mu

    Distributes network IO and query parsing across multiple CPU cores to handle concurrent requests without blocking.

    C++
    Vezi pe GitHub↗12,487
  • microsoft/garnetAvatar microsoft

    microsoft/garnet

    11,885Vezi pe GitHub↗

    Garnet is a multi-threaded in-memory database and distributed key-value store. It functions as a high-performance remote cache store that implements the RESP wire protocol to maintain compatibility with existing Redis clients and libraries. The project is distinguished by a shared-memory architecture that enables parallel request processing across multiple cores for sub-millisecond latency. It features a tiered storage system that automatically offloads colder data from system memory to SSD or cloud storage layers, and includes a specialized vector search database for high-dimensional similar

    Distributes network IO and query processing across multiple CPU cores to maintain high throughput and low latency.

    C#cachecache-storagecluster
    Vezi pe GitHub↗11,885
  • code4craft/webmagicAvatar code4craft

    code4craft/webmagic

    11,680Vezi pe GitHub↗

    Webmagic is a Java web crawling framework designed for building scalable automated crawlers to download and process large volumes of web pages. It functions as a distributed web crawler and dynamic content crawler, utilizing an XPath HTML parser to locate and extract specific data points from page structures. The framework distinguishes itself through its ability to handle dynamic content by rendering JavaScript and executing asynchronous requests to extract data from non-static pages. It also allows users to define and execute crawler logic via scripting languages, enabling the update of col

    Distributes web requests and page parsing across multiple concurrent threads to increase total data collection throughput.

    Javacrawlerframeworkjava
    Vezi pe GitHub↗11,680
  • openvinotoolkit/openvinoAvatar openvinotoolkit

    openvinotoolkit/openvino

    10,414Vezi pe GitHub↗

    OpenVINO is an AI inference engine and model serving platform designed to execute optimized deep learning models across CPUs, GPUs, and NPUs through a unified API. It includes a model optimization toolkit for converting, quantizing, and compressing models from various frameworks, alongside a specialized generative AI runtime for large language models. The project distinguishes itself through a plugin-based hardware acceleration layer that maps neural network operations to vendor-specific drivers. It features advanced execution mechanisms such as continuous batching, speculative decoding, and

    Processes inference requests simultaneously across multiple host threads while efficiently sharing model weight memory.

    C++aicomputer-visiondeep-learning
    Vezi pe GitHub↗10,414
  • boto/boto3Avatar boto

    boto/boto3

    9,834Vezi pe GitHub↗

    Boto3 is the AWS SDK for Python, providing a programmatic interface for managing and automating AWS cloud infrastructure and services. It serves as a cloud management API client and resource manager for provisioning, configuring, and scaling virtual servers, databases, and storage. The library enables the implementation of infrastructure-as-code through declarative templates and scripts, allowing for the deployment of identical resource stacks across multiple accounts and geographic regions. It also provides a framework for coordinating distributed workflows, serverless functions, and contain

    Handles high-throughput batch requests and real-time streaming responses for massive volumes of concurrent traffic.

    Pythonawsaws-sdkcloud
    Vezi pe GitHub↗9,834
  • coursera-dl/coursera-dlAvatar coursera-dl

    coursera-dl/coursera-dl

    9,634Vezi pe GitHub↗

    This project is a command-line utility and Python-based scraper designed to download and archive educational media from Coursera for offline access. It functions as a tool for saving course syllabi, videos, subtitles, and notebooks to a local file system to ensure a secure backup of academic materials. The tool distinguishes itself by providing capabilities for course quiz extraction, retrieving questions and answers from both graded and ungraded quizzes. It supports the retrieval of learning materials from both legacy and on-demand platforms and implements interrupted download resumption to

    Distributes network requests across multiple threads to increase throughput and optimize download performance.

    Pythonarchivalcourseracoursera-dl
    Vezi pe GitHub↗9,634
  • koljab/realtimesttAvatar KoljaB

    KoljaB/RealtimeSTT

    9,477Vezi pe GitHub↗

    RealtimeSTT is a local speech-to-text engine and real-time automatic speech recognition server. It utilizes transformer-based recognition and omnilingual pipelines to convert live audio streams into text, providing a WebSocket-based streaming API for raw PCM audio transmission. The project is distinguished by a dual-backend transcription pipeline that uses a lightweight engine for immediate partial suggestions and a heavier model for final high-accuracy results. It includes a wake word detection system to trigger recording and employs a shared-resource inference model to distribute heavy spee

    Manages multiple concurrent user sessions by isolating audio buffers while sharing model weight memory for inference.

    Pythonpythonrealtimespeech-to-text
    Vezi pe GitHub↗9,477
  • appleboy/gorushAvatar appleboy

    appleboy/gorush

    8,738Vezi pe GitHub↗

    Gorush is a dedicated notification dispatch server used to send real-time alerts to iOS and Android mobile devices. It functions as a centralized infrastructure for hosting a notification API and managing the delivery of push messages through high-throughput queuing. The system supports both gRPC streams and HTTP endpoints to receive notification triggers and includes a command-line interface for triggering alerts without a running server process. It manages network traffic through proxy routing via HTTP or SOCKS5 and secures server communication using automated TLS certificate management. O

    Employs an architecture designed to process massive volumes of notification tasks with low latency.

    Goandroidapnsgcm
    Vezi pe GitHub↗8,738
  • puma/pumaAvatar puma

    puma/puma

    7,878Vezi pe GitHub↗

    Puma is a concurrent HTTP server for Ruby applications that implements the Rack interface. It operates as a clustered web server, using a combination of worker processes and threads to handle multiple simultaneous web connections via TCP ports or UNIX domain sockets. The server features a master-worker process model that utilizes multiple CPU cores and employs copy-on-write preloading to reduce memory usage. It supports zero-downtime restarts through socket-handover capabilities, allowing application updates without dropping pending network requests. The project includes a token-authenticate

    Scales web traffic by distributing network IO and request handling across multiple CPU cores using threads and processes.

    Rubymultithreadingrackruby
    Vezi pe GitHub↗7,878
  • sparckles/robynAvatar sparckles

    sparckles/Robyn

    7,265Vezi pe GitHub↗

    Robyn is a high-performance asynchronous web framework and server for Python that utilizes a Rust-powered runtime to execute code. It functions as an asynchronous Python web server designed to handle many concurrent requests efficiently through a multithreaded execution model. The project includes specialized capabilities for AI agent request routing, managing communication between agents and external tools. It also serves as a WebSocket communication server, maintaining persistent bidirectional channels for real-time data exchange. The framework covers a broad range of web infrastructure, i

    Distributes network traffic across multiple operating system threads to process concurrent requests in parallel.

    Pythonasyncbackendhacktoberfest
    Vezi pe GitHub↗7,265
  • dotnetcore/capAvatar dotnetcore

    dotnetcore/CAP

    7,088Vezi pe GitHub↗

    CAP is a .NET distributed transaction framework and event bus designed to manage asynchronous communication in microservices. It implements the outbox pattern to ensure eventual consistency and reliable message delivery by persisting messages in local database tables until transactions commit. The framework includes a distributed message monitor and web dashboard for tracking the status of sent and received messages. It provides tools for event traffic visualization, distributed request tracing, and the ability to manually trigger retries for failed delivery attempts. The system supports var

    Allows configuration between parallel processing for high throughput and sequential execution for strict message ordering.

    C#distributed-transactionseventbuskafka
    Vezi pe GitHub↗7,088
  • wzdnzd/aggregatorAvatar wzdnzd

    wzdnzd/aggregator

    6,689Vezi pe GitHub↗

    This project is a proxy aggregation platform designed to collect and verify free proxy server lists from web platforms, social media, and public repositories. It functions as a crawler framework that gathers proxy data and subscription links, a validation tool for testing server liveness, and a synchronization service for distributing the results. The system uses a plugin-based architecture that allows for the integration of custom Python scripts to handle diverse web source structures. It also includes utilities to transform raw proxy data into standardized configuration formats compatible w

    Utilizes multi-threaded execution to increase the throughput of high-volume proxy data collection and validation.

    Pythonproxypool
    Vezi pe GitHub↗6,689
  • nuclio/nuclioAvatar nuclio

    nuclio/nuclio

    5,730Vezi pe GitHub↗

    Nuclio is a high-performance serverless framework designed for Kubernetes that automatically executes user functions when events arrive from HTTP endpoints, message queues, or streaming data platforms. It processes hundreds of thousands of events per second per function instance through efficient parallel workers, and can allocate functions to run on either CPU or GPU hardware to match workload requirements for data processing or machine learning tasks. The platform scales function instances down to zero when idle and wakes them on demand based on incoming event load, while providing an event

    Processes hundreds of thousands of events per second per function instance through efficient I/O and compute handling.

    Go
    Vezi pe GitHub↗5,730
  • robbiehanson/cocoahttpserverAvatar robbiehanson

    robbiehanson/CocoaHTTPServer

    5,609Vezi pe GitHub↗

    CocoaHTTPServer este un server web embedded ușor, conceput pentru a gestiona cererile de rețea primite și a servi conținutul aplicației locale. Proiectul implementează descoperirea serviciilor bazată pe Bonjour pentru a difuza disponibilitatea serverului în rețelele locale și suportă WebDAV pentru gestionarea fișierelor la distanță, permițând crearea, mutarea și editarea fișierelor prin HTTP. Securitatea rețelei este gestionată prin criptare TLS bazată pe certificate și autentificarea resurselor bazată pe parolă. Rutarea cererilor este gestionată printr-un sistem bazat pe delegare, în timp ce conexiunile concurente sunt gestionate folosind Grand Central Dispatch.

    Uses Grand Central Dispatch to manage concurrent network connections via a pool of worker threads.

    Objective-C
    Vezi pe GitHub↗5,609
  • oceanbase/miniobAvatar oceanbase

    oceanbase/miniob

    4,318Vezi pe GitHub↗

    MiniOB is an open-source educational relational database kernel designed for learning the internals of database systems. It implements a dual-engine storage architecture combining B+ Tree and LSM-Tree, supports SQL parsing and query execution, and provides transactional processing with multi-version concurrency control. The system communicates with clients using the MySQL wire protocol and includes a vector database extension for storing and querying high-dimensional vectors. The project distinguishes itself through its comprehensive coverage of core database concepts in a single, learnable c

    Assign each client connection its own thread that listens for messages, processes SQL, and sends responses.

    C++classroomcplusplusdatabase
    Vezi pe GitHub↗4,318
  • markparticle/webserverAvatar markparticle

    markparticle/WebServer

    4,102Vezi pe GitHub↗

    Acest proiect este un server web HTTP scris în C++ pentru mediul Linux. Acesta funcționează ca un server de rețea de înaltă performanță care procesează cereri HTTP și livrează fișiere statice. Serverul utilizează un model reactor și un pool de thread-uri pentru a gestiona volume mari de conexiuni simultane. Folosește o mașină de stări și expresii regulate pentru parsarea cererilor, în timp ce un sistem de temporizare bazat pe min-heap gestionează timeout-urile conexiunilor pentru a închide automat socket-urile inactive. Capabilitățile suplimentare includ un pooler de conexiuni la baza de date pentru a reduce overhead-ul de handshake și un sistem integrat de autentificare a utilizatorilor pentru înregistrare și login. Observabilitatea sistemului este asigurată printr-un sistem de logare asincron care înregistrează evenimentele de runtime în fundal.

    Implements a reactor model and thread pool to distribute network IO and request processing across multiple CPU cores.

    C++
    Vezi pe GitHub↗4,102
  • samsesh/socialbox-termuxAvatar samsesh

    samsesh/SocialBox-Termux

    4,145Vezi pe GitHub↗

    SocialBox-Termux is a credential bruteforce suite and security tool collection designed to run within the Termux Android environment. It functions as an automated account cracker used to test password lists against usernames to discover valid login credentials for social media and email platforms. The toolkit incorporates network traffic masking by routing requests through the Tor network to conceal the origin IP address. It utilizes signature-based rate bypass to mimic legitimate client traffic and avoid automated login blocks. The suite provides capabilities for account validation to verif

    Implements multi-threaded network request handling to accelerate the process of testing password lists.

    Shellandroidbrute-forcebruteforce
    Vezi pe GitHub↗4,145
  • glock45/swifterAvatar glock45

    glock45/swifter

    4,018Vezi pe GitHub↗

    Swifter este un motor de server HTTP ușor și o bibliotecă de rețelistică pentru limbajul de programare Swift. Oferă un strat de rețelistică minimal conceput pentru găzduirea serviciilor web interne, construirea de aplicații server-side și implementarea de servere HTTP personalizate. Proiectul permite crearea de servicii web încorporate pentru control de la distanță sau monitorizarea stării și suportă găzduirea web ușoară cu o amprentă minimală. Capabilitățile sale acoperă gestionarea conexiunilor TCP brute și a socket-urilor de rețea, utilizând un ciclu cerere-răspuns pentru a parsa datele primite în cereri HTTP și a le mapa către funcții handler.

    Processes incoming HTTP requests sequentially on a blocking thread.

    Swift
    Vezi pe GitHub↗4,018
Înapoi12Înainte
  1. Home
  2. Software Engineering & Architecture
  3. High-Throughput Task Processing

Explorează sub-etichetele

  • Network Request Processing2 sub-tag-uriArchitectures optimized for handling massive volumes of concurrent network requests with minimal overhead. **Distinct from High-Throughput Task Processing:** Distinct from general task processing by focusing specifically on the network request-response lifecycle.
  • Processing Mode ConfigurationsSettings to toggle between parallel throughput and sequential execution for message processing. **Distinct from High-Throughput Task Processing:** Focuses on the execution mode (parallel vs sequential) rather than general high-throughput architectural patterns.