c - Flutter (Dart) ffi - 应用程序在处理外部库方法期间冻结
问题描述
我正在使用 C 库 iperf3 来测量网络。当我开始网络测试时,我的应用程序冻结并等待结果。我尝试了异步和线程,但没有任何进展。有什么建议吗?我想运行我的测试并异步调用另一个方法(充其量,再次调用这个库,但其他方法)。可能吗?
我的网络.dart
final DynamicLibrary iperfLib = Platform.isAndroid
? DynamicLibrary.open("libiperf.so")
: DynamicLibrary.process();
typedef RunTestFunc = ffi.Pointer<ffi.Uint8> Function(
ffi.Pointer<ffi.Uint8> context);
typedef RunTest = ffi.Pointer<ffi.Uint8> Function(
ffi.Pointer<ffi.Uint8> context);
RunTest _run_test = iperfLib
.lookup<ffi.NativeFunction<RunTestFunc>>('run_test')
.asFunction<RunTest>();
ffi.Pointer<ffi.Uint8> runTest(ffi.Pointer<ffi.Uint8> context) {
return _run_test(context);
}
和iperf.c
Iperf* run_test(Iperf* test) {
__android_log_print( ANDROID_LOG_INFO, "DONE ", "server_hostname %s", test->server_hostname );
int cc = iperf_run_client( test ) ;
__android_log_print( ANDROID_LOG_INFO, "DONE ", " %d",cc );
iperf_free_test( test );
return test
}
解决方案
异步回调
问题是从 dart 调用的 C 例程被阻塞,因此阻塞了单个现有的 dart 隔离,从而冻结了 UI。
要解决此问题,您必须在 dart 隔离上打开一个端口,您的 C 例程可以通过该端口异步向 dart 隔离发送消息。要通知 dart 编译器这是一个非阻塞操作,只需延迟函数的完成,直到接收到指定端口上的消息。
Future<int> asyncData() async {
var receiveData;
bool receivedCallback = false;
var receivePort = ReceivePort()..listen((data) {
print('Received data from c');
receiveData = data;
receivedCallback = true;
});
var nativeSendPort = receivePort.sendPort.nativePort;
nativeTriggerFunction(nativeSendPort);
while(!receivedCallback) {
await Future.delayed(Duration(milliseconds: 100));
}
receivePort.close();
return receiveData;
}
在 C 中,您需要创建一个理想情况下应该尽可能轻量级的触发函数,将端口号传递给您的 C 代码并调用您想要在不同线程上执行的实际函数。触发函数几乎会立即完成,允许您的 dart 线程执行其他工作,并且一旦新创建的线程完成,它就会通过本机端口将其结果发送回 dart 隔离,该隔离可以从中断处继续。
void native_trigger_function(Dart_Port port) {
pthread_t t;
Dart_Port *args= malloc(sizeof(Dart_Port));
pthread_create(&t, NULL, _native_function, args);
}
void *_native_function(void *args) {
Dart_Port port = *(Dart_Port *)args;
int rc = 0;
// do some heavy work
// send return code to dart
Dart_CObject obj;
obj.type = Dart_CObject_kInt32;
obj.value.as_int32 = rc;
Dart_PostCObject_DL(args_c.send_port, &obj);
free(args);
pthread_exit(NULL);
}
注意:这个逻辑依赖于本地 dart api 工作,可以在这里找到。在使用之前,需要将接口附加到当前的 dart 隔离,这可以通过Dart_InitializeApiDL(dart_api_data)
从 C 中调用来实现,其中dart_api_data
是一个 void 指针,可以使用 dart:ffi 包从您的 dart 代码中获取NativeApi.initializeApiData
。
推荐阅读
- ios - alamofire 没有准备正确的网址
- java - 多维数组java
- javascript - HTML 元素在 Javascript for 循环中添加,然后在计数器增加时删除
- r - 在 R 中需要帮助子集和顺序标记主数据文件
- ios - 如何在 Swift 中使用协议初始化 UIViews 和 UIViewControllers
- c# - C# / LINQ 新手,查询中的分组无法解决
- c# - 调用 Application.Calculate 中断正在编辑的公式
- machine-learning - 机器学习中超参数和启发式的区别?
- python-2.7 - Python:将一个键值对转换为字典中的字符串
- java - 带有自签名证书的 SSLHandshakeException