一种高性能流数据并行处理方法、设备及介质

本发明公开一种高性能流数据并行处理方法、设备及介质，涉及数据处理技术领域，包括：响应于捕获到数据包，通过流量采集线程解析得到流量记录并维护于哈希表；判断流量记录是否满足转储条件或脚本执行条件；若满足转储条件，将流量记录指针写入第一无锁队列并触发第一唤醒条件；若满足脚本执行条件，将指针写入第二无锁队列并触发第二唤醒条件；响应于第一唤醒条件，通过数据转储线程对流量记录执行批量持久化操作；响应于第二唤醒条件，通过脚本执行线程执行用户自定义脚本。本发明通过无锁队列消除线程同步开销，结合哈希表索引与条件变量唤醒，实现高吞吐低延迟的网络流数据处理。