成人国产在线小视频_日韩寡妇人妻调教在线播放_色成人www永久在线观看_2018国产精品久久_亚洲欧美高清在线30p_亚洲少妇综合一区_黄色在线播放国产_亚洲另类技巧小说校园_国产主播xx日韩_a级毛片在线免费

資訊專欄INFORMATION COLUMN

Swoole 源碼分析——Reactor模塊之ReactorBase

baukh789 / 1755人閱讀

前言

作為一個網(wǎng)絡(luò)框架,最為核心的就是消息的接受與發(fā)送。高效的 reactor 模式一直是眾多網(wǎng)絡(luò)框架的首要選擇,本節(jié)主要講解 swoole 中的 reactor 模塊。

UNP 學習筆記——IO 復用

Reactor 的數(shù)據(jù)結(jié)構(gòu)

Reactor 的數(shù)據(jù)結(jié)構(gòu)比較復雜,首先 object 是具體 Reactor 對象的首地址,ptr 是擁有 Reactor 對象的類的指針,

event_num 存放現(xiàn)有監(jiān)控的 fd 個數(shù),max_event_num 存放允許持有的最大事件數(shù)目,flag 為標記位,

id 用于存放對應(yīng) reactorid,running 用于標記該 reactor 是否正在運行,一般是創(chuàng)建時會被置為 1,start 標記著 reactor 是否已經(jīng)被啟動,一般是進行 wait 監(jiān)控時被置為 1,once 標志著 reactor 是否是僅需要一次性監(jiān)控,check_timer 標志著是否要檢查定時任務(wù)

singal_no:每次 reactor 由于 fd 的就緒返回時,reactor 都會檢查這個 singal_no,如果這個值不為空,那么就會調(diào)用相應(yīng)的信號回調(diào)函數(shù)

disable_accept 標志著是否接受新的連接,這個只有主 reactor 中才會設(shè)置為 0,其他 reactor 線程不需要接受新的連接,只需要接受數(shù)據(jù)即可

check_signalfd 標志著是否需要檢查 signalfd

thread 用于標記當前是使用 reactor 多線程模式還是多進程模式,一般都會使用多線程模式

timeout_msec 用于記錄每次 reactor->wait 的超時

max_socket 記錄著 reactor 中最大的連接數(shù),與 max_connection 的值一致; socket_listreactor 多線程模式的監(jiān)聽的 socket,與 connection_list 保持一致; socket_arrayreactor 多進程模式中的監(jiān)聽的 fd

handle 是默認就緒的回調(diào)函數(shù),write_handle 是寫就緒的回調(diào)函數(shù), error_handle 包含錯誤就緒的回調(diào)函數(shù)

timewheel、heartbeat_intervallast_heartbeat_time 是心跳檢測,專門剔除空閑連接

last_malloc_trim_time 記錄了上次返還給系統(tǒng)的時間,swoole 會定期的通過 malloc_trim 函數(shù)返回空閑的內(nèi)存空間

struct _swReactor
{
    void *object;
    void *ptr;  //reserve

    /**
     * last signal number
     */
    int singal_no;

    uint32_t event_num;
    uint32_t max_event_num;

    uint32_t check_timer :1;
    uint32_t running :1;
    uint32_t start :1;
    uint32_t once :1;

    /**
     * disable accept new connection
     */
    uint32_t disable_accept :1;

    uint32_t check_signalfd :1;

    /**
     * multi-thread reactor, cannot realloc sockets.
     */
    uint32_t thread :1;

    /**
     * reactor->wait timeout (millisecond) or -1
     */
    int32_t timeout_msec;

    uint16_t id; //Reactor ID
    uint16_t flag; //flag

    uint32_t max_socket;

#ifdef SW_USE_MALLOC_TRIM
    time_t last_malloc_trim_time;
#endif

#ifdef SW_USE_TIMEWHEEL
    swTimeWheel *timewheel;
    uint16_t heartbeat_interval;
    time_t last_heartbeat_time;
#endif

