Handling fatal errors inside threads via register_shutdown_function

pthreads-shutdown-worker.php

<?php

class Worker extends \Worker {
    
    function run() {
        // &$this ref required to avoid segfault
        register_shutdown_function([&$this, 'onShutdown']);
    }
    
    private function onShutdown() {
        if (!$err = error_get_last()) {
            return;
        }
        
        $fatals = [
            E_ERROR,
            E_PARSE,
            E_CORE_ERROR,
            E_CORE_WARNING,
            E_COMPILE_ERROR,
            E_COMPILE_WARNING
        ];
        
        if (in_array($err['type'], $fatals)) {
            $this->handleFatalError();
        }
    }
    
    private function handleFatalError() {
        die('Worker thread died :(');
    }
    
}