【JAVA新生】kilim版的協(xié)程

Barry_Ng 發(fā)布于2019-08-14 11:52 / 1450人閱讀

摘要：試用了一下，發(fā)現(xiàn)它是基于的主要是。于是拿的代碼改了一個純協(xié)程的版本出來。兩個都是以提供和為主要，把協(xié)程的隱藏在下面。為了搞一個更簡單的，純協(xié)程來玩，把里無關(guān)的代碼都給刪了。結(jié)果在這里和官方的版本的不同在于，添加了一個方法相當(dāng)于的。

試用了一下 http://docs.paralleluniverse.co/quasar/，發(fā)現(xiàn)它是基于JDK 1.7的（主要是fork join pool）。于是拿kilim的代碼改了一個純協(xié)程的版本出來。kilim的原始版本（https://github.com/kilim/kilim）里所有的Task都與一個Scheduler綁定，而且官方的例子里都是講怎么使用Mailbox做messaging的。這個路數(shù)和stackless python非常像。兩個都是以提供scheduler和messaging為主要api，把協(xié)程的api隱藏在下面。為了搞一個更簡單的，純協(xié)程api來玩，把kilim里無關(guān)的代碼都給刪了。結(jié)果在這里：https://github.com/taowen/kilim

和官方的版本的不同在于，Task添加了一個方法resume（相當(dāng)于greenlet的switch）。第一次執(zhí)行resume的時候就是開始執(zhí)行這個task。如果task yield了，就會中途退出。要在斷點(diǎn)繼續(xù)的話，再次調(diào)用resume。

package hello_world;

import kilim.Pausable;
import kilim.Task;

public class Main {

    public static void main(String[] args) {
        Task task = new Task() {
            @Override
            public void execute() throws Pausable {
                System.out.println("hello");
                yield();
                System.out.println("world");
            }
        };
        task.resume();
        System.out.println("hey there");
        task.resume();
    }

}

代碼輸出如下

hello
hey there
world

要想執(zhí)行的話。要預(yù)先進(jìn)行weave。其實(shí)就是一條命令java kilim.tools.Weaver -d classesDir classesDir。但是要把這條命令整合到gradle的build過程中，還是很不容易的

apply plugin: "java"
apply plugin: "application"

mainClassName = "hello_world.Main"

repositories {
    mavenCentral()
    mavenLocal()
}

configurations {
    kilim
}

dependencies {
    compile "org.slf4j:slf4j-api:1.7.5"
    compile "org.github.taowen:kilim:1.0"
    kilim "org.github.taowen:kilim:1.0"
    testCompile "junit:junit:4.11"
}

task weave(type: JavaExec) {
    classpath "$project.buildDir/classes/main"
    classpath configurations.kilim
    main = "kilim.tools.Weaver"
    args "-d", "$project.buildDir/classes/main", "$project.buildDir/classes/main"
}

classes.dependsOn(weave)

關(guān)鍵點(diǎn)在于classes.dependsOn(weave)，這樣可以讓weave在javaCompile之后，classes之前執(zhí)行。這種修改別的task的dependency的做法比ANT靈活多了。