    /**
     * for thread
     */
    swConnection *socket_list;

    /**
     * for process
     */
    swArray *socket_array;

    swReactor_handle handle[SW_MAX_FDTYPE];        //默認事件
    swReactor_handle write_handle[SW_MAX_FDTYPE];  //擴展事件1(一般為寫事件)
    swReactor_handle error_handle[SW_MAX_FDTYPE];  //擴展事件2(一般為錯誤事件,如socket關(guān)閉)

    int (*add)(swReactor *, int fd, int fdtype);
    int (*set)(swReactor *, int fd, int fdtype);
    int (*del)(swReactor *, int fd);
    int (*wait)(swReactor *, struct timeval *);
    void (*free)(swReactor *);

    int (*setHandle)(swReactor *, int fdtype, swReactor_handle);
    swDefer_callback *defer_callback_list;
    swDefer_callback idle_task;
    swDefer_callback future_task;

    void (*onTimeout)(swReactor *);
    void (*onFinish)(swReactor *);
    void (*onBegin)(swReactor *);

    void (*enable_accept)(swReactor *);
    int (*can_exit)(swReactor *);

    int (*write)(swReactor *, int, void *, int);
    int (*close)(swReactor *, int);
    int (*defer)(swReactor *, swCallback, void *);
};
reactor 的創(chuàng)建

reactor 的創(chuàng)建主要是調(diào)用 swReactorEpoll_create 函數(shù)

setHandle 函數(shù)是為監(jiān)聽的 fd 設(shè)置回調(diào)函數(shù),包括讀就緒、寫就緒、錯誤

onFinish 是每次調(diào)用 epoll 函數(shù)返回后,處理具體邏輯后,最后調(diào)用的回調(diào)函數(shù)

onTimeout 是每次調(diào)用 epoll 函數(shù)超時后的回調(diào)函數(shù)

write 函數(shù)是利用 reactorsocket 發(fā)送數(shù)據(jù)的接口

defer 函數(shù)用于添加 defer_callback_list 成員變量,這個成員變量是回調(diào)函數(shù)列表,epoll 函數(shù)超時和 onFinish 都會循環(huán) defer_callback_list 里面的回調(diào)函數(shù)

socket_array 是監(jiān)聽的 fd 列表

int swReactor_create(swReactor *reactor, int max_event)
{
    int ret;
    bzero(reactor, sizeof(swReactor));

#ifdef HAVE_EPOLL
    ret = swReactorEpoll_create(reactor, max_event);

    reactor->running = 1;

    reactor->setHandle = swReactor_setHandle;

    reactor->onFinish = swReactor_onFinish;
    reactor->onTimeout = swReactor_onTimeout;

    reactor->write = swReactor_write;
    reactor->defer = swReactor_defer;
    reactor->close = swReactor_close;

    reactor->socket_array = swArray_new(1024, sizeof(swConnection));
    if (!reactor->socket_array)
    {
        swWarn("create socket array failed.");
        return SW_ERR;
    }

    return ret;
}
reactor 的函數(shù) reactor 設(shè)置文件就緒回調(diào)函數(shù) swReactor_setHandle

reactor 中設(shè)置的 fd 由兩部分構(gòu)成,一種是 swFd_type,標識著文件描述符的類型,一種是 swEvent_type 標識著文件描述符感興趣的讀寫事件

enum swFd_type
{
    SW_FD_TCP             = 0, //tcp socket
    SW_FD_LISTEN          = 1, //server socket
    SW_FD_CLOSE           = 2, //socket closed
    SW_FD_ERROR           = 3, //socket error
    SW_FD_UDP             = 4, //udp socket
    SW_FD_PIPE            = 5, //pipe
    SW_FD_STREAM          = 6, //stream socket
    SW_FD_WRITE           = 7, //fd can write
    SW_FD_TIMER           = 8, //timer fd
    SW_FD_AIO             = 9, //linux native aio
    SW_FD_SIGNAL          = 11, //signalfd
    SW_FD_DNS_RESOLVER    = 12, //dns resolver
    SW_FD_INOTIFY         = 13, //server socket
    SW_FD_USER            = 15, //SW_FD_USER or SW_FD_USER+n: for custom event
    SW_FD_STREAM_CLIENT   = 16, //swClient stream
    SW_FD_DGRAM_CLIENT    = 17, //swClient dgram
};

