[nio]dawn的基本概念

1.dawn是单线程的:

为什么单线程?现实中非常多程序都是单线程的。比方redis,memcache,nodejs。mmorpgserver。。。。。

採用单线程有两大优点,首先,不须要使用锁,逻辑更easy理解,不易出错,其次,降低了切换线程时的调度成本。

2.什么是Task

dawn中使用了Task,这事实上是kilim中的协程,协程最主要的功能是挂起和恢复,这点和线程是一致的。

全部的Task都是执行在同一个线程中的,所以,从内存的可见性和一致性的角度来讲,Task之间是不须要同步的。这里有个例外。那就是IO,假设多个Task读写同一个IO设备(比方socket),那潜在是不安全的。由于数据比較大时。可能须要多次read write,此时。多个Task的数据会混在一起发送,导致接收方收到混乱的数据。所以,IO操作必须是原子的,dawn已经考虑到这一点。并在底层封装IO操作。保证了IO操作的原子性。

Task的一般性使用方法,比方做定时任务,启动一个Task。sleep一定时间。睡醒后,运行一段代码。然后再sleep,循环。。

。。

再比方server端网络连接的处理,接收到一个连接后。就能够启动一个独立的Task来专门处理这个连接,收包、解包、处理、封包、发送,一个循环搞定,就和用一个独立的线程来处理一个单个的连接一样。

那你可能会有疑问了。连接数多的话,Task岂不是过多了?没关系。和使用线程不一样,我们能够启动大量的Task。在我的机器上,使用jvm的默认配置。就能启动10万个Task。Task之间每秒能够进行200多万次切换。这么多的Task。大多数场景都能够应付了。

3.什么是NonpausableTask

从字面上看。就是不可暂停的任务,的确如此,这是一种定时任务。不能挂起、唤醒,仅仅能一次性运行完。NonpausableTask因为不涉及到挂起、恢复。所以效率更高,假设仅仅从Task切换的角度上讲。NonpausableTask的切换效率是Task的两倍左右。假设大量使用NonpausableTask的话,就等于是在进行传统的回调式的异步编程,程序复杂度会升高,假设是高频率运行的简单任务,能够考虑用NonpausableTask来替换Task,可能会提升系统吞吐量。

可是一般来讲,我们应该优先优化程序的架构、逻辑,最后再考虑NonpausableTask。

4.什么是Scheduler?

就像线程是由内核调度的一样,Task是由Scheduler调度的。比方在Task里运行sleep(2000)。就是告诉调度器,我要挂起了,两秒后你唤醒我。此时,Scheduler就会在内部做一个2秒的定时,两秒后恢复此Task的运行。

此外,Scheduler也包含了IO事件的检測以、线程间事件的派发(开发中)。比方Task正在TcpChannel.read上等待数据到来,此时Scheduler检測到了socket处于可读状态,则会唤醒Task,让Task继续运行,以读取数据。

每一个Scheduler都是一个独立的线程,所以,仅仅有在同一个Scheduler上执行的Task,才干安全的分享内存、socket等资源。

所以说。dawn事实上是能够扩展到多线程的,此部分功能尚在规划中。只是线程池相关的功能会非常快提供。

时间: 2024-08-06 19:57:43

[nio]dawn的基本概念的相关文章

Java BIO、NIO、AIO基础概念

引用别人的例子理解一下概念,以银行取款为例. 同步与异步:这两个概念与消息的通知机制有关,也就是同步的情况下,是由处理消息者自己去等待消息是否被触发,而异步的情况下是由触发机制来通知处理消息者,. ① 同步 : 自己亲自出马持银行卡到银行取钱(使用同步IO时,Java自己处理IO读写). ② 异步 : 委托一小弟拿银行卡到银行取钱,然后给你(使用异步IO时,Java将IO读写委托给OS处理,需要将数据缓冲区地址和大小传给OS(银行卡和密码),OS需要支持异步IO操作API). 阻塞与非阻塞:与程

[NIO]dawn之Task具体解释

