面试题：Flutter 异步加载数据时如何处理资源竞争和内存泄漏问题

解决资源竞争问题

使用锁机制：在 Dart 中可以使用 Lock 类来实现锁机制。例如，假设有多个异步任务需要访问共享的缓存空间：

import 'dart:async';
import 'dart:collection';
import 'package:async/async.dart';

class Cache {
  final Map<String, dynamic> _cache = {};
  final Lock _lock = Lock();

  Future<dynamic> get(String key) async {
    await _lock.synchronized(() async {
      return _cache[key];
    });
  }

  Future<void> put(String key, dynamic value) async {
    await _lock.synchronized(() async {
      _cache[key] = value;
    });
  }
}

资源池：对于网络连接等资源，可以创建资源池来管理。比如，使用 Pool 类来管理网络连接：

import 'package:pool/pool.dart';

// 创建一个网络连接池，最大连接数为5
final Pool _networkPool = Pool(5);

Future<void> makeNetworkRequest() async {
  await _networkPool.withResource(() async {
    // 这里进行网络请求操作，例如使用http库
    // 由于是从资源池获取资源，避免了多个任务同时创建过多连接
  });
}

解决内存泄漏问题

正确管理 Stream：当使用 Stream 时，确保在不需要时取消订阅。例如：

StreamSubscription? _subscription;

void startListening() {
  _subscription = Stream.periodic(const Duration(seconds: 1)).listen((event) {
    print('Received event: $event');
  });
}

void stopListening() {
  _subscription?.cancel();
  _subscription = null;
}

使用 StatefulWidget 生命周期管理：在 Flutter 中，StatefulWidget 的 dispose 方法可用于清理资源。例如，如果在 State 中创建了异步任务，在 dispose 中取消任务：

import 'dart:async';
import 'package:flutter/material.dart';

class MyWidget extends StatefulWidget {
  @override
  _MyWidgetState createState() => _MyWidgetState();
}

class _MyWidgetState extends State<MyWidget> {
  Timer? _timer;

  @override
  void initState() {
    super.initState();
    _timer = Timer.periodic(const Duration(seconds: 1), (timer) {
      // 执行一些异步任务
    });
  }

  @override
  void dispose() {
    _timer?.cancel();
    super.dispose();
  }

  @override
  Widget build(BuildContext context) {
    return Container();
  }
}

星途面试题库

面试题：Flutter 异步加载数据时如何处理资源竞争和内存泄漏问题

知识考点

面试题答案

解决资源竞争问题

解决内存泄漏问题