enum swEvent_type
{
    SW_EVENT_DEAULT = 256,
    SW_EVENT_READ = 1u << 9,
    SW_EVENT_WRITE = 1u << 10,
    SW_EVENT_ERROR = 1u << 11,
    SW_EVENT_ONCE = 1u << 12,
};

swReactor_fdtype 用于從文件描述符中提取 swFd_type,也就是文件描述符的類型:

static sw_inline int swReactor_fdtype(int fdtype)
{
    return fdtype & (~SW_EVENT_READ) & (~SW_EVENT_WRITE) & (~SW_EVENT_ERROR);
}

swReactor_event_read、swReactor_event_writeswReactor_event_error 這三個函數(shù)與 swFd_type 正相反,是從文件描述符中提取讀寫事件

static sw_inline int swReactor_event_read(int fdtype)
{
    return (fdtype < SW_EVENT_DEAULT) || (fdtype & SW_EVENT_READ);
}

static sw_inline int swReactor_event_write(int fdtype)
{
    return fdtype & SW_EVENT_WRITE;
}

static sw_inline int swReactor_event_error(int fdtype)
{
    return fdtype & SW_EVENT_ERROR;
}

swReactor_setHandle 用于為文件描述符 _fdtype 設(shè)定讀就緒、寫就緒的回調(diào)函數(shù)

int swReactor_setHandle(swReactor *reactor, int _fdtype, swReactor_handle handle)
{
    int fdtype = swReactor_fdtype(_fdtype);

    if (fdtype >= SW_MAX_FDTYPE)
    {
        swWarn("fdtype > SW_MAX_FDTYPE[%d]", SW_MAX_FDTYPE);
        return SW_ERR;
    }

    if (swReactor_event_read(_fdtype))
    {
        reactor->handle[fdtype] = handle;
    }
    else if (swReactor_event_write(_fdtype))
    {
        reactor->write_handle[fdtype] = handle;
    }
    else if (swReactor_event_error(_fdtype))
    {
        reactor->error_handle[fdtype] = handle;
    }
    else
    {
        swWarn("unknow fdtype");
        return SW_ERR;
    }

    return SW_OK;
}
reactor 添加 defer 函數(shù)

defer 函數(shù)會在每次事件循環(huán)結(jié)束或超時的時候調(diào)用

swReactor_defer 函數(shù)會為 defer_callback_list 添加新的回調(diào)函數(shù)

static int swReactor_defer(swReactor *reactor, swCallback callback, void *data)
{
    swDefer_callback *cb = sw_malloc(sizeof(swDefer_callback));
    if (!cb)
    {
        swWarn("malloc(%ld) failed.", sizeof(swDefer_callback));
        return SW_ERR;
    }
    cb->callback = callback;
    cb->data = data;
    LL_APPEND(reactor->defer_callback_list, cb);
    return SW_OK;
}
reactor 超時回調(diào)函數(shù)

epoll 在設(shè)置的時間內(nèi)沒有返回的話,也會自動返回,這個時候就會調(diào)用超時回調(diào)函數(shù):

static void swReactor_onTimeout(swReactor *reactor)
{
    swReactor_onTimeout_and_Finish(reactor);

    if (reactor->disable_accept)
    {
        reactor->enable_accept(reactor);
        reactor->disable_accept = 0;
    }
}

swReactor_onTimeout_and_Finish 函數(shù)用于在超時、finish 等情況下調(diào)用

