// Copyright (c) 2023, the Dart project authors.  Please see the AUTHORS file
// for details. All rights reserved. Use of this source code is governed by a
// BSD-style license that can be found in the LICENSE file.

// SharedObjects=ffi_test_functions

import 'dart:async';
import 'dart:isolate';
import 'dart:ffi';

import 'callback_tests_utils.dart';

typedef SimpleAdditionType = Int32 Function(Int32, Int32);
int simpleAddition(int x, int y) {
  print("simpleAddition($x, $y)");
  return x + y;
}

void main() async {
  // The main isolate is very special and cannot be suspended (due to having an
  // active api scope throughout it's lifetime), so we run this test in a helper
  // isolate.
  const int count = 50;
  final futures = <Future>[];
  for (int i = 0; i < count; ++i) {
    futures.add(Isolate.run(() async {
      // First make the callback pointer.
      final callbackFunctionPointer =
          Pointer.fromFunction<SimpleAdditionType>(simpleAddition, 0);

      // Then cause suspenion of [Thread].
      await Future.delayed(const Duration(seconds: 1));

      // Then make use of callback.
      CallbackTest("SimpleAddition", callbackFunctionPointer).run();
    }));
  }
  await Future.wait(futures);
}