保证 Goroutine 在指定操作系统线程中运行

package main

import (
    "fmt"
    "runtime"
    "sync"
)

// Task 定义任务类型
type Task func()

// GUIThreadProxy 封装 GUI 线程代理
type GUIThreadProxy struct {
    taskChan chan Task
    wg       sync.WaitGroup
}

// NewGUIThreadProxy 创建一个新的 GUIThreadProxy
func NewGUIThreadProxy() *GUIThreadProxy {
    return &GUIThreadProxy{
        taskChan: make(chan Task),
    }
}

// Start 启动 GUI 线程代理
func (g *GUIThreadProxy) Start() {
    g.wg.Add(1)
    go func() {
        defer g.wg.Done()
        runtime.LockOSThread() // 锁定到当前线程
        fmt.Println("GUI thread started")
        for task := range g.taskChan {
            task() // 执行任务
        }
        fmt.Println("GUI thread stopped")
    }()
}

// EnqueueTask 将任务添加到队列
func (g *GUIThreadProxy) EnqueueTask(task Task) {
    g.taskChan <- task
}

// Stop 停止 GUI 线程代理
func (g *GUIThreadProxy) Stop() {
    close(g.taskChan)
    g.wg.Wait()
}

func main() {
    // 创建 GUI 线程代理
    guiProxy := NewGUIThreadProxy()
    guiProxy.Start()

    // 向 GUI 线程发送任务
    guiProxy.EnqueueTask(func() {
        fmt.Println("Task 1 executed in GUI thread")
    })

    guiProxy.EnqueueTask(func() {
        fmt.Println("Task 2 executed in GUI thread")
    })

    // 模拟一些其他 Goroutine 的工作
    var wg sync.WaitGroup
    for i := 0; i < 5; i++ {
        wg.Add(1)
        go func(i int) {
            defer wg.Done()
            fmt.Printf("Goroutine %d is doing some work\n", i)
        }(i)
    }
    wg.Wait()

    // 停止 GUI 线程代理
    guiProxy.Stop()
}