//處理完成時(shí)候的回調(diào),一般都是成功回調(diào)
Future<R> then<R>(FutureOr<R> onValue(T value), {Function onError});
//處理失敗的回調(diào),比如throw一個(gè)error就會(huì)走到這里
Future<T> catchError(Function onError, {bool test(Object error)});
//Future.whenComplete總是在Future完成后調(diào)用，不管Future的結(jié)果是正確的還是錯(cuò)誤的。
Future<T> whenComplete(FutureOr action());

import 'dart:io';
 
main(List<String> args) {
  // 阻塞主線程的調(diào)用
  // blockMainThread();
  // 異步調(diào)用
  asyncMethod();
}
 
/*****----- 異步的調(diào)用方式 ---***/
void asyncMethod() {
  /**
   * main start
    main end
    hello world
   * */
  print("main start");
  var future = getAsyncNetworkData();
  future.then((String value) {
    // 只有拿到結(jié)果 才會(huì)執(zhí)行這里面的代碼
    print(value);
  }).catchError((error) {
    // 打印結(jié)果 Exception: 我是錯(cuò)誤信息
    print(error);
  }).whenComplete(() {
    // 代碼走這，不管成功或者失敗都會(huì)走這里
    print("代碼執(zhí)行完畢");
  });
  print("main end");
}
 
Future<String> getAsyncNetworkData() {
  return Future<String>(() {
    sleep(Duration(seconds: 3));
    // return "hello world";
 
    // 拋出異常
    throw Exception("我是錯(cuò)誤信息");
  });
}
 
/*****----- 阻塞主線程的調(diào)用方式 ---***/
void blockMainThread() {
  /**
   * main start
    this is hello world
    main end
   * 
  */
  print("main start");
  var res = getNetworkData();
  print(res);
  print("main end");
}
 
// 模擬網(wǎng)絡(luò)請(qǐng)求
String getNetworkData() {
  // 阻塞2秒
  sleep(Duration(seconds: 2));
  return "this is hello world";
}

import 'dart:io';
 
main(List<String> args) {
  print("main start");
  /**
   * main start
    main end
    第一次網(wǎng)絡(luò)請(qǐng)求的結(jié)果
    第二次網(wǎng)路請(qǐng)求的結(jié)果
    第三次網(wǎng)路請(qǐng)求的結(jié)果
   * 
   * */
  // 這種方式可以解決回調(diào)地獄的問(wèn)題 多個(gè)網(wǎng)絡(luò)請(qǐng)求依賴也不用進(jìn)行嵌套調(diào)用 直接鏈?zhǔn)秸{(diào)用即可
  Future(() {
    // 這是第一次網(wǎng)絡(luò)請(qǐng)求
    sleep(Duration(seconds: 2));
    return "第一次網(wǎng)絡(luò)請(qǐng)求的結(jié)果";
  })
      .then((res) {
        print(res);
        sleep(Duration(seconds: 2));
        // 這是第二次網(wǎng)絡(luò)請(qǐng)求
        return "第二次網(wǎng)路請(qǐng)求的結(jié)果";
      })
      .then((res) {
        print(res);
        sleep(Duration(seconds: 2));
        return "第三次網(wǎng)路請(qǐng)求的結(jié)果";
      })
      .then((value) => print(value))
      .catchError((error) {
        print(error);
      });
  print("main end");
}

import 'dart:io';
 
main(List<String> args) {
  print("main start");
  // getData();
  futureMethodData();
  print("main end");
}
 
// future 的實(shí)現(xiàn)方式
futureMethodData() {
  Future(() {
    // 這是第一次網(wǎng)絡(luò)請(qǐng)求
    sleep(Duration(seconds: 2));
    return "這是第一次網(wǎng)絡(luò)請(qǐng)求結(jié)果";
  }).then((value) {
    print(value);
    sleep(Duration(seconds: 2));
    return value + "這是第二次網(wǎng)絡(luò)請(qǐng)求結(jié)果";
  }).then((value) {
    print(value);
    sleep(Duration(seconds: 2));
    return value + "這是第三次網(wǎng)絡(luò)請(qǐng)求結(jié)果";
  }).then((value) {
    print(value);
  });
}
 
// async-await 的實(shí)現(xiàn)方式
getData() async {
  // 模擬三次網(wǎng)絡(luò)請(qǐng)求
  /**
   * 
   * main start
    main end
    args1helloworld
    args1helloworldhelloworld
    args1helloworldhelloworldhelloworld
   */
  var res1 = await getNetworkData("args1");
  print(res1);
  var res2 = await getNetworkData(res1);
  print(res2);
  var res3 = await getNetworkData(res2);
  print(res3);
}
 
getNetworkData(String args) {
  return Future(() {
    sleep(Duration(seconds: 2));
    return args + "helloworld";
  });
}

import 'dart:io';
import 'dart:isolate';
 
main(List<String> args) async {
  print("main start");
  // 1
  ReceivePort receivePort = ReceivePort();
  // 2  spawn 返回的是future 所以要異步操作
  Isolate isolate =
      await Isolate.spawn<SendPort>(calculate, receivePort.sendPort);
 
  // 可以給創(chuàng)建的isolate 中發(fā)送消息
  receivePort.sendPort.send("這是從main isolate 發(fā)送的消息");
 
  //3 監(jiān)聽創(chuàng)建的isolate的回調(diào)信息
  receivePort.listen((message) {
    print(message);
    // 收到結(jié)果 關(guān)閉 kill
    receivePort.close();
    isolate.kill();
  });
 
  print("main end");
}
 
calculate(SendPort port) {
  // 模擬耗時(shí)操作
  sleep(Duration(seconds: 2));
  // 回調(diào)信息
  port.send("這是從創(chuàng)建的isolate 發(fā)送的信息");
}