2

我正在使用 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
}
4

1 回答 1

1

异步回调

问题是从 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。

于 2021-06-10T12:20:00.847 回答