VIP_fuck 发表于 2016-06-03 10:39

回复 9# yulihua49


    多谢,这种方式没有试过。一定实际动手试试。

yulihua49 发表于 2016-06-03 10:41

本帖最后由 yulihua49 于 2016-06-03 11:04 编辑

VIP_fuck 发表于 2016-06-03 10:39 static/image/common/back.gif
回复 9# yulihua49



你可以先用着我给的两个程序,这两个程序不使用任何特殊资源,也没有特殊的系统调用,完全通用的。以后我教你怎样写yield。yield肯定是有特殊性的了。
程序在68行调用yield:
1.找到当前线程的context。找不到返回-1;(后续任务以同步阻塞完成)
2.把事件提交给epoll,作为resume的条件。
3.swapcontext,挂起这个任务,线程回到epoll_wait,可以为别人服务了。
4.一旦这个任务的事件发生了,立即由epoll_wait激活一个线程,抓取相应的context,使用setcontext,恢复任务现场,返回0.
后续的动作就是继续NONBLOCK的IO。直至完成返回。
这样上级程序还以为是同步调用完成了。哪知道都变了天了(可能不是原来那个线程了)。

VIP_fuck 发表于 2016-06-03 11:03

回复 12# yulihua49


    嗯?程序在哪儿呢?

yulihua49 发表于 2016-06-03 12:20

本帖最后由 yulihua49 于 2016-06-03 12:21 编辑

VIP_fuck 发表于 2016-06-03 11:03 static/image/common/back.gif
回复 12# yulihua49



7楼和9楼12楼有说明。

VIP_fuck 发表于 2016-06-03 13:33

回复 14# yulihua49


    多谢多谢

yulihua49 发表于 2016-06-03 15:02

本帖最后由 yulihua49 于 2016-06-03 15:16 编辑

回复 15# VIP_fuck
你就同步的先用着,将来需要异步时,加一个异步插件就行了,所有的上层程序都无需修改。
但是要注意,不能有线程锁跨越这个函数,你得想其他方法代替。因为调用之前和之后,可能不是一个线程,导致不能解锁。

看看我的用法:
            if(Lock) pthread_mutex_unlock(Lock); //线程锁不可跨AIO
            ret=sc_connect(pl,rs);
            if(Lock) pthread_mutex_lock(Lock);

另一个地方:
                pthread_mutex_lock(&nodep->mut);
                nodep->lock++;//软锁
                pthread_mutex_unlock(&nodep->mut);
      }

      pthread_rwlock_unlock(&dmlock);

      if(nodep->cmd) {
                result=nodep->cmd(gp,json_object_object_get(json,"param"),err_json);//里边可能AIO,执行之前必须解除所有的线程锁。
                pthread_mutex_lock(&nodep->mut);
                nodep->lock--;//软解锁
                pthread_mutex_unlock(&nodep->mut);




   

cokeboL 发表于 2016-06-05 17:41

本帖最后由 cokeboL 于 2016-06-05 17:42 编辑

“粘包”或者部分包“的时候阻塞卡其他连接,除非你只处理一个连接。

IanFang 发表于 2016-06-14 09:01

回复 1# VIP_fuck

论坛是个好地方,前提是你要批判的看别人的回复,有时候被误导比不懂更糟糕。


epoll有ET和LT两种模式,类似于数电里面的边缘触发和水平触发。LT当然和你理解的大多数情况差不多,除了效率高点外和poll行为表现差不多。ET模式差别就大了,何谓边缘?就是状态跳变的那一下事件才会报上来。比如说IN事件来了以后,如果你数据不读完,有可能就再也不会报了。明明有数据可读就是不通知你,这就是差别。如何保证数据读完?只能设为非阻塞读到EAGAIN为止,没有其它旁门左道的办法。




   

IanFang 发表于 2016-06-14 09:12

多看下man文档。

//..............

Anapplicationthatemploysthe EPOLLET flag should use non-blocking file descriptors to avoid having a blocking read or
       write starve a task that is handling multiple file descriptors.The suggested way to use epoll as an edge-triggered(EPOL-
       LET) interface is as follows:

            i   with non-blocking file descriptors; and

            iiby waiting for an event only after read(2) or write(2) return EAGAIN.

yulihua49 发表于 2016-06-14 20:53

IanFang 发表于 2016-06-14 09:01 static/image/common/back.gif
回复 1# VIP_fuck

论坛是个好地方,前提是你要批判的看别人的回复,有时候被误导比不懂更糟糕。

我使用LT方式。改ET没发现效率高和响应快,反而有潜在的风险。
页: 1 [2]
查看完整版本: 用 epoll 监听 socket的时候,还有必要让 socket 非阻塞吗?