android-async-task

这是一个Android平台处理复杂异步任务的库
github传送门: https://github.com/gplibs/android-async-task

1. 安装方法

gradle:

dependencies {
    compile 'com.gplibs:task:1.0.0'
}

Application onCreate:

public class App extends Application {
    @Override
    public void onCreate() {
        super.onCreate();
        
        TaskProxy.init(getApplicationContext());
    }
}

---

2. 一个简单例子

如图 Task1, Task2, Task3 为一组，按先后顺序执行， 其中Task2在主线程执行， Task1, Task3在后台线程执行。

Task4, Task5 为二组，按先后顺序执行，都在后台线程执行。

一组和二组同时启动，都执行完成后，开始Task6(Task6在主线程执行)。

以下是使用该库实现上面过程的代码：

TasksSample:

public class TasksSample extends TaskProxy<TasksSample> {

    @TaskGroup(1)
    protected Task<Void> task1() {
        Log.d("TASK", "Task1 begin - isUIThread:" + isUIThread());
        sleep(1000);
        Log.d("TASK", "Task1 end");
        return VoidTask();
    }

    @UIThread
    @TaskGroup(1)
    protected Task<Void> task2() {
        Log.d("TASK", "Task2 begin - isUIThread:" + isUIThread());
        sleep(1000);
        Log.d("TASK", "Task2 end");
        return VoidTask();
    }

    @TaskGroup(1)
    protected Task<Void> task3() {
        Log.d("TASK", "Task3 begin - isUIThread:" + isUIThread());
        sleep(1000);
        Log.d("TASK", "Task3 end");
        return VoidTask();
    }

    @TaskGroup(2)
    protected Task<Void> task4() {
        Log.d("TASK", "Task4 begin - isUIThread:" + isUIThread());
        sleep(500);
        Log.d("TASK", "Task4 end");
        return VoidTask();
    }

    @TaskGroup(2)
    protected Task<Void> task5() {
        Log.d("TASK", "Task5 begin - isUIThread:" + isUIThread());
        sleep(2500);
        Log.d("TASK", "Task5 end");
        return VoidTask();
    }

    @UIThread
    protected Task<Void> task6() {
        Log.d("TASK", "Task6 begin - isUIThread:" + isUIThread());
        sleep(100);
        Log.d("TASK", "Task6 end");
        return VoidTask();
    }

    public Task<Void> doTasks() {
        Log.d("TASK", "TasksSample tasks begin");
        TaskFactory.startSync(
                getProxy().task1(),
                getProxy().task2(),
                getProxy().task3(),
                getProxy().task4(),
                getProxy().task5()
        );
        getProxy().task6().startSync();
        Log.d("TASK", "TasksSample tasks end");
        return VoidTask();
    }

    private void sleep(int ms) {
        try {
            Thread.sleep(ms);
        } catch (Exception ex) {
            ex.printStackTrace();
        }
    }

    private boolean isUIThread() {
        return Thread.currentThread().getId() == Looper.getMainLooper().getThread().getId();
    }
}

调用 TasksSample:

public class TasksActivity extends AppCompatActivity {

    TasksSample mSample = new TasksSample();

    @Override
    protected void onCreate(Bundle savedInstanceState) {
        super.onCreate(savedInstanceState);
        setContentView(R.layout.activity_tasks);

        test();
    }

    private void test() {
        Log.d("TASK", "Activity test begin");
        mSample.getProxy().doTasks().startAsync(new TaskCallback<Task<Void>>() {
            @Override
            public void run(Task<Void> task) {
                Log.d("TASK", "doTasks callback");
            }
        });
        Log.d("TASK", "Activity test end");
    }
}

运行结果:

如上 书写起来非常简洁方便；

@TaskGroup 给任务分组， @UIThread 标识在主线程执行；

多个分组的任务直接丢进 TaskFactory 内部自动根据注解执行（同一组的任务按放进的先后顺序执行）。

---

3. 有返回值的任务

Res