用于按序执行一系列任务，可随时绑定（如多接口返回），可对每个步骤设置超时及响应时间。
可以将项目clone下来，里面有demo可以修改及测试，喜欢请Star⭐️
Step 1. Add it in your root build.gradle at the end of repositories:
allprojects {
repositories {
...
maven { url 'https://jitpack.io' }
}
}
Step 2. Add the dependency
dependencies {
implementation 'com.github.iostyle:ContinuousTrigger:1.0.6'
//自1.0.6版本开始，项目中的依赖方式修改为compileOnly，你需要确保自己的项目中引入了相关的依赖
implementation 'org.jetbrains.kotlinx:kotlinx-coroutines-android:x.x.x'
}
| attribute | description |
|---|---|
| id | 唯一标识符，用来注册/绑定触发器 |
| timeout | 超时时间，当前节点超时时间内没有attach将跳转到下一节点，默认值为-1 |
| chokeMode | 阻塞模式，开启阻塞模式后需要在你的业务逻辑处理完成后手动调用next |
| method | description |
|---|---|
| with | Builder模式构造注册 |
| create | Builder模式创建实例并初始化 |
| register | 实例化方式有序注册 |
| attach | 根据ID绑定触发器 |
| adjustAttach | 灵活绑定 (since V1.0.6) |
| next | 下一步(阻塞模式下需手动调用) |
| cancel | 根据ID取消对应触发器，如果是当前节点则自动执行下一个 |
| clear | 清空 |
| getTriggerInstance | 通过主键获取实例 |
| saveTriggerInstance | 缓存实例，无需手动调用，构造时传入主键即可 |
| removeTriggerInstance | 从缓存中移除实例，可选是否销毁 |
| clearTriggers | 清空所有缓存实例 |
- V 1.0.6
- 支持灵活绑定，无需注册，适用于无顺序要求场景灵活执行
- 替换项目中组件的依赖方式为compileOnly，减少侵入性
同时注意从这个版本开始，集成方式有所改变，你需要确保自己的项目中引入了相关的依赖
- V 1.0.5
- 支持缓存，通过主键可在任何位置获取实例进行操作
- V 1.0.4
- 支持DSL语法
- V 1.0.3
- 节点级别添加阻塞模式控制
- 移除response方法 降低代码侵入性
后续更新计划：1.延迟处理 2.动态插队 3.动态延迟插队
下面是Kotlin及Java使用时的示例代码，因为模拟了应用场景所以代码量比较多，核心代码只有注册和绑定仅此而已
/**
* 链式调用写法
*/
trigger = ContinuousTrigger.Builder()
.with(
Trigger().apply {
id = "test1"
timeout = 2000
}
)
.with(
Trigger().apply {
id = "test2"
// 应用于dialog的阻塞模式
chokeMode = true
}
)
.with(
Trigger().apply {
id = "test3"
timeout = 2000
}
)
.create()
/**
* DSL写法
*/
val t0 = Trigger().apply {
id = "test1"
timeout = 2000
}
val t1 = Trigger().apply {
id = "test2"
// 应用于dialog的阻塞模式
chokeMode = true
}
val t2 = Trigger().apply {
id = "test3"
timeout = 2000
}
//name为可选参数 设置name后通过getTriggerInstance(name)获取实例
trigger = (ContinuousTrigger.Builder("myTrigger") with t0 with t1 with t2).create()
GlobalScope.launch {
delay(1500)
withContext(Dispatchers.Main) {
trigger?.attach("test1", object : Trigger.Strike {
override fun strike() {
Log.e("trigger", "test1")
}
})
}
}
//在任何位置可以根据名字获取实例
getTriggerInstance("myTrigger")?.attach("test2", object : Trigger.Strike {
override fun strike() {
Log.e("trigger", "test2")
AlertDialog.Builder(this@MainActivity).setMessage("test2")
.setOnDismissListener {
trigger?.next()
}.show()
}
})
GlobalScope.launch {
delay(6000)
withContext(Dispatchers.Main) {
trigger?.attach("test3", object : Trigger.Strike {
override fun strike() {
Log.e("trigger", "test3")
}
})
}
}
/**
* 灵活绑定写法
*/
saveTriggerInstance("adjustTrigger")
getTriggerInstance("adjustTrigger")?.run {
adjustAttach("t1", object : Trigger.Strike {
override fun strike() {
Log.e("trigger", "t1")
AlertDialog.Builder(this@MainActivity).setMessage("t1")
.setOnDismissListener {
next()
}.show()
}
}, true)
}
getTriggerInstance("adjustTrigger")?.run {
adjustAttach(
"t2", object : Trigger.Strike {
override fun strike() {
Log.e("trigger", "t2")
GlobalScope.launch {
delay(1000)
next()
}
}
}, true
)
}
getTriggerInstance("adjustTrigger")?.adjustAttach(
"t3",
object : Trigger.Strike {
override fun strike() {
Log.e("trigger", "t3")
}
},
) Trigger t0 = new Trigger();
t0.setId("test1");
t0.setTimeout(2000);
Trigger t1 = new Trigger();
t1.setId("test2");
t1.setChokeMode(true);
Trigger t2 = new Trigger();
t2.setId("test3");
t2.setTimeout(2000);
//name为可选参数 用于在任意位置获取trigger实例
trigger = new ContinuousTrigger.Builder("myTrigger")
.with(t0)
.with(t1)
.with(t2)
.create();
new Thread(new Runnable() {
@Override
public void run() {
try {
Thread.sleep(1500);
} catch (InterruptedException e) {
e.printStackTrace();
}
runOnUiThread(new Runnable() {
@Override
public void run() {
if (trigger != null)
trigger.attach("test1", new Trigger.Strike() {
@Override
public void strike() {
Log.e("trigger", "test1");
}
});
}
});
}
}).start();
new Thread(new Runnable() {
@Override
public void run() {
runOnUiThread(new Runnable() {
@Override
public void run() {
UtilKt.getTriggerInstance("myTrigger").attach("test2", new Trigger.Strike() {
@Override
public void strike() {
Log.e("trigger", "test2");
new AlertDialog.Builder(JavaMainActivity.this).setMessage("test2")
.setOnDismissListener(new DialogInterface.OnDismissListener() {
@Override
public void onDismiss(DialogInterface dialog) {
if (trigger != null)
trigger.next();
}
}).show();
}
});
}
});
}
}).start();
new Thread(new Runnable() {
@Override
public void run() {
try {
Thread.sleep(6000);
} catch (InterruptedException e) {
e.printStackTrace();
}
runOnUiThread(new Runnable() {
@Override
public void run() {
if (trigger != null)
trigger.attach("test3", new Trigger.Strike() {
@Override
public void strike() {
Log.e("trigger", "test3");
UtilKt.removeTriggerInstance("myTrigger");
}
});
}
});
}
}).start();
React
Typescript
Django
Laravel
Facebook
Microsoft
Google
Alibaba
D3
Tencent