uringcore 0.9.1

High-performance asyncio event loop for Python using io_uring - 36% faster than asyncio

uringcore

A high-performance asyncio event loop for Linux using io_uring.

Introduction

uringcore provides a drop-in replacement for Python's asyncio event loop, built on the io_uring interface available in Linux kernel 5.11+. The project targets use cases where low-latency I/O and high throughput are critical requirements.

The implementation leverages a completion-driven architecture rather than the traditional readiness-based model used by epoll. This design eliminates syscalls from the hot path, resulting in measurable performance improvements for network-intensive applications.

Use Cases

• High-frequency trading systems requiring sub-millisecond latency
• Real-time data pipelines processing millions of messages per second
• API gateways handling high concurrent connection counts
• WebSocket servers with persistent connections
• Database connection pools with intensive query workloads

Requirements

• Linux kernel 5.11+ (for IORING_OP_PROVIDE_BUFFERS)
• Python 3.10+
• Rust 1.70+

Optional:

• SQPOLL mode requires CAP_SYS_ADMIN or kernel 5.12+ with unprivileged SQPOLL

Installation

From PyPI

pip install uringcore

From Source

git clone https://github.com/ankitkpandey1/uringcore.git
cd uringcore

# Create virtual environment
python3 -m venv .venv
source .venv/bin/activate

# Install build dependencies
pip install maturin

# Build and install
maturin develop

Quick Start

Replace the default asyncio event loop with uringcore:

import asyncio
import uringcore

# Set the event loop policy
asyncio.set_event_loop_policy(uringcore.EventLoopPolicy())

async def main():
    # Standard asyncio code works unchanged
    await asyncio.sleep(1)
    print("Hello from uringcore!")

asyncio.run(main())

With FastAPI

import asyncio
import uringcore
from fastapi import FastAPI

asyncio.set_event_loop_policy(uringcore.EventLoopPolicy())

app = FastAPI()

@app.get("/")
async def root():
    return {"message": "Powered by uringcore"}

With Starlette

import asyncio
import uringcore
from starlette.applications import Starlette
from starlette.responses import JSONResponse
from starlette.routing import Route

asyncio.set_event_loop_policy(uringcore.EventLoopPolicy())

async def homepage(request):
    return JSONResponse({"hello": "world"})

app = Starlette(routes=[Route("/", homepage)])

Performance

Verified benchmark results against standard asyncio and uvloop:

Metric	uringcore	asyncio	uvloop
Throughput	15,394 req/s	11,317 req/s	11,721 req/s
p50 Latency	58 µs	83 µs	78 µs
p99 Latency	121 µs	181 µs	182 µs
vs asyncio	+36%	baseline	+4%

See BENCHMARK.md for methodology and detailed analysis.

Features

• Pure io_uring - No fallback to epoll for core I/O
• TCP Support - create_server, create_connection, start_server
• UDP Support - create_datagram_endpoint
• Unix Sockets - create_unix_server, create_unix_connection
• Subprocess - subprocess_exec, subprocess_shell
• Signal Handlers - add_signal_handler, remove_signal_handler
• Executor Integration - run_in_executor for blocking calls
• Reader/Writer Callbacks - add_reader, add_writer for 3rd-party compatibility
• Connection Timeouts - IORING_OP_LINK_TIMEOUT support

Project Structure

uringcore/
├── src/                    # Rust core implementation
│   ├── lib.rs              # PyO3 module entry point
│   ├── buffer.rs           # Zero-copy buffer pool
│   ├── ring.rs             # io_uring wrapper with LINK_TIMEOUT
│   ├── state.rs            # FD state machine
│   └── error.rs            # Error types
├── python/                 # Python layer
│   └── uringcore/
│       ├── __init__.py
│       ├── loop.py         # UringEventLoop
│       ├── policy.py       # EventLoopPolicy
│       ├── transport.py    # Socket transport
│       ├── datagram.py     # UDP transport
│       ├── subprocess.py   # Subprocess transport
│       └── ssl_transport.py # SSL/TLS wrapper
├── tests/                  # Test suites
│   ├── test_basic.py       # Unit tests
│   ├── test_stress.py      # Concurrent stress tests
│   ├── test_asyncio_compat.py  # asyncio API tests
│   └── e2e/
│       ├── starlette/
│       └── fastapi/
└── benchmarks/             # Performance benchmarks

Documentation

• Architecture - Design decisions and system overview
• Benchmarks - Performance measurements and analysis

Development

Running Tests

# Rust tests
cargo test

# Python tests
source .venv/bin/activate
pytest tests/ -v

# All tests including e2e
pytest tests/ tests/e2e/ -v

Code Quality

# Rust formatting and linting
cargo fmt
cargo clippy --all-targets -- -D warnings

# Python linting (if ruff/black installed)
ruff check .

License

SPDX-License-Identifier: Apache-2.0
Copyright 2024 Ankit Kumar Pandey <[e-mail]>

Licensed under the Apache License, Version 2.0. See LICENSE for details.

Author

Ankit Kumar Pandey - [e-mail]

Acknowledgments

• The io_uring subsystem maintainers, particularly Jens Axboe
• The PyO3 project for Rust-Python bindings
• The uvloop project for demonstrating high-performance event loop implementation