一种数据处理流程调试方法、系统及设备

1.一种数据处理流程调试方法，其特征在于，包括：利用前驱数据处理线程将数据写入至数据交换区，由后继数据处理线程读取所述数据交换区中的数据；当所述数据交换区中的数据发生变化时，产生断点事件以及读写事件；利用事件监听器监听所述断点事件以及读写事件，并向用户接口发送显示读计数、写计数指令，以及，向调试控制器发送增加断点指令；利用调试控制器根据所述断点指令构建断点队列以及根据用户接口发送的控制指令向所述数据交换区发送操作指令；所述控制指令包括继续指令、终止指令以及预览指令；所述操作指令包括增加允许读计数指令、设置数据交换区状态指令以及查看数据指令；所述数据交换区中的操作具体包括：当所述前驱数据处理线程向所述数据交换区写入数据时，若所述写计数等于所述读计数，令所述前驱数据处理线程向所述数据交换区写入数据，并触发读写事件和断点事件；当所述后继数据处理线程读取所述数据交换区的数据时，若读计数小于允许读计数，令所述后继数据处理线程读取所述数据交换区的数据，将读计数加1，并触发读写事件；当所述数据交换区接收到所述调试控制器的增加允许读计数指令时，将当前处于中断状态的数据交换区的允许读计数加1；当所述数据交换区接收到所述调试控制器的设置交换区状态指令时，将数据交换区状态置为“废弃”状态，终止执行所有数据处理线程；当所述数据交换区接收到所述调试控制器的查看数据指令时，返回所述数据交换区的当前数据；所述调试控制器中的操作具体包括：当接收到所述事件监听器的增加断点指令时，基于数据交换区标识生成断点，并插入到断点队列顶端；当接收到断点监视器的检查断点请求时，查看断点队列底端的断点，返回数据交换区标识；一个所述数据交换区标识对应一个数据交换区；当接收到所述用户接口的继续指令时，从断点队列底端取出一个断点，并根据数据交换区标识向对应的数据交换区发送增加允许读计数指令；当接收到所述用户接口的终止指令时，向数据处理流程中的所有交换区发送设置交换区状态指令；当接收到用户接口的预览指令时，查看断点队列底端的断点，并根据数据交换区标识向对应的数据交换区发送查看数据指令，并将从数据交换区获取的数据返回至所述用户接口；利用断点监视器通过所述调试控制器监视所述断点队列中的断点，并向用户接口发送显示中断状态指令；令所述断点监视器以固定时间间隔向所述调试控制器发送检查断点请求，并根据返回的数据交换区标识，向用户接口发送显示中断状态指令；所述显示中断状态指令消息中包含数据交换区标识；利用所述用户接口根据所述预览指令，显示断点位置处的数据，设定数据过滤条件，为检查数据是否符合预期提供辅助手段调试。 2.根据权利要求1所述的数据处理流程调试方法，其特征在于，利用前驱数据处理线程将数据输入至数据交换区，由后继数据处理线程读取所述数据交换区中的数据，具体包括：判断所述数据交换区状态是否为废弃状态；若是，终止数据处理线程的操作；所述数据处理线程包括前驱数据处理线程以及后继数据处理线程；若否，按照预定义的功能执行所述数据处理线程的操作。 3.根据权利要求1所述的数据处理流程调试方法，其特征在于，所述用户接口中的操作，具体包括：接收所述事件监听器的显示读计数、写计数指令，在表征数据处理流程的有向无环图上的每条边的中间位置显示当前写入和读取数据的次数；接收所述断点监视器的显示中断状态指令，取消当前显示的中断状态，根据数据交换区标识查找有向无环图中的有向边，并在有向边的中间位置显示暂停标识，以标识当前的中断位置。 4.根据权利要求1所述的数据处理流程调试方法，其特征在于，所述事件监听器中的操作具体包括：当监听到数据交换区的读写事件时，向所述用户接口发送显示读计数、写计数指令；所述显示读计数、写计数指令中包含数据交换区标识、读计数和写计数；当监听到所述数据交换区的断点事件时，向所述调试控制器发送增加断点指令；所述增加断点指令中包含数据交换区标识。 5.一种数据处理流程调试系统，其特征在于，包括：前驱数据处理线程，用于将数据写入至数据交换区，由后继数据处理线程读取所述数据交换区中的数据；数据交换区，用于当所述数据交换区中的数据发生变化时，产生断点事件以及读写事件；事件监听器，用于监听所述断点事件以及读写事件，并向用户接口发送显示读计数、写计数指令，以及，向调试控制器发送增加断点指令；调试控制器，用于根据所述断点指令构建断点队列以及根据用户接口发送的控制指令向所述数据交换区发送操作指令；所述控制指令包括继续指令、终止指令以及预览指令；所述操作指令包括增加允许读计数指令、设置数据交换区状态指令以及查看数据指令；所述数据交换区中的操作具体包括：当所述前驱数据处理线程向所述数据交换区写入数据时，若所述写计数等于所述读计数，令所述前驱数据处理线程向所述数据交换区写入数据，并触发读写事件和断点事件；当所述后继数据处理线程读取所述数据交换区的数据时，若读计数小于允许读计数，令所述后继数据处理线程读取所述数据交换区的数据，将读计数加1，并触发读写事件；当所述数据交换区接收到所述调试控制器的增加允许读计数指令时，将当前处于中断状态的数据交换区的允许读计数加1；当所述数据交换区接收到所述调试控制器的设置交换区状态指令时，将数据交换区状态置为“废弃”状态，终止执行所有数据处理线程；当所述数据交换区接收到所述调试控制器的查看数据指令时，返回所述数据交换区的当前数据；所述调试控制器中的操作具体包括：当接收到所述事件监听器的增加断点指令时，基于数据交换区标识生成断点，并插入到断点队列顶端；当接收到断点监视器的检查断点请求时，查看断点队列底端的断点，返回数据交换区标识；一个所述数据交换区标识对应一个数据交换区；当接收到所述用户接口的继续指令时，从断点队列底端取出一个断点，并根据数据交换区标识向对应的数据交换区发送增加允许读计数指令；当接收到所述用户接口的终止指令时，向数据处理流程中的所有交换区发送设置交换区状态指令；当接收到用户接口的预览指令时，查看断点队列底端的断点，并根据数据交换区标识向对应的数据交换区发送查看数据指令，并将从数据交换区获取的数据返回至所述用户接口；断点监视器，用于通过所述调试控制器监视所述断点队列中的断点，并向用户接口发送显示中断状态指令；令所述断点监视器以固定时间间隔向所述调试控制器发送检查断点请求，并根据返回的数据交换区标识，向用户接口发送显示中断状态指令；所述显示中断状态指令消息中包含数据交换区标识；用户接口，用于根据所述预览指令，显示断点位置处的数据，设定数据过滤条件，为检查数据是否符合预期提供辅助手段调试。 6.一种电子设备，其特征在于，包括存储器及处理器，所述存储器用于存储计算机程序，所述处理器运行所述计算机程序以使所述电子设备执行如权利要求1-4中任一项所述的数据处理流程调试方法。 7.一种计算机可读存储介质，其特征在于，其存储有计算机程序，所述计算机程序被处理器执行时实现如权利要求1-4中任一项所述的数据处理流程调试方法。