// 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);
}