Isolator

Features

• ✨ Run synchronous and async functions in separate threads
• 🧵 True isolation through Tokio's thread pools
• 🛡️ Catch panics and convert them to proper errors
• 🔄 Support for async/await
• 🧪 Comprehensive test coverage
• 📦 Minimal dependencies (only tokio and thiserror)

Installation

Add this to your Cargo.toml:

[dependencies]
isolator = "0.1.2"

Usage

Basic Example

use isolator::{isolate, IsolationResult};

fn main() -> IsolationResult<()> {
    // Run a function in a separate thread
    let result = isolate(|| {
        println!("Running in a separate thread!");
        42
    })?;

    println!("Result: {}", result); // prints: Result: 42
    Ok(())
}

Async Example

use isolator::{isolate_async, IsolationResult};

#[tokio::main]
async fn main() -> IsolationResult<()> {
    let result = isolate_async(|| async {
        // This async code runs in Tokio's thread pool
        tokio::time::sleep(std::time::Duration::from_secs(1)).await;
        42
    }).await?;

    println!("Async result: {}", result);
    Ok(())
}

Error Handling

The library provides the IsolationError enum for handling both panics and regular errors:

#[derive(Error, Debug)]
pub enum IsolationError {
    #[error("Function panicked: {0}")]
    Panic(String),
    #[error("Function failed: {0}")]
    Error(Box<dyn std::error::Error + Send + Sync>),
}

Example with error handling:

use isolator::{isolate, IsolationError};

fn main() {
    match isolate(|| {
        if true {
            panic!("Something went wrong!");
        }
        42
    }) {
        Ok(value) => println!("Success: {}", value),
        Err(IsolationError::Panic(msg)) => println!("Panic caught: {}", msg),
        Err(IsolationError::Error(e)) => println!("Error caught: {}", e),
    }
}

Advanced Usage

Custom Error Types

You can use your own error types as long as they implement std::error::Error:

use thiserror::Error;
use isolator::isolate;

#[derive(Error, Debug)]
enum MyError {
    #[error("Custom error: {0}")]
    Custom(String),
}

fn fallible_function() -> Result<(), MyError> {
    Err(MyError::Custom("oops".to_string()))
}

fn main() {
    let result = isolate(|| fallible_function());
    // Handle the result...
}

Thread Pool Configuration

The library uses Tokio's thread pools for isolation:

• isolate() uses spawn_blocking for CPU-intensive tasks
• isolate_async() uses Tokio's async runtime for concurrent tasks

use isolator::isolate_async;
use tokio;

#[tokio::main]
async fn main() {
    let result = isolate_async(|| async {
        // Runs in Tokio's thread pool
        tokio::time::sleep(std::time::Duration::from_secs(1)).await;
        "Done!"
    }).await;
    
    println!("Result: {:?}", result);
}

API Reference

For detailed API documentation, visit docs.rs/isolator.

Contributing

Contributions are welcome! Please feel free to submit a Pull Request. For major changes, please open an issue first to discuss what you would like to change.