mirror of
https://gitee.com/energye/energy.git
synced 2024-11-30 10:47:57 +08:00
112 lines
2.6 KiB
Go
112 lines
2.6 KiB
Go
//----------------------------------------
|
|
//
|
|
// Copyright © yanghy. All Rights Reserved.
|
|
//
|
|
// Licensed under Apache License Version 2.0, January 2004
|
|
//
|
|
// https://www.apache.org/licenses/LICENSE-2.0
|
|
//
|
|
//----------------------------------------
|
|
|
|
// 应用主线程异步回调
|
|
package cef
|
|
|
|
import (
|
|
"github.com/energye/energy/common/imports"
|
|
"github.com/energye/golcl/lcl/api/dllimports"
|
|
"math"
|
|
"sync"
|
|
)
|
|
|
|
var (
|
|
qac = &queueAsyncCall{id: 0, calls: sync.Map{}}
|
|
applicationQueueAsyncCallFunc dllimports.ProcAddr
|
|
)
|
|
|
|
func applicationQueueAsyncCallInit() {
|
|
applicationQueueAsyncCallFunc = imports.Proc(internale_SetApplicationQueueAsyncCallFunc)
|
|
applicationQueueAsyncCallFunc.Call(applicationQueueAsyncCallEvent)
|
|
}
|
|
|
|
func applicationQueueAsyncCallProc(id uintptr) uintptr {
|
|
qac.call(id)
|
|
return 0
|
|
}
|
|
|
|
// 队列异步调用函数 id:事件id
|
|
type qacFn func(id int)
|
|
|
|
type queueCall struct {
|
|
IsSync bool
|
|
Fn qacFn
|
|
Wg *sync.WaitGroup
|
|
}
|
|
|
|
type queueAsyncCall struct {
|
|
id uintptr
|
|
calls sync.Map
|
|
}
|
|
|
|
// LCL UI
|
|
//
|
|
// 1.在UI主进程中执行, 队列异步调用-适用大多场景(包括UI线程和非UI线程)
|
|
//
|
|
// 2.大多数非UI线程操作都需要使用该函数
|
|
//
|
|
// 3.在任何变更UI的操作都有可能导致UI线程不一至出现程序错误或程序崩溃, 可以尝试使用该回调函数解决.
|
|
//
|
|
// 4.在windows linux macos 可同时使用
|
|
func QueueAsyncCall(fn qacFn) int {
|
|
id := qac.set(&queueCall{
|
|
IsSync: false,
|
|
Fn: fn,
|
|
})
|
|
imports.Proc(internale_CEFApplication_QueueAsyncCall).Call(id)
|
|
return int(id)
|
|
}
|
|
|
|
// LCL UI
|
|
//
|
|
// 1.在UI主进程中执行, 队列异步调用-适用大多场景(非UI线程)
|
|
//
|
|
// 2.大多数非UI线程操作都需要使用该函数
|
|
//
|
|
// 3.在任何变更UI的操作都有可能导致UI线程不一至出现程序错误或程序崩溃, 可以尝试使用该回调函数解决.
|
|
//
|
|
// 4.在windows linux macos 需要注意使用场景, 当非UI线程使用时正常执行, UI线程使用时会造成UI线程锁死, 这种情况建议使用 QueueAsyncCall 自己增加同步锁
|
|
func QueueSyncCall(fn qacFn) int {
|
|
qc := &queueCall{
|
|
IsSync: true,
|
|
Fn: fn,
|
|
Wg: &sync.WaitGroup{},
|
|
}
|
|
qc.Wg.Add(1)
|
|
id := qac.set(qc)
|
|
imports.Proc(internale_CEFApplication_QueueAsyncCall).Call(id)
|
|
qc.Wg.Wait()
|
|
qc.Fn = nil
|
|
qc.Wg = nil
|
|
qc = nil
|
|
return int(id)
|
|
}
|
|
|
|
func (m *queueAsyncCall) call(id uintptr) {
|
|
if call, ok := m.calls.LoadAndDelete(id); ok {
|
|
qc := call.(*queueCall)
|
|
if qc.IsSync {
|
|
qc.Fn(int(id))
|
|
qc.Wg.Done()
|
|
} else {
|
|
qc.Fn(int(id))
|
|
}
|
|
}
|
|
}
|
|
func (m *queueAsyncCall) set(fn *queueCall) uintptr {
|
|
if m.id >= math.MaxUint {
|
|
m.id = 0
|
|
}
|
|
m.id++
|
|
m.calls.Store(m.id, fn)
|
|
return m.id
|
|
}
|