在上篇文章中,我们设置好了开发环境,接下来.我们将在了解了Task以及Buffer之后,再開始了解网络编程.我们首先来看看Task task简单介绍 package zhmt.dawn; import kilim.Pausable; import kilim.Scheduler; import kilim.Task; //继承kilim.Task public class HelloWorld extends Task{ //覆盖execute,注意这里的Pausable异常,这个异常必须抛出.

[nio]dawn开发环境配置

为什么dawn需要特殊的开发配置? dawn使用的是kilim协程,在编码结束后需要进行代码织入.试想,如果每次写完程序,运行代码之前都手工运行一次织入程序,是多么蛋疼的一件事情.更糟糕的是,如果你没掌握织入的技巧,可能就失去了在eclipse调试java代码的机会,开发效率会大大降低.所以,我们可以编写一段ant脚本,让eclipse帮我们自动完成织入. 步骤 我们就拿dawn这个项目做为实例,只要是java工程,基本都是类似的配置.如果你不知道怎么拿到dawn源码可以点击这里:https:/

[NIO]dawn之Task详解

在上篇文章中,我们设置好了开发环境,接下来,我们将在了解了Task以及Buffer之后,再开始了解网络编程.我们首先来看看Task package zhmt.dawn; import kilim.Pausable; import kilim.Scheduler; import kilim.Task; //继承kilim.Task public class HelloWorld extends Task{ //覆盖execute,注意这里的Pausable异常,这个异常必须抛出,不能捕捉(实际上也

NIO学习系列:核心概念及基本读写

1.    引言    I/O流或者输入/输出流指的是计算机与外部世界或者一个程序与计算机的其余部分的之间的接口.新的输入/输出(NIO)库是在JDK 1.4中引入的.NIO弥补了原来的I/O的不足,它在标准Java代码中提供了高速的.面向块的I/O.   原来的I/O库与NIO最重要的区别是数据打包和传输的方式的不同,原来的 I/O 以流 的方式处理数据,而 NIO 以块 的方式处理数据.    面向流的I/O系统一次一个字节地处理数据.一个输入流产生一个字节的数据,一个输出流消费一个字节的数

Linux IO模型与Java NIO

概述看Java NIO一篇文章的时候又看到了"异步非阻塞"这个概念,一直处于似懂非懂的状态,想解释下到底什么是异步 什么是非阻塞,感觉抓不住重点.决定仔细研究一下.本文试图研究以下问题: web server原理,bio的connector与nio的connector在架构上到底什么区别? NIO的优势到底在哪里,是如何应用到实践中的? 同步/异步.阻塞/非阻塞到底是什么概念,引出的IO模型同步阻塞.同步非阻塞.异步阻塞.异步非阻塞的具体使用场景,适用的场景是怎样的? bio nio也

说说Java NIO【转】

转自:http://www.molotang.com/articles/894.html 在Java发布JDK1.4之后,NIO也随之出现了.NIO的出现实际上是为了给Java开发提供更多更多更灵活的接口,当然也是为了提高性能.我们本篇对NIO做一个概述. 0. IO的同步异步和阻塞 Java NIO就是Java New IO.但NIO也通常会和BIO和AIO放在一起来提,有人把NIO理解为non-blocking IO,即非阻塞IO.这个理解其实也是有道理的,因为NIO使得非阻塞IO成为了可能

【NIO】之IO和NIO的区别

在Java1.4之前的版本,Java对I/O的支持并不完善,开发人员在开发高性能I/O程序的时候,会面临以下几个问题: 1.没有数据缓存区,I/O性能存在问题 2.没有C/C++通道的概念,输入和输出流是相互独立的不能复用 3.同步阻塞式I/O通信(BIO),造成线程资源被长时间阻塞(致命缺陷) 4.硬件可移植性差,支持的字符集编码有限 根据UNIX网络编程的概念,I/O模型有五种 详情请查看这篇文章 UNIX五种网络I/O模型 在没有JavaNIO之前呢,基于Java的所有的所有的Socket

Nio经典工作方式

1 public void selector() throws IOException { 2 ByteBuffer buffer = ByteBuffer.allocate(1024); 3 Selector selector = Selector.open(); 4 ServerSocketChannel ssc = ServerSocketChannel.open(); 5 ssc.configureBlocking(false);//设置为非阻塞模式 6 ssc.socket().bin