BlackForestBytes/goext
19
0
Fork 0
Code Actions Activity

v0.0.603
Some checks failed
Build Docker and Deploy / Run goext test-suite (push) Has been cancelled
Details

Browse Source
This commit is contained in:
Mike Schwörer
2025-09-20 15:19:09 +02:00
parent c764a946ff
commit 78ad103151
2 changed files with 12 additions and 5 deletions
Download Patch File Download Diff File Expand all files Collapse all files

13
dataext/delayedCombiningInvoker.go
View File

@@ -79,10 +79,14 @@ func (d *DelayedCombiningInvoker) Request() {
}
func (d *DelayedCombiningInvoker) run() {
needsExecutorRunningCleanup := true
defer func() {
d.syncLock.Lock()
d.executorRunning.Set(false)
d.syncLock.Unlock()
if needsExecutorRunningCleanup {
d.syncLock.Lock()
d.executorRunning.Set(false)
d.syncLock.Unlock()
}
}()
for {
@@ -129,6 +133,9 @@ func (d *DelayedCombiningInvoker) run() {
_ = langext.RunPanicSafe(d.action)
// =================================================
d.executorRunning.Set(false) // ensure HasPendingRequests returns fals ein onExecutionDone listener
needsExecutorRunningCleanup = false
for _, fn := range d.onExecutionDone {
_ = langext.RunPanicSafe(fn)
}