這個函數(shù)首先會檢查是否存在定時任務(wù),如果有定時任務(wù)就會調(diào)用 swTimer_select 執(zhí)行回調(diào)函數(shù)

接下來就要執(zhí)行存儲在 defer_callback_list 的多個回調(diào)函數(shù), 該 list 是事先定義好的需要 defer 執(zhí)行的函數(shù)

idle_taskEventLoop 中使用的每一輪事件循環(huán)結(jié)束時調(diào)用的函數(shù)。

如果當前 reactor 當前在 work 進程,那么就要調(diào)用 swWorker_try_to_exit 函數(shù)來判斷 event_num 是不是為 0,如果為 0 ,那么就置 running 為0,停止等待事件就緒

如果當前 SwooleG.serv 為空,swReactor_empty 函數(shù)用于判斷當前 reactor 是否還有事件在監(jiān)聽,如果沒有,那么就會設(shè)置 running 為 0

判斷當前時間是否可以調(diào)用 malloc_trim 釋放空閑的內(nèi)存,如果距離上次釋放內(nèi)存的時間超過了 SW_MALLOC_TRIM_INTERVAL,就更新 last_malloc_trim_time 并調(diào)用 malloc_trim

static void swReactor_onTimeout_and_Finish(swReactor *reactor)
{
    //check timer
    if (reactor->check_timer)
    {
        swTimer_select(&SwooleG.timer);
    }
    //defer callback
    swDefer_callback *cb, *tmp;
    swDefer_callback *defer_callback_list = reactor->defer_callback_list;
    reactor->defer_callback_list = NULL;
    LL_FOREACH(defer_callback_list, cb)
    {
        cb->callback(cb->data);
    }
    LL_FOREACH_SAFE(defer_callback_list, cb, tmp)
    {
        sw_free(cb);
    }
    //callback at the end
    if (reactor->idle_task.callback)
    {
        reactor->idle_task.callback(reactor->idle_task.data);
    }
#ifdef SW_COROUTINE
    //coro timeout
    if (!swIsMaster())
    {
        coro_handle_timeout();
    }
#endif
    //server worker
    swWorker *worker = SwooleWG.worker;
    if (worker != NULL)
    {
        if (SwooleWG.wait_exit == 1)
        {
            swWorker_try_to_exit();
        }
    }
    //not server, the event loop is empty
    if (SwooleG.serv == NULL && swReactor_empty(reactor))
    {
        reactor->running = 0;
    }

#ifdef SW_USE_MALLOC_TRIM
    if (SwooleG.serv && reactor->last_malloc_trim_time < SwooleG.serv->gs->now - SW_MALLOC_TRIM_INTERVAL)
    {
        malloc_trim(SW_MALLOC_TRIM_PAD);
        reactor->last_malloc_trim_time = SwooleG.serv->gs->now;
    }
#endif
}

swReactor_empty 用來判斷當前的 reactor 是否還有事件需要監(jiān)聽

可以從函數(shù)中可以看出來,如果定時任務(wù) timer 里面還有等待的任務(wù),那么就可以返回 false

event_num 如果為 0,可以返回 true,結(jié)束事件循環(huán)

對于協(xié)程來說,還要調(diào)用 can_exit 來判斷是否可以退出事件循環(huán)

int swReactor_empty(swReactor *reactor)
{
    //timer
    if (SwooleG.timer.num > 0)
    {
        return SW_FALSE;
    }

    int empty = SW_FALSE;
    //thread pool
    if (SwooleAIO.init && reactor->event_num == 1 && SwooleAIO.task_num == 0)
    {
        empty = SW_TRUE;
    }
    //no event
    else if (reactor->event_num == 0)
    {
        empty = SW_TRUE;
    }
    //coroutine
    if (empty && reactor->can_exit && reactor->can_exit(reactor))
    {
        empty = SW_TRUE;
    }
    return empty;
}
reactor 事件循環(huán)結(jié)束函數(shù)

