首页 > 代码库 > [NIO]dawn之Task具体解释
[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异常,这个异常必须抛出。不能捕捉(实际上也不会捕捉到这个异常) @Override public void execute() throws Pausable, Exception { System.out.println("hello world"); } public static void main(String[] args) { //创建调度器,并启动 Scheduler sch = new Scheduler(); sch.start(); //new 我们写的Task HelloWorld task = new HelloWorld(); //让task在sch中运行 task.startOn(sch); System.out.println("task started."); } }
注意Pausable这个异常。这个异常不须要catch,必须抛出,假设你的函数调用了一个抛出Pausable异常的函数,那么你的函数也必须抛出Pausable异常。为什么不须要catch呢?由于这个异常仅仅是起到一个标记的作用。标记当前函数是能够暂停的(也就是指协程的挂起、恢复)。假设一个函数是可暂停的,那么全部调用它的函数也都是可暂停的,因此他们也都须要标记自己是Pausable的。那么这个标记是什么时候起作用呢?是在执行weaver.xml的时候,这时。织入程序会扫描全部方法,假设标记了Pausable,就会插入挂起、恢复相关的代码。所以这个标记是编译时用的。真正执行的时候没什么用,执行的时候不会抛出这个异常,我们也捕捉不到。
啰嗦了一堆,代码侍奉:
package zhmt.dawn; import kilim.Pausable; import kilim.Scheduler; import kilim.Task; public class SleepTest extends Task{ //覆盖execute,注意这里的Pausable异常,这个异常必须抛出,不能捕捉(实际上也不会捕捉到这个异常) @Override public void execute() throws Pausable, Exception { System.out.println("I am tired."); sleepOneSecond(); //1秒后打印 System.out.println("I am refreshed."); } //sleepOneSecond调用了sleep,而sleep是可暂停的。所以,sleepOneSecond抛出了Pausable异常 private void sleepOneSecond() throws Pausable{ sleep(1000); } public static void main(String[] args) { //创建调度器,并启动 Scheduler sch = new Scheduler(); sch.start(); //new 我们写的Task SleepTest task = new SleepTest(); //让task在sch中运行 task.startOn(sch); } }
你可能会想假设sleepOneSecond捕捉了Pausable异常,会如何呢?你能够试试,熟悉一下这个错误场景吧,它是我们的老朋友的。以后会常遇到。
注意这里的task.startOn(sch)。这里指定了task由谁来调度。这里明白指定scheduler的原因是当前的代码是在main线程而非scheduler中运行的。假设是在scheduler中运行的代码,启动task时是不能要指定调度器的,由于会默认在当前调度器中运行。
dawn程序一般启动方法
ok。以上我们了解了task基本使用方法。以下。我从项目的有用角度来看看一看。dawn程序通常是怎样启动、初始化的(我在项目中就是这么用的):
1、创建一个主调度器,能够保存在全局变量上,方便外部线程向主调度器公布任务。
2、创建一个用于初始化的Task。把我们的整个程序从用这个task载入起来。
3、启动这个初始化task
示比例如以下,这个程序实现了这么个功能,启动若干任务。累加一个全局变量,另外一个变量打印累加速度(每秒累加几次):
/* Copyright (c) 2006, Sriram Srinivasan * * You may distribute this software under the terms of the license * specified in the file "License" */ package zhmt.dawn; //import kilim.Mailbox; import kilim.Pausable; import kilim.Scheduler; import kilim.Task; public class TestScheduler extends Task { public static void main(String[] args) throws Exception { final Scheduler sch = new Scheduler(); sch.start(); new Task(){ public void execute() throws Pausable ,Exception { for (int i = 0; i < 6000; i++) { TestScheduler s = new TestScheduler(); s.start(); } new Task() { public void execute() throws Pausable, Exception { while (true) { acc = 0; sleep(1000); System.out.println("spd:"+acc); //打印累加速度 } } }.start(); }; }.startOn(sch); } static long acc = 0; /** * The entry point. mb.get() is a blocking call that yields the thread * ("pausable") */ public void execute() throws Pausable { for (int i = 0; i < 100000000; i++) { acc++;//1毫秒累加一次 sleep(1); } } }
注意:构造函数函数不能抛出Pausable异常,会导致程序不能执行。原因我也不是十分明确。我仅仅是确保了自己的程序不犯这个错。
假设你能执行以上程序,也欢迎你把执行的结果贴出来。同一时候贴出你的操作系统以及cpu配置。让我评估一下这个程序在不同平台上执行的结果。
[NIO]dawn之Task具体解释
声明:以上内容来自用户投稿及互联网公开渠道收集整理发布,本网站不拥有所有权,未作人工编辑处理,也不承担相关法律责任,若内容有误或涉及侵权可进行投诉: 投诉/举报 工作人员会在5个工作日内联系你,一经查实,本站将立刻删除涉嫌侵权内容。