aceld / aceld/kis-flow

使用Connector进行并流时,可能会出现数据未准备好的情况

Offen
#28 1 Kommentar 0 Reaktionen 0 zugewiesene Personen Auf GitHub ansehen
Vorherrschende Sprache
Go
Sterne
409
Forks
34
PR-Merge-Kennzahlen
Keine gemergten PRs in 30 T.

Beschreibung

# 出现的问题
在示例8中,数据流图:
![image](https://github.com/aceld/kis-flow/assets/90942167/04b7ecd7-749f-4dd7-808d-6fb39ac68fee)
## 问题的描述
在程序中开启两个Goroutine分别执行Flow1和Flow2,如果Flow2执行到Function2,要执行Load操作时,Flow1并未到Function3并完成Save操作,就会出现下面的错误:
```
LoadScoreAvg12(): GetStuScoresByStuId err = avg_score not found for stuId: 101
context.Background
Function Called Error err = avg_score not found for stuId: 101

->Call Func SaveScoreScore12
panic: avg_score not found for stuId: 101
```
## 可能的方案
是否能在Connector中添加方法判断数据是否成功存储(Save),如果数据并未被加载完成,当前Function会阻塞等待,直到数据存储完成后再执行Load并进行后续操作

Beitragsleitfaden

Für dieses Repository ist kein Beitragsleitfaden indexiert

Bewertung

Dieses Issue wurde noch nicht bewertet.

Neue Issues direkt in Ihr Postfach

Eine kurze Übersicht über anfängerfreundliche GitHub-Issues.