在上篇文章中,我们设置好了开发环境,接下来。我们将在了解了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异常,这个异常必须抛出。不能捕捉(实际上也不会捕捉到这个异常)@Overridepublic void execute() throws Pausable, Exception {System.out.println("hello world");}public static void main(String[] args) {//创建调度器,并启动Scheduler sch = new Scheduler();sch.start();//new 我们写的TaskHelloWorld 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异常,这个异常必须抛出,不能捕捉(实际上也不会捕捉到这个异常)@Overridepublic 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 我们写的TaskSleepTest 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具体解释相关推荐

  1. springcloud和dubbole的区别和解释

    对比参照表: name Dubbo springcloud 服务注册中心 Zookeeper SpringCloud Netflix Eureka 服务调用方式 RPC REST Api 服务监控 D ...

  2. 计算机领域中Task和Job的区别

    There are only two hard things in Computer Science: cache invalidation and naming things (计算科学中只有两件事 ...

  3. NIO编程之三次握手成功而服务器不响应客户端

    下面这篇推文转自微信公众号<阿里技术>:https://mp.weixin.qq.com/s/yH3PzGEFopbpA-jw4MythQ 这篇文章写的是NIO的socket通信,三次握手 ...

  4. Python 的协程

    前言 最近在看部分Python源码时, 发现了async 这个关键字. 查了一下发现了Python中的协程. 协程这玩意, 在GO中我用过啊, 简单说, 就是一个轻量级的线程嘛, 由语言自己来实现不同 ...

  5. Airflow使用入门指南

    Airflow能做什么 关注公众号, 查看更多 http://mp.weixin.qq.com/s/xPjXMc_6ssHt16J07BC7jA Airflow是一个工作流分配管理系统,通过有向非循环 ...

  6. Python实现性能测试(locust)

    一.安装locust pip install locust -- 安装(在pycharm里面安装或cmd命令行安装都可) locust -V -- 查看版本,显示了就证明安装成功了 或者直接在Pych ...

  7. Java基础教程-10-多线程

    Java基础教程-10-多线程 1. 多线程 我们在之前,学习的程序在没有跳转语句的前提下,都是由上至下依次执行,那现在想要设计一个程序,边打游戏边听歌,怎么设计? 要解决上述问题,咱们得使用多进程或 ...

  8. 透过Tracepoint理解内核 - 调度器框架和性能

    静态tracepoint预埋在内核的关键位置, 通过这些预埋的tracepoint, 可以比较容易梳理出相关模块的框架及主要流程. 相比于直接钻到scheduler的实现细节中去, 我们先通过trac ...

  9. 大数据组件之Flink简介

    一.Flink 简介 Apache Flink 是一个分布式的流处理框架,它能够对有界和无界的数据流进行高效的处理.Flink 的核心是流处理,同时它也能支持批处理,Flink 将批处理看成是流处理的 ...

  10. C# async / await 用法

    目录 一.简介 二.异步等待返回结果 三.异步方法返回类型 四.await foreach 五.Task.Delay 结束 一.简介 await 运算符暂停对其所属的 async 方法的求值,直到其操 ...

最新文章

  1. <软件过程与改进>计算大题考点总结与例题
  2. SpringSecurity简单入门
  3. XML学习(一)————XML简介
  4. day9 java的实例语句块和代码执行顺序
  5. 2017.9.10 土地购买 思考记录
  6. 安装oracle12.1  32位客户端时,出现[INS-10102]未能初始化安装程序错误
  7. 如何打开.chm文档(比如华为产品手册等)
  8. 蓝屏(BSOD)转储设置,看本文就够了!
  9. mysql 时间类型datetime与timestamp区别比较
  10. UE4.27 基于composure的虚拟制片
  11. 安卓系统双屏异显_Android10模拟器上调试双屏异显
  12. 【5G安全系列】NAS层安全密钥衍生——USIM相关密钥的衍生
  13. latex如何换页 一页放不下
  14. C++面向对象程序设计大作业:魔兽世界(三):开战
  15. 【面试总结系列】CSS 预编译器 Sass、Less、Stylus 三者之间的比较详解
  16. 碟评--梁紫丹新碟<<紫色的声音>>
  17. HP孙振耀退休感言(转载)
  18. springboot整合mybatis (三) 一对多配置
  19. 值得收藏的 104个 CSS 面试题
  20. SmartNovel——自动帮你写文章

热门文章

  1. VB.NET版+三层实现登陆
  2. NBU备份数据库时的ORA-27211错误分析解决
  3. oracle滚动打补丁,ORACLE打补丁的方法和案例
  4. kmalloc参数GFP_ATOMIC or GFP_KERNEL?
  5. Netlink 0003 -- Netlink动手实践
  6. netlink 0001 --- 基础简介
  7. IOMMU 虚拟IO地址和物理地址相关联
  8. FreeSWITCH核心命令
  9. Linux内核DMA机制
  10. 嗯....零乱知识点map和字符串转换的