每次事件循環(huán)結(jié)束之后,都會調(diào)用 onFinish 函數(shù)

該函數(shù)主要函數(shù)調(diào)用 swReactor_onTimeout_and_Finish,在此之前還會檢查在事件循環(huán)過程中是否有信號觸發(fā)

static void swReactor_onFinish(swReactor *reactor)
{
    //check signal
    if (reactor->singal_no)
    {
        swSignal_callback(reactor->singal_no);
        reactor->singal_no = 0;
    }
    swReactor_onTimeout_and_Finish(reactor);
}
reactor 事件循環(huán)關(guān)閉函數(shù)

當一個 socket 關(guān)閉的時候,會調(diào)用 close 函數(shù),對應(yīng)的回調(diào)函數(shù)就是 swReactor_close

該函數(shù)用于釋放 swConnection 內(nèi)部申請的內(nèi)存,并調(diào)用 close 函數(shù)關(guān)閉連接

int swReactor_close(swReactor *reactor, int fd)
{
    swConnection *socket = swReactor_get(reactor, fd);
    if (socket->out_buffer)
    {
        swBuffer_free(socket->out_buffer);
    }
    if (socket->in_buffer)
    {
        swBuffer_free(socket->in_buffer);
    }
    if (socket->websocket_buffer)
    {
        swString_free(socket->websocket_buffer);
    }
    bzero(socket, sizeof(swConnection));
    socket->removed = 1;
    swTraceLog(SW_TRACE_CLOSE, "fd=%d.", fd);
    return close(fd);
}

swReactor_get 用于從 reactor 中根據(jù)文件描述符獲取對應(yīng) swConnection 對象的場景,由于 swoole 一般都會采用 reactor 多線程模式,因此基本只會執(zhí)行 return &reactor->socket_list[fd]; 這一句。

socket_list 這個列表與 connection_list 保持一致,是事先申請的大小為 max_connection 的類型是 swConnection 的數(shù)組

socket_list 中的數(shù)據(jù)有一部分是已經(jīng)建立連接的 swConnection 的對象,有一部分僅僅是空的 swConnection,這個時候 swConnection->fd 為 0

static sw_inline swConnection* swReactor_get(swReactor *reactor, int fd)
{
    if (reactor->thread)
    {
        return &reactor->socket_list[fd];
    }
    swConnection *socket = (swConnection*) swArray_alloc(reactor->socket_array, fd);
    if (socket == NULL)
    {
        return NULL;
    }
    if (!socket->active)
    {
        socket->fd = fd;
    }
    return socket;
}
reactor 的數(shù)據(jù)寫入

如果想對一個 socket 寫入數(shù)據(jù),并不能簡單的直接調(diào)用 send 函數(shù),因為這個函數(shù)可能被信號打斷(EINTR)、可能暫時不可用(EAGAIN)、可能只寫入了部分數(shù)據(jù),也有可能寫入成功。因此,reactor 定義了一個函數(shù)專門處理寫數(shù)據(jù)這一邏輯

首先要利用 swReactor_get 取出對應(yīng)的 swConnection 對象

如果取出的對象 fd 是 0,說明這個 fd 文件描述符事先并沒有在 reactor 里面進行監(jiān)聽

如果這個 socketout_buffer 為空,那么就先嘗試利用 swConnection_send 函數(shù)調(diào)用 send 函數(shù),觀察是否可以直接把所有數(shù)據(jù)發(fā)送成功

如果返回 EINTR,那么說明被信號打斷了,重新發(fā)送即可

如果返回 EAGAIN,那么說明此時 socket 暫時不可用,此時需要將 fd 文件描述符的寫就緒狀態(tài)添加到 reactor 中,然后將數(shù)據(jù)拷貝到 out_buffer 中去

如果返回寫入的數(shù)據(jù)量小于 n,說明只寫入了部分,此時需要把沒有寫入的部分拷貝到 out_buffer 中去

