// 1. 创建Fiber对象
$fiber = new Fiber(function(): void {
    echo "Fiber启动\n";
    
    // 3. 暂停Fiber并向外部传递值
    $value = Fiber::suspend('暂停时的值');
    echo "Fiber恢复，接收到的值: " . $value . "\n";
});

// 2. 启动Fiber
$value = $fiber->start();
echo "从Fiber接收到的值: " . $value . "\n";

// 4. 恢复Fiber并传递值
$value = $fiber->resume('恢复值');
echo "从Fiber接收到的值: " . $value . "\n";

// 创建任务执行器
class TaskRunner {
    private array $fibers = [];
    private array $results = [];
    
    public function addTask(callable $task, ...$args): void {
        $fiber = new Fiber(function() use ($task, $args) {
            return $task(...$args);
        });
        
        $this->fibers[] = $fiber;
        $fiber->start();
    }
    
    public function run(): array {
        while (count($this->fibers) > 0) {
            foreach ($this->fibers as $key => $fiber) {
                if ($fiber->isTerminated()) {
                    $this->results[] = $fiber->getReturn();
                    unset($this->fibers[$key]);
                } elseif ($fiber->isSuspended()) {
                    $fiber->resume();
                }
            }
        }
        
        return $this->results;
    }
}

// 使用示例
$runner = new TaskRunner();

// 添加耗时任务
$runner->addTask(function() {
    // 模拟耗时操作
    Fiber::suspend();
    sleep(1); // 实际应用中可能是IO操作
    return "任务1完成";
});

$runner->addTask(function() {
    // 模拟耗时操作
    Fiber::suspend();
    sleep(1); // 实际应用中可能是IO操作
    return "任务2完成";
});

// 并行执行所有任务
$results = $runner->run();
print_r($results);

// 并发HTTP请求类
class ConcurrentHttpClient {
    private array $fibers = [];
    private array $responses = [];
    
    public function request(string $url, array $options = []): void {
        $fiber = new Fiber(function() use ($url, $options) {
            // 模拟HTTP请求
            echo "开始请求: $url\n";
            
            // 暂停Fiber，模拟网络延迟
            Fiber::suspend();
            
            // 模拟返回响应
            $response = [
                'url' => $url,
                'status' => 200,
                'body' => "来自 $url 的响应内容"
            ];
            
            return $response;
        });
        
        $this->fibers[] = $fiber;
        $fiber->start();
    }
    
    public function execute(): array {
        while (count($this->fibers) > 0) {
            foreach ($this->fibers as $key => $fiber) {
                if (!$fiber->isTerminated()) {
                    $fiber->resume();
                    if ($fiber->isTerminated()) {
                        $this->responses[] = $fiber->getReturn();
                        unset($this->fibers[$key]);
                    }
                }
            }
        }
        
        return $this->responses;
    }
}

// 使用示例
$client = new ConcurrentHttpClient();

// 添加多个并发请求
$urls = [
    'https://api.example.com/users',
    'https://api.example.com/products',
    'https://api.example.com/orders'
];

foreach ($urls as $url) {
    $client->request($url);
}

// 执行所有请求
$responses = $client->execute();

// 输出结果
foreach ($responses as $response) {
    echo "URL: {$response['url']}, 状态: {$response['status']}\n";
}

// 文件处理器类
class FileProcessor {
    private array $fibers = [];
    private array $results = [];
    
    public function processFile(string $filename, callable $processor): void {
        $fiber = new Fiber(function() use ($filename, $processor) {
            echo "开始处理文件: $filename\n";
            
            // 模拟文件读取
            Fiber::suspend();
            
            // 模拟文件内容
            $content = "这是文件 $filename 的内容";
            
            // 处理文件内容
            $result = $processor($content);
            
            return [
                'filename' => $filename,
                'result' => $result
            ];
        });
        
        $this->fibers[] = $fiber;
        $fiber->start();
    }
    
    public function execute(): array {
        while (count($this->fibers) > 0) {
            foreach ($this->fibers as $key => $fiber) {
                if (!$fiber->isTerminated()) {
                    $fiber->resume();
                    if ($fiber->isTerminated()) {
                        $this->results[] = $fiber->getReturn();
                        unset($this->fibers[$key]);
                    }
                }
            }
        }
        
        return $this->results;
    }
}

// 使用示例
$processor = new FileProcessor();

// 文件处理函数
$wordCounter = function($content) {
    return str_word_count($content);
};

// 添加多个文件处理任务
$files = ['file1.txt', 'file2.txt', 'file3.txt'];
foreach ($files as $file) {
    $processor->processFile($file, $wordCounter);
}

// 并行处理所有文件
$results = $processor->execute();

// 输出结果
foreach ($results as $result) {
    echo "文件: {$result['filename']}, 单词数: {$result['result']}\n";
}

// 简单的事件驱动服务器
class EventDrivenServer {
    private array $fibers = [];
    private array $clients = [];
    
    public function acceptClient(string $clientId): void {
        $fiber = new Fiber(function() use ($clientId) {
            echo "客户端 $clientId 已连接\n";
            
            // 模拟接收客户端数据
            Fiber::suspend();
            $data = "来自客户端 $clientId 的数据";
            
            // 处理客户端数据
            $response = "处理结果: " . strtoupper($data);
            
            // 模拟发送响应
            Fiber::suspend();
            echo "已向客户端 $clientId 发送响应\n";
            
            return $response;
        });
        
        $this->fibers[$clientId] = $fiber;
        $this->clients[] = $clientId;
        $fiber->start();
    }
    
