【KTips】在Kotlin中实现一个十分简单的自循环状态机

在平日的编码生活中,你有没有遇到过需要通过状态机来实现的逻辑呢?一个状态的轮转、事件订阅的通讯处理等。
状态机的实现方式千变万化,这里我会为你介绍一个简单的自循环状态机实现。

简单介绍

在开始之前,我先说明一下这个所谓的 “自循环状态机” ,避免歧义。这个词儿是我自己编出来的,
意为这个状态机中的 动作变换 均由状态本身来完成。

用大家都喜欢的大白话来讲,就是 “状态” 是一个 class,它自己包括了它的 “行为” —— 也就是一个可执行方法,
然后这个方法的返回值便是下一个将被 “变换”“状态”

文字表述还是缺乏力量,接下来便用代码来为你展示。

实现

类型定义

让我们来定义状态机中不断轮转的状态

public abstract class State<S : State<S>> {/*** 行为.* @return 下一个状态,或结束循环。 */public abstract operator fun invoke(): S?
}

那么最基础的抽象定义便结束了。很简单不是吗?

[!info]
根据业务需求,invoke 也可以适当地调整,比如让它变为 suspend 可挂起的。

自循环扩展

定义完了非常简单的状态类型 State,接下来就是实现它的 “自循环”。
State 的自循环其实很简单:提供一个初始状态,然后不断地循环,
invoke 的结果来代替当前的状态,直到循环结束。

但是在每一个使用状态机的地方都去写这么一些逻辑还是会有些啰嗦,
此时扩展函数便派上了用场。

我们先来看代码:

public suspend inline fun <S : State<S>> S.loop(onEach: (S) -> Boolean = { true },onNext: (S?) -> S? = { it }
): S {var state = this // 1while (onEach(state)) { // 2state().let(onNext)?.also { state = it } ?: return state // 3}return state
}

在上面的代码中,我们在 1 处定义了初始的状态,也就是 loopreceiver 参数 S
并从 2 处开始进入循环,也就是开始了我们状态的"自循环"。

每一次循环我们都会执行当前状态 state 的行为逻辑 invoke,并将它的返回结果设置为当前状态,
如此循环往复,直到循环终止,或者行为逻辑 invoke 返回了 null,并最终向 loop 返回最后一个被执行的状态。

除了状态本身,自循环扩展函数 loop 提供了两个用来干涉循环流程的函数 onEachonNext 来使得 loop 更加灵活,
而得益于 Kotlin 的内联函数,它们几乎不会带来什么副作用。

简单用法

纸上得来终觉浅,我们用一个简单的例子来看看这个状态机是如何使用的。
我们假设有一个订阅事件的逻辑如下:

获取10次
开始
接收事件
结束

那么用代码来实现的话大概就可以是这个样子:

fun main() {Start.loop()
}/** 三个状态的统一类型 */
sealed class MyState : State<MyState>()/** 代表开始。 */
data object Start : MyState() {override fun invoke(): MyState {// 进入 '接收事件' 阶段,此处假设给它分配了一个idreturn Receive(Random.nextLong())}
}/** 代表接收事件。有一个计数器,到达10后结束 */
data class Receive(val id: Long) : MyState() {var times = 0override fun invoke(): MyState {// 达到10次以上,结束此状态循环,进入结束状态if (times >= 10) {return Done}println("times = $times")// 递增计数,并返回自身,也就是继续保持 Receive 状态times++return this}
}/** 代表结束。 */
data object Done : MyState() {override fun invoke(): MyState? {// 结束状态可以再做一些什么操作,然后返回 null 终止循环println("Done!")return null}
}

结尾

以上就是一个简单的自循环状态机的实现啦!怎么样,是不是很简单呢?

如果有帮助到你,我的荣幸~

本文来自互联网用户投稿,该文观点仅代表作者本人,不代表本站立场。本站仅提供信息存储空间服务,不拥有所有权,不承担相关法律责任。如若转载,请注明出处:http://www.mzph.cn/web/6244.shtml

如若内容造成侵权/违法违规/事实不符,请联系多彩编程网进行投诉反馈email:809451989@qq.com,一经查实,立即删除!

相关文章

C# Web控件与数据感应之 CheckBoxList 类

目录 关于数据感应 CheckBoxList 类 范例运行环境 数据源表设计 角色字典表 用户角色表 AutoValueDBList 方法 原理 设计 实现 调用示例 初始化数据 启动查询模式 使用保存模式 小结 关于数据感应 数据感应也即数据捆绑&#xff0c;是一种动态的&#xff0c;We…

PostgreSQL的扩展pgpool

PostgreSQL的扩展pgpool pgpool-II&#xff08;通常简称为 pgpool&#xff09;是一个流行的 PostgreSQL 中间件&#xff0c;广泛用于连接池、负载均衡、自动故障转移等场景。作为一种高级数据库解决方案&#xff0c;pgpool 能够在多个 PostgreSQL 服务器之间分配数据库查询&am…

base64解码时报错“decode base64: invalid input“

现象 用base64 -d 去还原base64编码后的文件时报错decode base64: invalid input 例如: $ base64 test.zip | base64 -d > test2.zip base64: invalid input $ ll test* -rw-r--r-- 1 user grp 152 19 11:41 test.zip -rw-r--r-- 1 user grp 57 19 11:42 test2.zip解决办…

【Docker学习】docker version查看版本信息

就像很多应用一样&#xff0c;docker也使用version来查看版本信息。但因为docker包含有不少独立组件&#xff0c;version的作用范围会更广一些。 用法1&#xff1a; docker --version 描述&#xff1a; 输出安装的Docker CLI 的版本号。关于Docker CLI&#xff0c;请访问。 实操…

项目管理-项目范围管理2/2

项目管理&#xff1a;每天进步一点点~ 活到老&#xff0c;学到老 ヾ(◍∇◍)&#xff89;&#xff9e; 何时学习都不晚&#xff0c;加油 项目范围管理&#xff0c;过程 6个&#xff0c;包括“规收定 创确控”&#xff1a; 规划范围管理收集需求定义范围创建WBS确认范围控制…

【YOLOv8报错】ModuleNotFoundError: No module named ‘lap‘

文章目录 【问题描述】【解决方式】【参考链接】 【问题描述】 使用YOLOv8进行追踪运行代码时报错&#xff1a;ModuleNotFoundError: No module named lap 【解决方式】 执行以下命令 pip install lapx【参考链接】 https://github.com/ultralytics/ultralytics/issues/177…

怎么证明E[E(X|Y,Z)Y]= E(X|Y)

性质8的证明 物理意义

Python词频统计

在Python中进行词频统计是一项基础的文本分析任务&#xff0c;通常涉及以下步骤&#xff1a; 文本预处理&#xff1a;包括去除标点符号、转换为小写、去除停用词等。分词&#xff1a;将文本分割成单词或词汇。统计词频&#xff1a;对分词后的结果进行计数。 以下是一个简单的…

webpack基础---常用loader

webpack 命令式和配置文件 html-webpack-plugin 配置项&#xff1a;{ templete: filename: inject: } 清除上次打包的文件&#xff0c;output: { clear: true } mode选项&#xff1a; none development prodution souce-map&#xff1a;可以精准定位代码行数 { devt…

【Android学习】简易计算器的实现

1.项目基础目录 新增dimens.xml 用于控制全部按钮的尺寸。图片资源放在drawable中。 另外 themes.xml中原来的 <style name"Theme.Learn" parent"Theme.MaterialComponents.DayNight.DarkActionBar">变为了&#xff0c;加上后可针对button中增加图片…

发卡授权盗u系统源码ZHU

2024最新UI发卡盗U/支持多语言/更新UI界面/支持多个主流钱包去除后门板&#xff0c; 搭建系统TGaqxm01&#xff0c;最好是部署智能合约后用合约地址来授权包含转账支付页面盗U授权源码。 完美提U&#xff0c;教程包含如何提u 。功能完美。 1.Php静态 2.目录puicta 3.扩sal 4.s…

机车 - 什么是点火正时

摩托车发动机点火正时简介 当摩托车发动机在压缩行程将要结束时&#xff0c;发动机的火花塞会准时的点火&#xff0c;使混合气燃烧&#xff0c;产生强大膨胀压力&#xff0c;推动活塞下行作功产生动力。但是这个从燃烧到产生最大膨胀压力需要一定的时间。这就需要活塞在到达上死…

416. 分割等和子集

两维dp class Solution {public boolean canPartition(int[] nums) {int n nums.length;int sum 0;for(int i0;i<n;i){sumnums[i];}if(sum%2 ! 0)return false;int target sum/2;boolean[][] dp new boolean[n][target1];// 初始化&#xff0c;初始化dp表格的第一行元素…

Spring Boot中使用Redis和Lua脚本实现延时队列

码到三十五 &#xff1a; 个人主页 延时队列是一种常见的需求。延时队列允许我们延迟处理某些任务&#xff0c;这在处理需要等待一段时间后才能执行的操作时特别有用&#xff0c;如发送提醒、定时任务等。文中&#xff0c;将介绍如何在Spring Boot环境下使用Redis和Lua脚本来实…

C#三人飞行棋

C#三人飞行棋 #region 1控制台设置int w 50, h 30; ConsoleInit(w, h); #endregion#region 2 场景选择实例//声明一个表示场景标识的变量 E_SceneType nowSceneType new E_SceneType(); while (true) {switch (nowSceneType){case E_SceneType.Begion://开始场景逻辑Consol…

吴恩达机器学习笔记 三十七 电影推荐系统 使用特征 成本函数 协同过滤算法

以电影评分系统为例&#xff0c;令 r(i, j) 来表示用户 j 已经对电影 i 评分&#xff0c; y&#xff08;i, j&#xff09;表示评分具体是多少。 假如每部电影有自己的特征&#xff0c;那么用户 j 对电影 i 的评分预测为 w(j) * x(i) b(j) r(i, j) &#xff1a;一个用户 j 是否…

global IoT SIM解决方案

有任何关于GSMA\IOT\eSIM\RSP\业务应用场景相关的问题&#xff0c;欢迎W: xiangcunge59 一起讨论, 共同进步 (加的时候请注明: 来自CSDN-iot). Onomondo提供的全球IoT SIM卡解决方案具有以下特点和优势&#xff1a; 1. **单一全球配置文件**&#xff1a;Onomondo的SIM卡拥…

【C++风云录】破解聊天机器人开发:寻找最适合你的工具

重量级面面观&#xff1a;六大顶级聊天机器人开发工具的对比 前言 在本文中&#xff0c;我们将深入探讨六种不同的C集成聊天机器人开发工具&#xff0c;包括Botkit, DialogueFlow, Rasa, Wit.ai, IBM Watson Assistant和 Microsoft Bot Framework。每个工具都将从选择原因&am…

Flink checkpoint 源码分析- Checkpoint barrier 传递源码分析

背景 在上一篇的博客里&#xff0c;大致介绍了flink checkpoint中的触发的大体流程&#xff0c;现在介绍一下触发之后下游的算子是如何做snapshot。 上一篇的文章: Flink checkpoint 源码分析- Flink Checkpoint 触发流程分析-CSDN博客 代码分析 1. 在SubtaskCheckpointCoo…

Vue3+ts(day05:ref、props、生命周期、hook)

学习源码可以看我的个人前端学习笔记 (github.com):qdxzw/frontlearningNotes 觉得有帮助的同学&#xff0c;可以点心心支持一下哈&#xff08;笔记是根据b站上学习的尚硅谷的前端视频【张天禹老师】&#xff0c;记录一下学习笔记&#xff0c;用于自己复盘&#xff0c;有需要学…