如果 out_buffer 不為空,那么說明此時 socket 不可寫,那么就要將數(shù)據(jù)拷貝到 out_buffer 中去,等著 reactor 監(jiān)控到寫就緒之后,把 out_buffer 發(fā)送出去。

如果此時 out_buffer 存儲空間不足,那么就要 swYield 讓進程休眠一段時間,等待 fd 的寫就緒狀態(tài)

int swReactor_write(swReactor *reactor, int fd, void *buf, int n)
{
    int ret;
    swConnection *socket = swReactor_get(reactor, fd);
    swBuffer *buffer = socket->out_buffer;

    if (socket->fd == 0)
    {
        socket->fd = fd;
    }

    if (socket->buffer_size == 0)
    {
        socket->buffer_size = SwooleG.socket_buffer_size;
    }

    if (socket->nonblock == 0)
    {
        swoole_fcntl_set_option(fd, 1, -1);
        socket->nonblock = 1;
    }

    if (n > socket->buffer_size)
    {
        swoole_error_log(SW_LOG_WARNING, SW_ERROR_PACKAGE_LENGTH_TOO_LARGE, "data is too large, cannot exceed buffer size.");
        return SW_ERR;
    }

    if (swBuffer_empty(buffer))
    {
        if (socket->ssl_send)
        {
            goto do_buffer;
        }

        do_send:
        ret = swConnection_send(socket, buf, n, 0);

        if (ret > 0)
        {
            if (n == ret)
            {
                return ret;
            }
            else
            {
                buf += ret;
                n -= ret;
                goto do_buffer;
            }
        }
#ifdef HAVE_KQUEUE
        else if (errno == EAGAIN || errno == ENOBUFS)
#else
        else if (errno == EAGAIN)
#endif
        {
            do_buffer:
            if (!socket->out_buffer)
            {
                buffer = swBuffer_new(sizeof(swEventData));
                if (!buffer)
                {
                    swWarn("create worker buffer failed.");
                    return SW_ERR;
                }
                socket->out_buffer = buffer;
            }

            socket->events |= SW_EVENT_WRITE;

            if (socket->events & SW_EVENT_READ)
            {
                if (reactor->set(reactor, fd, socket->fdtype | socket->events) < 0)
                {
                    swSysError("reactor->set(%d, SW_EVENT_WRITE) failed.", fd);
                }
            }
            else
            {
                if (reactor->add(reactor, fd, socket->fdtype | SW_EVENT_WRITE) < 0)
                {
                    swSysError("reactor->add(%d, SW_EVENT_WRITE) failed.", fd);
                }
            }

            goto append_buffer;
        }
        else if (errno == EINTR)
        {
            goto do_send;
        }
        else
        {
            SwooleG.error = errno;
            return SW_ERR;
        }
    }
    else
    {
        append_buffer: if (buffer->length > socket->buffer_size)
        {
            if (socket->dontwait)
            {
                SwooleG.error = SW_ERROR_OUTPUT_BUFFER_OVERFLOW;
                return SW_ERR;
            }
            else
            {
                swoole_error_log(SW_LOG_WARNING, SW_ERROR_OUTPUT_BUFFER_OVERFLOW, "socket#%d output buffer overflow.", fd);
                swYield();
                swSocket_wait(fd, SW_SOCKET_OVERFLOW_WAIT, SW_EVENT_WRITE);
            }
        }

        if (swBuffer_append(buffer, buf, n) < 0)
        {
            return SW_ERR;
        }
    }
    return SW_OK;
}

文章版權(quán)歸作者所有,未經(jīng)允許請勿轉(zhuǎn)載,若此文章存在違規(guī)行為,您可以聯(lián)系管理員刪除。

轉(zhuǎn)載請注明本文地址:http://systransis.cn/yun/29218.html