    public function run(): void {
        while (count($this->fibers) > 0) {
            foreach ($this->fibers as $clientId => $fiber) {
                if (!$fiber->isTerminated()) {
                    $fiber->resume();
                    if ($fiber->isTerminated()) {
                        $response = $fiber->getReturn();
                        echo "客户端 $clientId 处理完成: $response\n";
                        unset($this->fibers[$clientId]);
                    }
                }
            }
        }
        
        echo "所有客户端已处理完成\n";
    }
}

// 使用示例
$server = new EventDrivenServer();

// 模拟接受多个客户端连接
$server->acceptClient('client1');
$server->acceptClient('client2');
$server->acceptClient('client3');

// 运行服务器
$server->run();

// 带有日志和错误处理的Fiber示例
class LoggedFiber extends Fiber {
    private string $name;
    
    public function __construct(string $name, callable $callback) {
        $this->name = $name;
        parent::__construct($callback);
    }
    
    public function start(...$args) {
        echo "[DEBUG] 启动Fiber: {$this->name}\n";
        try {
            return parent::start(...$args);
        } catch (Throwable $e) {
            echo "[ERROR] Fiber {$this->name} 启动失败: " . $e->getMessage() . "\n";
            throw $e;
        }
    }
    
    public function resume($value = null) {
        echo "[DEBUG] 恢复Fiber: {$this->name}\n";
        try {
            return parent::resume($value);
        } catch (Throwable $e) {
            echo "[ERROR] Fiber {$this->name} 恢复失败: " . $e->getMessage() . "\n";
            throw $e;
        }
    }
    
    public function throw(Throwable $exception) {
        echo "[DEBUG] 向Fiber {$this->name} 抛出异常\n";
        try {
            return parent::throw($exception);
        } catch (Throwable $e) {
            echo "[ERROR] Fiber {$this->name} 异常处理失败: " . $e->getMessage() . "\n";
            throw $e;
        }
    }
}

// 使用示例
$fiber = new LoggedFiber("task1", function() {
    echo "Fiber task1 开始执行\n";
    
    try {
        $value = Fiber::suspend("暂停值");
        echo "Fiber task1 恢复，接收到: $value\n";
        
        // 模拟可能出错的操作
        if (rand(0, 1) === 0) {
            throw new Exception("随机错误");
        }
        
        return "task1完成";
    } catch (Exception $e) {
        echo "Fiber task1 捕获异常: " . $e->getMessage() . "\n";
        return "task1出错";
    }
});

$fiber->start();
$fiber->resume("恢复值");

if (!$fiber->isTerminated()) {
    $result = $fiber->getReturn();
    echo "Fiber结果: $result\n";
}

// Fiber性能监控示例
class FiberMonitor {
    private array $fiberStats = [];
    
    public function trackFiber(string $name, callable $callback): Fiber {
        $startTime = microtime(true);
        $startMemory = memory_get_usage();
        
        $fiber = new Fiber(function() use ($callback, $name, $startTime, $startMemory) {
            $fiberStartTime = microtime(true);
            $fiberStartMemory = memory_get_usage();
            
            try {
                $result = $callback();
                
                $fiberEndTime = microtime(true);
                $fiberEndMemory = memory_get_usage();
                
                $this->fiberStats[$name] = [
                    'execution_time' => $fiberEndTime - $fiberStartTime,
                    'memory_usage' => $fiberEndMemory - $fiberStartMemory,
                    'status' => 'completed'
                ];
                
                return $result;
            } catch (Throwable $e) {
                $fiberEndTime = microtime(true);
                $fiberEndMemory = memory_get_usage();
                
                $this->fiberStats[$name] = [
                    'execution_time' => $fiberEndTime - $fiberStartTime,
                    'memory_usage' => $fiberEndMemory - $fiberStartMemory,
                    'status' => 'failed',
                    'error' => $e->getMessage()
                ];
                
                throw $e;
            }
        });
        
        $this->fiberStats[$name] = [
            'creation_time' => $startTime,
            'creation_memory' => $startMemory,
            'status' => 'created'
        ];
        
        return $fiber;
    }
    
    public function getStats(): array {
        return $this->fiberStats;
    }
    
    public function printStats(): void {
        echo "Fiber性能统计:\n";
        echo str_repeat("-", 50) . "\n";
        echo sprintf("%-15s %-15s %-15s %-15s\n", "名称", "执行时间(s)", "内存使用(B. ", "状态");✅
        echo str_repeat("-", 50) . "\n";
        
        foreach ($this->fiberStats as $name => $stats) {
            $executionTime = isset($stats['execution_time']) ? number_format($stats['execution_time'], 4) : 'N/A';
            $memoryUsage = isset($stats['memory_usage']) ? $stats['memory_usage'] : 'N/A';
            $status = $stats['status'];
            
            echo sprintf("%-15s %-15s %-15s %-15s\n", $name, $executionTime, $memoryUsage, $status);
            
            if (isset($stats['error'])) {
                echo "错误: " . $stats['error'] . "\n";
            }
        }
        
        echo str_repeat("-", 50) . "\n";
    }
}

// 使用示例
$monitor = new FiberMonitor();

$fiber1 = $monitor->trackFiber("task1", function() {
    Fiber::suspend();
    // 模拟耗时操作
    usleep(100000);
    return "task1结果";
});

$fiber2 = $monitor->trackFiber("task2", function() {
    Fiber::suspend();
    // 模拟内存密集型操作
    $data = str_repeat("x", 10000);
    return "task2结果";
});

$fiber1->start();
$fiber2->start();

$fiber1->resume();
$fiber2->resume();

// 输出性能统计
$monitor->printStats();