nonblocking

    0热度

    1回答

    通常,RDBMS驱动程序是阻塞的,而Tornado是非阻塞服务器。这会导致在执行CRUD操作时异步使用异步,因为IOLoop将被阻止,直到SQL查询结束。 我正在使用RDBMS作为数据库(因为ACID),但它也需要Websockets编排一些奇特的功能(即推送通知)和一些使用Tornado的Google搜索之后的项目,因为两者都是通常的REST和Websockets可以在一个应用程序中实现。 浏览

    1热度

    1回答

    在一个Python模块中,我正在做一些东西。在做这些事情的过程中,我创建了一个Thrift连接。问题在于连接开始后,程序停滞在网络逻辑中。 (即阻塞)。 在模块A,我有: stuff = "do some stuff" network.ConnectionManager(host, port, ...) stuff = "do more stuff" # not getting to this

    0热度

    2回答

    This是一个类似的答案,但不是我确切想要的。我想要做以下两件事: 我想知道是否所有的字节已经发送到接收器? 另外我想知道socket的输出缓冲区的当前剩余容量,而不尝试写入它?

    2热度

    1回答

    我有一个ruby脚本,它从串口读取数据。 该数据可能是一些原始的二进制字符串,代表特定的协议数据报(我正在尝试XBee API)。 这个数据在很长的方法调用的运行要处理的,是这样的: 看序列 解析二进制数据报 解析有效载荷 变换值(即:日期从时间戳,线性回归等) 转换为JSON 插入数据库 数据收入频率比我的处理能力快。我需要做这样的事情: loop do begin res

    0热度

    1回答

    我有适用于Couchbase的微服务。我的服务必须向Couchbase询问当前ID有多少个文档:如果数量很少,我会创建另一个文档。 我的问题是,这是非阻塞的:如果我在第一次创建文档时有很多请求,第二个请求也表明文档的数量很低(因为先不要创建但文件),所以另一个新文件被创建。 为了解决这个问题,我在akka中创建了一个演员系统,每个id有一个演员,阻塞(等待)直到第一个完成。这给出了我想要的顺序。有

    1热度

    1回答

    的区别是什么时,你说的调用是无阻塞,当你说的调用是异步

    0热度

    1回答

    虽然经历了Java 7 ConcurrentHashMap的内部实现,但我注意到要设置新的Segment,我们使用的是Unsafe类,它执行Ordered write并使用Compare和Swap算法,从而支持非阻塞行为。 我的疑问是,为什么并发HashMap中不使用比较&交换算法或类似的东西,以保持读&写单链表无阻塞,而不是获取上段锁,然后写单链表?

    2热度

    1回答

    我想问一下当需要从数据库初始化actor状态时的模式。我有一个DAO,它返回Future和Normaly非阻塞消息应该发送给未来的演员完成。但这种情况是不同的。在初始化完成之前,我无法从actor邮箱收到任何消息。在等待数据库未来完成时阻止actor线程的唯一方法是?

    1热度

    1回答

    随着标准的Java java.io.DataInputStream有可能读起来像异类二进制数据: val stream = new DataInputStream(???) val i = stream.readInt() if (i > 5) { val string = stream.readUTF() ??? } else { v

    0热度

    1回答

    一般来说,围绕被动异步代码异步处理请求(play,akka,netty等)存在巨大的噱头。 以这种方式执行代码时,建议不要在任何地方阻止和使用异步库。 如果我正确理解这一点,这种方式,而不是为每个请求创建一个线程,我们最终有线程执行者为这些库带来的执行的多个部分(主要处理请求,异步调用服务执行程序,异步数据库驱动程序执行程序等) 这种方式执行最终分裂成多个线程(=在多个执行者中)。 这些异步库如何