PHPスクリプトのタイムアウト機構を解析する、PHPスクリプトを解析する_PHPチュートリアル

<span>void</span> zend_set_timeout(<span>long</span> seconds, <span>int</span> reset_signals) <span>/*</span><span> {{{ </span><span>*/</span><span>
{
    TSRMLS_FETCH();

    </span><span>//</span><span> 赋值</span>
    EG(timeout_seconds) =<span> seconds;

#ifdef ZEND_WIN32
    </span><span>if</span>(!<span>seconds) {
        </span><span>return</span><span>;
    }
    
    </span><span>//</span><span> 启动定时器线程</span>
    <span>if</span> (timeout_thread_initialized == <span>0</span> && InterlockedIncrement(&timeout_thread_initialized) == <span>1</span><span>) {
        </span><span>/*</span><span> We start up this process-wide thread here and not in zend_startup(), because if Zend
         * is initialized inside a DllMain(), you're not supposed to start threads from it.
         </span><span>*/</span><span>
        zend_init_timeout_thread();
    }
    
    </span><span>//</span><span> 向线程发送WM_REGISTER_ZEND_TIMEOUT消息</span>
<span>    PostThreadMessage(timeout_thread_id, WM_REGISTER_ZEND_TIMEOUT, (WPARAM) GetCurrentThreadId(),(LPARAM) seconds);
</span><span>#else</span>

    <span>//</span><span> linux平台下</span>
    <span>struct</span> itimerval t_r;        <span>/*</span><span> timeout requested </span><span>*/</span>
    <span>int</span><span> signo;

    </span><span>if</span><span> (seconds) {
        t_r.it_value.tv_sec </span>=<span> seconds;
        t_r.it_value.tv_usec </span>= t_r.it_interval.tv_sec = t_r.it_interval.tv_usec = <span>0</span><span>;

        </span><span>//</span><span> 设置定时器，seconds秒后会发送SIGPROF信号</span>
        setitimer(ITIMER_PROF, &<span>t_r, NULL);
    }
    signo </span>=<span> SIGPROF;

    </span><span>if</span><span> (reset_signals) {
        sigset_t sigset;

        </span><span>//</span><span> 设置SIGPROF信号对应的处理函数为zend_timeout</span>
<span>        signal(signo, zend_timeout);
        
        </span><span>//</span><span> 防屏蔽</span>
        sigemptyset(&<span>sigset);
        sigaddset(</span>&<span>sigset, signo);
        sigprocmask(SIG_UNBLOCK, </span>&<span>sigset, NULL);
    }
</span><span>#endif</span><span>
}</span>

<span>static</span><span> LRESULT CALLBACK zend_timeout_WndProc(HWND hWnd, UINT message, WPARAM wParam, LPARAM lParam)
{
    </span><span>switch</span><span> (message) {
        </span><span>case</span><span> WM_DESTROY:
            PostQuitMessage(</span><span>0</span><span>);
            </span><span>break</span><span>;
        
        </span><span>//</span><span> 生成一个定时器，开始计时</span>
        <span>case</span><span> WM_REGISTER_ZEND_TIMEOUT:
            </span><span>/*</span><span> wParam is the thread id pointer, lParam is the timeout amount in seconds </span><span>*/</span>
            <span>if</span> (lParam == <span>0</span><span>) {
                KillTimer(timeout_window, wParam);
            } </span><span>else</span><span> {
                SetTimer(timeout_window, wParam, lParam</span>*<span>1000</span><span>, NULL);
                EG(timed_out) </span>= <span>0</span><span>;
            }
            </span><span>break</span><span>;
        
        </span><span>//</span><span> 关闭定时器</span>
        <span>case</span><span> WM_UNREGISTER_ZEND_TIMEOUT:
            </span><span>/*</span><span> wParam is the thread id pointer </span><span>*/</span><span>
            KillTimer(timeout_window, wParam);
            </span><span>break</span><span>;
        
        </span><span>//</span><span> 超时了，也需关闭定时器</span>
        <span>case</span><span> WM_TIMER: {
                KillTimer(timeout_window, wParam);
                EG(timed_out) </span>= <span>1</span><span>;
            }
            </span><span>break</span><span>;
        </span><span>default</span><span>:
            </span><span>return</span><span> DefWindowProc(hWnd, message, wParam, lParam);
    }
    </span><span>return</span> <span>0</span><span>;
}</span>

<span>while</span> (<span>1</span><span>) {
    </span><span>int</span><span> ret;
#ifdef ZEND_WIN32
    </span><span>if</span> (EG(timed_out)) {   <span>//</span><span> windows下的超时，执行每条opcode之前都判断是否需要调用zend_timeout</span>
        zend_timeout(<span>0</span><span>);
    }
</span><span>#endif</span>

    <span>if</span> ((ret = OPLINE->handler(execute_data TSRMLS_CC)) > <span>0</span><span>) {
    ...
    }
}</span>

<span>void</span> zend_unset_timeout(TSRMLS_D) <span>/*</span><span> {{{ </span><span>*/</span><span>
{
#ifdef ZEND_WIN32
    
    </span><span>//</span><span> 通过发送WM_UNREGISTER_ZEND_TIMEOUT消息来关闭定时器</span>
    <span>if</span><span>(timeout_thread_initialized) {
        PostThreadMessage(timeout_thread_id, WM_UNREGISTER_ZEND_TIMEOUT, (WPARAM) GetCurrentThreadId(), (LPARAM) </span><span>0</span><span>);
    }
</span><span>#else</span>
    <span>if</span><span> (EG(timeout_seconds)) {
        </span><span>struct</span><span> itimerval no_timeout;
        no_timeout.it_value.tv_sec </span>= no_timeout.it_value.tv_usec = no_timeout.it_interval.tv_sec = no_timeout.it_interval.tv_usec = <span>0</span><span>;
        
        </span><span>//</span><span> 全置0，相当于关闭定时器</span>
        setitimer(ITIMER_PROF, &<span>no_timeout, NULL);
    }
</span><span>#endif</span><span>
}</span>

ZEND_API <span>void</span> zend_timeout(<span>int</span> dummy) <span>/*</span><span> {{{ </span><span>*/</span><span>
{
    TSRMLS_FETCH();

    </span><span>if</span><span> (zend_on_timeout) {
        zend_on_timeout(EG(timeout_seconds) TSRMLS_CC);
    }

    zend_error(E_ERROR, </span><span>"</span><span>Maximum execution time of %d second%s exceeded</span><span>"</span>, EG(timeout_seconds), EG(timeout_seconds) == <span>1</span> ? <span>""</span> : <span>"</span><span>s</span><span>"</span><span>);
}</span>