在上篇文章中,我们设置好了开发环境,接下来,我们将在了解了Task以及Buffer之后,再开始了解网络编程。我们首先来看看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异常,会怎样呢?你可以试试,熟悉一下这个错误场景吧,它是我们的老朋友的,以后会常遇到。
注意:构造函数
未完,待更新
时间: 2024-10-14 11:19:24