Switch to process-based parallelism and remove threading

README.md

@@ -56,7 +56,7 @@ OpenEvolve implements a comprehensive evolutionary coding system with:
 - **Error Recovery**: Robust checkpoint loading with automatic fix for common serialization issues
 
 #### 🚀 **Performance & Scalability**
-- **Threaded Parallelism**: High-throughput asynchronous evaluation pipeline
+- **Process-Based Parallelism**: True parallel execution bypassing Python's GIL for CPU-bound tasks
 - **Resource Management**: Memory limits, timeouts, and resource monitoring
 - **Efficient Storage**: Optimized database with artifact management and cleanup policies
 

openevolve/_version.py

@@ -1,3 +1,3 @@
 """Version information for openevolve package."""
 
-__version__ = "0.0.20"
+__version__ = "0.1.0"

openevolve/controller.py

@@ -16,7 +16,7 @@
 from openevolve.evaluator import Evaluator
 from openevolve.llm.ensemble import LLMEnsemble
 from openevolve.prompt.sampler import PromptSampler
-from openevolve.threaded_parallel import ImprovedParallelController
+from openevolve.process_parallel import ProcessParallelController
 from openevolve.utils.code_utils import (
     extract_code_language,
 )
@@ -257,7 +257,7 @@ async def run(
 
         # Initialize improved parallel processing
         try:
-            self.parallel_controller = ImprovedParallelController(
+            self.parallel_controller = ProcessParallelController(
                 self.config, self.evaluation_file, self.database
             )
 
@@ -439,7 +439,7 @@ async def _run_evolution_with_checkpoints(
         )
 
         # Check if shutdown was requested
-        if self.parallel_controller.shutdown_flag.is_set():
+        if self.parallel_controller.shutdown_event.is_set():
             logger.info("Evolution stopped due to shutdown request")
             return