相關(guān)文章

  • Swoole 源碼分析——Client模塊Send

    摘要:當此時的套接字不可寫的時候,會自動放入緩沖區(qū)中。當大于高水線時,會自動調(diào)用回調(diào)函數(shù)。寫就緒狀態(tài)當監(jiān)控到套接字進入了寫就緒狀態(tài)時,就會調(diào)用函數(shù)。如果為,說明此時異步客戶端雖然建立了連接,但是還沒有調(diào)用回調(diào)函數(shù),因此這時要調(diào)用函數(shù)。 前言 上一章我們說了客戶端的連接 connect,對于同步客戶端來說,連接已經(jīng)建立成功;但是對于異步客戶端來說,此時可能還在進行 DNS 的解析,on...

    caozhijian 評論0 收藏0
  • Swoole 源碼分析——Server模塊Stream 模式

    摘要:新建可以看到,自動采用包長檢測的方法該函數(shù)主要功能是設(shè)置各種回調(diào)函數(shù)值得注意的是第三個參數(shù)代表是否異步。發(fā)送數(shù)據(jù)函數(shù)并不是直接發(fā)送數(shù)據(jù),而是將數(shù)據(jù)存儲在,等著寫事件就緒之后調(diào)用發(fā)送數(shù)據(jù)。 swReactorThread_dispatch 發(fā)送數(shù)據(jù) reactor 線程會通過 swReactorThread_dispatch 發(fā)送數(shù)據(jù),當采用 stream 發(fā)送數(shù)據(jù)的時候,會調(diào)用 sw...

    wums 評論0 收藏0
  • Swoole 源碼分析——Reactor 模塊 ReactorEpoll

    摘要:對象的創(chuàng)建在中,最為高效的機制就是。該數(shù)據(jù)結(jié)構(gòu)中是的,用于在函數(shù)接受就緒的事件。為了能夠更為簡便在調(diào)用后獲取的類型,并不會僅僅向函數(shù)添加,而是會添加類型,該數(shù)據(jù)結(jié)構(gòu)中包含文件描述符和文件類型。 Epoll 對象的創(chuàng)建 在 linux 中,最為高效的 reactor 機制就是 epoll。swReactor 的 object 會存儲 epoll 的對象 swReactorEpoll_...

    leanxi 評論0 收藏0
  • Swoole 源碼分析——基礎(chǔ)模塊 Pipe 管道

    摘要:并沒有使用命名管道。的創(chuàng)建創(chuàng)建匿名管道就是調(diào)用函數(shù),程序自動設(shè)置管道為非阻塞式。函數(shù)同樣的獲取管道文件描述符根據(jù)來決定。模塊負責為進程創(chuàng)建與。當線程啟動的時候,會將加入的監(jiān)控當中。 前言 管道是進程間通信 IPC 的最基礎(chǔ)的方式,管道有兩種類型:命名管道和匿名管道,匿名管道專門用于具有血緣關(guān)系的進程之間,完成數(shù)據(jù)傳遞,命名管道可以用于任何兩個進程之間。swoole 中的管道都是匿名管道...

    Tikitoo 評論0 收藏0
  • Swoole 源碼分析——Server模塊Start

    摘要:是緩存區(qū)高水位線,達到了說明緩沖區(qū)即將滿了創(chuàng)建線程函數(shù)用于將監(jiān)控的存放于中向中添加監(jiān)聽的文件描述符等待所有的線程開啟事件循環(huán)利用創(chuàng)建線程,線程啟動函數(shù)是保存監(jiān)聽本函數(shù)將用于監(jiān)聽的存放到當中,并設(shè)置相應(yīng)的屬性 Server 的啟動 在 server 啟動之前,swoole 首先要調(diào)用 php_swoole_register_callback 將 PHP 的回調(diào)函數(shù)注冊到 server...

    3fuyu 評論0 收藏0

發(fā)表評論

0條評論

baukh789

|高級講師

TA的文章

閱讀更多
最新活動
閱讀需要支付1元查看
<