11 repositorios
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 es una plataforma empresarial de integración de datos ETL diseñada para extraer, transformar y cargar datos entre fuentes dispares y bases de datos de destino. Funciona como un orquestador basado en metadatos que utiliza un diseñador de flujo de trabajo visual para crear y gestionar secuencias complejas de tareas de datos y tuberías de transformación. El sistema se distingue por su motor de procesamiento de datos distribuido, que ejecuta cargas de trabajo a través de clústeres de nodos de servidor para aumentar el rendimiento. Emplea una arquitectura basada en plugins, lo que permite extender la plataforma mediante archivos JAR externos para proporcionar conectividad a diversas bases de datos y servicios en la nube. La plataforma cubre una amplia gama de capacidades de integración de datos, incluyendo carga masiva, gestión remota de archivos y transformación de estructuras de datos. Proporciona herramientas para la validación de la calidad de los datos, automatización de tuberías y gestión del ciclo de vida de los trabajos, junto con utilidades de monitoreo para rastrear la salud del servidor y el estado de ejecución en tiempo real.
Implements high-volume data processing by executing discrete pipeline steps in separate concurrent threads to maximize throughput.
ClamAV es un motor antivirus de código abierto y escáner de detección de malware. Identifica troyanos, virus y otro software malicioso escaneando archivos y flujos de datos contra una base de datos de firmas conocidas. El sistema funciona como un detector de amenazas basado en firmas, lo que permite la implementación de inteligencia de amenazas convirtiendo muestras de malware en firmas accionables. Admite la creación de firmas de malware personalizadas para identificar amenazas de seguridad específicas o especializadas. El motor proporciona capacidades para el monitoreo de seguridad de endpoints y escaneo integral de detección de malware en sistemas informáticos.
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 es una herramienta de análisis estático y linter para código fuente en C y C++ diseñada para detectar errores de programación, fugas de memoria y violaciones de seguridad sin ejecutar el programa. Funciona como un motor de detección de errores y herramienta de aseguramiento de calidad para identificar problemas de concurrencia, errores de conversión de tipos y cumplimiento de estándares de codificación segura. El proyecto proporciona una interfaz gráfica de usuario para seleccionar archivos y revisar errores, junto con un linter para imponer convenciones de nomenclatura y estándares de codificación. Soporta la creación de reglas de análisis personalizadas utilizando expresiones regulares para identificar patrones de codificación específicos. La herramienta incluye capacidades para análisis incremental, supresión de advertencias y exclusión de archivos para gestionar grandes codebases. También cuenta con generación de informes HTML e integración con editores como VS Code para proporcionar identificación de errores durante el desarrollo.
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 es un sistema de aprendizaje automático diseñado para transformar publicaciones académicas y científicas en PDF a XML estructurado. Funciona como un analizador de PDF a XML y extractor de metadatos académicos, identificando y normalizando títulos, autores, afiliaciones y referencias bibliográficas de trabajos de investigación. El sistema utiliza un segmentador de documentos de aprendizaje profundo para dividir los PDF sin procesar en regiones funcionales y emplea un resolvedor de referencias bibliográficas para hacer coincidir las citas con registros externos para el enriquecimiento de metadatos y la resolución de DOI. Admite una canalización completa de entrenamiento de modelos de aprendizaje automático, lo que permite la generación de corpus de entrenamiento anotados, reentrenamiento de modelos y la exportación de binarios de modelos. El proyecto cubre una amplia gama de capacidades de extracción, incluyendo el análisis de encabezados de documentos, estructuración del cuerpo del texto completo y la identificación de entidades específicas del dominio como información de financiación y citas de patentes. También proporciona herramientas de análisis espacial para la extracción de cuadros delimitadores y mapeo de coordenadas para sincronizar etiquetas semánticas con el diseño original del PDF. La aplicación se puede desplegar a través de imágenes contenedorizadas e incluye utilidades de línea de comandos para el procesamiento por lotes multiproceso de grandes colecciones de documentos.
Implements multi-threaded batch processing to maximize hardware throughput when parsing large document collections.
Crawler4j is a multi-threaded Java web crawler and spider designed for high-volume web traversal and content extraction. It functions as a polite crawling framework that enables the discovery and indexing of HTML and binary content across multiple websites. The project distinguishes itself through a persistent crawling model that serializes session state to local storage, allowing the engine to resume indexing after a crash or interruption. It includes a politeness controller to regulate request frequency and delays, preventing server overloading and IP blocking. The system covers a broad ra
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.
Esta biblioteca es una herramienta basada en Java para aplicar restricciones de estructura de datos y verificar formatos técnicos contra especificaciones de esquema definidas. Funciona como una utilidad de procesamiento que analiza estructuras de datos complejas mientras gestiona referencias de esquema externas y dependencias circulares. El motor se distingue por un diseño de procesador inmutable que permite una validación concurrente y segura para hilos sin requerir sincronización externa. Emplea aritmética de precisión arbitraria para evaluar restricciones numéricas, evitando errores comunes de redondeo de punto flotante, y utiliza procesamiento a nivel de carácter para asegurar la validación de cadenas consciente de Unicode para símbolos complejos. Los desarrolladores pueden extender el pipeline central registrando palabras clave personalizadas y manejadores de formato para implementar lógica de negocio especializada. El proyecto proporciona una gestión integral de esquemas, incluyendo la comprobación de cumplimiento estructural contra meta-esquemas, resolución de dependencias basada en URI y carga de esquemas configurable. Admite informes de error detallados que continúan la validación a través de elementos secundarios incluso después de fallos principales, e incluye una interfaz de línea de comandos para la verificación de datos basada en terminal.
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.