11 Repos
Execution of high-volume data tasks using concurrent threads to increase throughput.
Distinct from High-Performance Collection Processing: Closest candidates focus on packet processing or database queries; this is a general architectural pattern for high-volume data collection.
Explore 11 awesome GitHub repositories matching software engineering & architecture · Multi-Threaded Batch Processing. Refine with filters or upvote what's useful.
Pentaho Kettle ist eine Enterprise-ETL-Datenintegrationsplattform, die darauf ausgelegt ist, Daten zwischen unterschiedlichen Quellen und Zieldatenbanken zu extrahieren, zu transformieren und zu laden. Sie fungiert als metadatengesteuerter Orchestrator, der einen visuellen Workflow-Designer nutzt, um komplexe Sequenzen von Datenaufgaben und Transformationspipelines zu erstellen und zu verwalten. Das System zeichnet sich durch seine verteilte Datenverarbeitungs-Engine aus, die Workloads über Cluster von Server-Nodes hinweg ausführt, um den Durchsatz zu erhöhen. Es verwendet eine Plugin-basierte Architektur, die es ermöglicht, die Plattform über externe JAR-Dateien zu erweitern, um Konnektivität zu diversen Datenbanken und Cloud-Diensten bereitzustellen. Die Plattform deckt ein breites Spektrum an Datenintegrationsfunktionen ab, einschließlich Bulk-Loading, Remote-Dateiverwaltung und Datenstrukturtransformation. Sie bietet Werkzeuge für Datenqualitätsvalidierung, Pipeline-Automatisierung und Job-Lebenszyklusmanagement sowie Überwachungsprogramme zur Verfolgung des Serverzustands und des Echtzeit-Ausführungsstatus.
Implements high-volume data processing by executing discrete pipeline steps in separate concurrent threads to maximize throughput.
ClamAV ist eine Open-Source-Antivirus-Engine und ein Malware-Erkennungsscanner. Er identifiziert Trojaner, Viren und andere schädliche Software durch das Scannen von Dateien und Datenströmen anhand einer Datenbank bekannter Signaturen. Das System fungiert als Signatur-basierter Bedrohungserkenner, der die Implementierung von Threat Intelligence ermöglicht, indem Malware-Proben in umsetzbare Signaturen umgewandelt werden. Es unterstützt die Erstellung benutzerdefinierter Malware-Signaturen zur Identifizierung spezifischer oder spezialisierter Sicherheitsbedrohungen. Die Engine bietet Funktionen für Endpoint-Security-Monitoring und umfassende Malware-Erkennungsscans über Computersysteme hinweg.
Parallelizes the scanning of files and data streams across multiple CPU cores to increase throughput.
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 connectivity probes.
Cppcheck ist ein statisches Analysetool und Linter für C- und C++-Quellcode, das darauf ausgelegt ist, Programmierfehler, Speicherlecks und Sicherheitsverletzungen zu erkennen, ohne das Programm auszuführen. Es fungiert als Bug-Detection-Engine und Qualitätssicherungstool, um Nebenläufigkeitsprobleme, Type-Cast-Fehler und die Einhaltung sicherer Codierungsstandards zu identifizieren. Das Projekt bietet eine grafische Benutzeroberfläche zur Auswahl von Dateien und zur Überprüfung von Fehlern sowie einen Linter zur Durchsetzung von Namenskonventionen und Codierungsstandards. Es unterstützt die Erstellung benutzerdefinierter Analyse-Regeln mittels regulärer Ausdrücke, um spezifische Codierungsmuster zu identifizieren. Das Tool umfasst Funktionen für inkrementelle Analyse, Warnungsunterdrückung und Dateiausschluss, um große Codebasen zu verwalten. Zudem bietet es HTML-Berichterstellung und Integration in Editoren wie VS Code, um Fehleridentifizierung während der Entwicklung zu ermöglichen.
Distributes independent analysis tasks across multiple CPU cores to increase processing throughput.
Caesium is an image compression tool that reduces file sizes for JPG, PNG, WebP, and TIFF images while preserving visual quality and metadata. It operates as a cross-platform desktop application with a graphical interface, a command-line tool for scripting and automation, and a web-based interface for browser uploads, all supporting batch processing of multiple images at once. The tool distinguishes itself by offering multiple interaction modes — desktop, terminal, and web — each capable of handling the same core compression tasks. It preserves folder structure when saving compressed images,
Distributes compression tasks across multiple CPU threads to process several images simultaneously without blocking the user interface.
Grobid ist ein Machine-Learning-System, das darauf ausgelegt ist, akademische und wissenschaftliche PDF-Publikationen in strukturiertes XML umzuwandeln. Es fungiert als PDF-zu-XML-Parser und Extraktor für wissenschaftliche Metadaten, der Titel, Autoren, Zugehörigkeiten und bibliografische Referenzen aus Forschungspapieren identifiziert und normalisiert. Das System nutzt einen Deep-Learning-Dokumentensegmentierer, um rohe PDFs in funktionale Regionen zu unterteilen, und verwendet einen bibliografischen Referenz-Resolver, um Zitate mit externen Registern für die Metadatenanreicherung und DOI-Auflösung abzugleichen. Es unterstützt eine vollständige Machine-Learning-Modell-Trainingspipeline, die die Generierung annotierter Trainingskorpora, das Nachtrainieren von Modellen und den Export von Modell-Binärdateien ermöglicht. Das Projekt deckt ein breites Spektrum an Extraktionsfunktionen ab, einschließlich Dokument-Header-Parsing, Strukturierung des Volltextkörpers und Identifizierung domänenspezifischer Entitäten wie Finanzierungsinformationen und Patentzitate. Es bietet zudem räumliche Analysetools für die Extraktion von Bounding-Boxen und Koordinaten-Mapping, um semantische Labels mit dem ursprünglichen PDF-Layout zu synchronisieren. Die Anwendung kann über containerisierte Images bereitgestellt werden und enthält Kommandozeilen-Utilities für das Multi-Threaded-Batch-Processing großer Dokumentensammlungen.
Implements multi-threaded batch processing to maximize hardware throughput when parsing large document collections.
Crawler4j ist ein Multi-Threaded-Java-Webcrawler und -Spider für hochvolumiges Web-Traversing und Content-Extraktion. Es fungiert als „höfliches“ Crawling-Framework, das die Entdeckung und Indizierung von HTML- und Binärinhalten über mehrere Websites hinweg ermöglicht. Das Projekt zeichnet sich durch ein persistentes Crawling-Modell aus, das den Session-Status im lokalen Speicher serialisiert, sodass die Engine die Indizierung nach einem Absturz oder einer Unterbrechung fortsetzen kann. Es enthält einen Politeness-Controller zur Regulierung der Anfragefrequenz und -verzögerungen, um Serverüberlastungen und IP-Sperren zu vermeiden. Das System deckt eine breite Palette an Traversierungsfunktionen ab, einschließlich tiefenbegrenztem Scope-Management, Zielfilterung und Request-Interception für benutzerdefinierte User-Agents und Proxy-Routing. Die Datenspeicherung erfolgt über ein Repository-Pattern, das die Crawling-Logik von der Persistenz der Seitenmetadaten in relationalen Datenbanken entkoppelt.
Ships a multi-threaded engine for high-throughput web traversal and content extraction.
SDRangel is a comprehensive software-defined radio suite and digital signal processing framework. It functions as an RF spectrum analyzer and modular radio demodulator, providing a unified hardware abstraction layer to connect various radio devices to software processing pipelines for data acquisition and transmission. The platform is distinguished by its modular architecture, which uses a data-flow graph of dynamic libraries to construct signal processing chains. This allows for a plugin-based environment where users can extract audio and digital data from raw radio signals using various mod
Implements a multi-threaded sample pipeline with shared memory buffers to minimize signal latency.
VidGear is a high-performance Python video processing framework designed for capturing, transcoding, and manipulating video streams. It functions as a multi-protocol video streamer and a WebRTC streaming server, enabling the transfer of video frames over networks using RTSP, RTMP, RTP, and MJPEG protocols. The project distinguishes itself through hardware-accelerated video transcoding and decoding using GPU backends like CUDA to reduce CPU load. It includes a cross-platform screen capture tool and a specialized system for establishing direct peer-to-peer media connections using WebRTC signali
Reads frames from IP cameras, network streams, and hardware decoders using multi-threaded processing.
Diese Bibliothek ist ein Java-basiertes Tool zur Durchsetzung von Datenstruktureinschränkungen und zur Verifizierung technischer Formate gegen definierte Schema-Spezifikationen. Sie fungiert als Verarbeitungsdienstprogramm, das komplexe Datenstrukturen parst und gleichzeitig externe Schema-Referenzen sowie zirkuläre Abhängigkeiten verwaltet. Die Engine zeichnet sich durch ein unveränderliches Prozessor-Design aus, das eine thread-sichere, gleichzeitige Validierung ermöglicht, ohne dass eine externe Synchronisation erforderlich ist. Sie verwendet Arithmetik mit beliebiger Präzision, um numerische Einschränkungen zu bewerten, was häufige Rundungsfehler bei Gleitkommazahlen verhindert, und nutzt zeichenbasierte Verarbeitung, um eine Unicode-bewusste String-Validierung für komplexe Symbole sicherzustellen. Entwickler können die Kern-Pipeline erweitern, indem sie benutzerdefinierte Schlüsselwörter und Format-Handler registrieren, um spezialisierte Geschäftslogik zu implementieren. Das Projekt bietet ein umfassendes Schema-Management, einschließlich struktureller Compliance-Prüfung gegen Meta-Schemas, URI-basierter Abhängigkeitsauflösung und konfigurierbarem Schema-Laden. Es unterstützt detaillierte Fehlerberichte, die die Validierung über Kindelemente hinweg fortsetzen, selbst nach Fehlern bei Elternelementen, und enthält eine Befehlszeilenschnittstelle für die terminalbasierte Datenverifizierung.
Executes thread-safe validation tasks concurrently to maintain high performance during heavy data processing.
This project is a procedural content generation framework and three-dimensional mesh generation library designed for the Unity game engine. It provides a system for automating the creation of complex landscapes and natural environments by programmatically constructing geometric terrain surfaces and heightmaps. The generator utilizes layered noise functions to calculate elevation values, which are then translated into terrain geometry. To maintain performance during real-time rendering, the system employs chunk-based mesh generation and dynamic level-of-detail management, which adjusts geometr
Offloads heavy mathematical calculations and mesh construction to background threads to maintain high frame rates during terrain generation.