multithreading - 从 Go 应用程序中的线程低级 C/C++ 代码层调用 Go 回调

Question

我有一个 Go 应用程序和一些 C API 函数(例如一些 Win32 API 函数)，它们异步工作并产生工作线程。此 API 函数从其中一些工作线程调用回调。线程是系统线程，由 C 代码(而不是 Go)在内部创建。现在，我想将 Go 函数作为回调传递给该 C API 函数。因此，Go 回调函数将由 C 函数在工作线程的上下文中调用，Go 应用程序不知道。

我们可以假设已经采取了安全措施，并且回调中的所有数据访问都由互斥锁适本地保护，以免干扰主 Go 代码。

问题是“Go 是否支持这样的场景？”，即回调会正常工作还是因为 Go 运行时不是为我想做的事情而设计的东西很容易在内部崩溃？

Answer 1

我进行了一个 Go 回调的实验，从 20 个本地 Windows 线程并行调用。回调增加一个变量，将元素添加到 map 并在屏幕上打印值。一切都很顺利，所以我认为在更复杂的场景中也不会出现问题。

这是我的测试的源代码供其他人使用:

proxy.h

#ifndef _PROXY_H_
#define _PROXY_H_
long threaded_c_func(long param);
#endif

proxy.c

#include "proxy.h"
#ifdef WIN32
#include <Windows.h>
#endif

#define ROUNDS 20

volatile long passed = 0;

extern long long threadedCallback(long cbidx);

DWORD WINAPI ThreadFunc(LPVOID param) {    
    threadedCallback(*((long *)param));
    InterlockedIncrement(&passed);
}

long threaded_c_func(long cbidx) {

    for (int i  = 0; i < ROUNDS; i++)
    {
        DWORD ThreadId = 0;
        CreateThread(NULL, 1024*1024, &ThreadFunc, (LPVOID) &cbidx, 0, &ThreadId);
    }
    while (passed < ROUNDS)
    {
        Sleep(100);
    }
    return ROUNDS;
} 

callbackTest.go

package main

/*
#cgo CFLAGS: -I .
#cgo LDFLAGS: -L .

#include "proxy.h"

long threaded_c_func(long param);
*/
import "C"

import (
    "fmt"
    "strconv"
    "sync"
)

var hashTable map[int32]string

var count int32
var mtx sync.Mutex

//export threadedCallback
func threadedCallback(cbidx int) C.longlong {
    mtx.Lock()
    defer mtx.Unlock()
    count++
    hashTable[count] = strconv.Itoa(int(count))
    fmt.Println("Current counter ", count)
    return C.longlong(count)
}

func main() {
    hashTable = make(map[int32]string)
    var expected C.long
    expected = C.threaded_c_func(1)
    if int32(expected) == count {
        fmt.Println("Counters match")
    } else {
        fmt.Println("Expected ", int32(expected), " got ", count)
    }
    for k, v := range hashTable {
        if strconv.Itoa(int(k)) == v {
            fmt.Println(v, " match")
        } else {
            fmt.Println(v, "don't  match")
        }
    }
}