[NIO]dawn之Task具体解释

Posted 2020-09-20 blfbuaa

在上篇文章中，我们设置好了开发环境，接下来。我们将在了解了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配置。让我评估一下这个程序在不同平台上执行的结果。