Android前台服务中跨类传递传感器数据的高效方案咨询

你的问题核心是频繁创建新线程导致的资源浪费，以及依赖静态变量共享数据的不合理设计。下面是针对你的场景的高效实现方案：

1. 重构工作线程为单例模式，避免重复创建 #

把MainMeranie改成长期运行的单例线程，在前台服务启动时初始化一次，后续不再新建实例。这样既省去线程创建销毁的开销，也能自然保留内部数据（无需静态变量）。

public class MainMeranie extends Thread {
    // 单例实例，双重检查锁保证线程安全
    private static volatile MainMeranie instance;
    // 阻塞队列，用于接收传感器传来的新数据（生产者-消费者模式）
    private final BlockingQueue<SensorData> dataQueue = new LinkedBlockingQueue<>();
    // 保存历史数据的数组（非静态，单例唯一实例持有）
    private Double[] latitude = new Double[MAX_VALUE];
    private Double[] longitude = new Double[MAX_VALUE];
    private int currentIndex = 0; // 数组写入指针

    // 私有构造，禁止外部直接实例化
    private MainMeranie() {
        setName("MainMeranie-Worker");
    }

    // 获取单例实例
    public static MainMeranie getInstance() {
        if (instance == null) {
            synchronized (MainMeranie.class) {
                if (instance == null) {
                    instance = new MainMeranie();
                }
            }
        }
        return instance;
    }

    // 外部调用此方法传递传感器数据
    public void submitSensorData(Double latitude, Double longitude, Double altitude, int pressureAccuracy, Double GPSaltitude) {
        try {
            dataQueue.put(new SensorData(latitude, longitude, altitude, pressureAccuracy, GPSaltitude));
        } catch (InterruptedException e) {
            Thread.currentThread().interrupt();
        }
    }

    @Override
    public void run() {
        // 线程持续运行，直到被中断
        while (!isInterrupted()) {
            try {
                // 阻塞等待新数据到来
                SensorData data = dataQueue.take();
                // 写入历史数据数组
                if (currentIndex < MAX_VALUE) {
                    this.latitude[currentIndex] = data.latitude * 111139;
                    this.longitude[currentIndex] = data.longitude * 111139;
                    // 处理其他字段...
                    currentIndex++;
                } else {
                    // 数组满时循环覆盖，或根据需求扩容
                    currentIndex = 0;
                }
                // 执行你的业务逻辑（原run方法中的条件判断、循环等）
                processBusinessTask();
            } catch (InterruptedException e) {
                // 线程被中断，退出循环
                break;
            }
        }
    }

    // 你的业务处理逻辑
    private void processBusinessTask() {
        // 此处编写原run方法中的条件判断、循环等代码
    }

    // 内部静态类，封装传感器数据
    private static class SensorData {
        Double latitude;
        Double longitude;
        Double altitude;
        int pressureAccuracy;
        Double GPSaltitude;

        SensorData(Double latitude, Double longitude, Double altitude, int pressureAccuracy, Double GPSaltitude) {
            this.latitude = latitude;
            this.longitude = longitude;
            this.altitude = altitude;
            this.pressureAccuracy = pressureAccuracy;
            this.GPSaltitude = GPSaltitude;
        }
    }
}

2. 前台服务中的调用方式 #

在前台服务中初始化并启动单例线程，后续收到传感器数据时直接提交，无需新建线程：

public class MyForegroundService extends Service {
    @Override
    public void onCreate() {
        super.onCreate();
        // 仅初始化并启动一次工作线程
        MainMeranie.getInstance().start();
    }

    // 假设这是接收传感器数据的回调方法
    private void onSensorDataReceived(Double latitude, Double longitude, Double altitude, int pressureAccuracy, Double GPSaltitude) {
        // 提交数据给工作线程处理，无需新建线程
        MainMeranie.getInstance().submitSensorData(latitude, longitude, altitude, pressureAccuracy, GPSaltitude);
    }

    @Override
    public void onDestroy() {
        super.onDestroy();
        // 服务销毁时中断工作线程，避免内存泄漏
        MainMeranie.getInstance().interrupt();
    }

    @Nullable
    @Override
    public IBinder onBind(Intent intent) {
        return null;
    }
}

方案优势 #

• 低开销：线程仅启动一次，避免了频繁创建销毁线程的调度开销
• 数据持久化：单例实例的非静态变量自然保留历史数据，无需依赖静态变量
• 解耦安全：用阻塞队列实现生产者（传感器）和消费者（业务处理）解耦，保证数据处理的顺序性，避免并发问题
• 生命周期可控：服务销毁时可安全中断线程，防止内存泄漏

额外优化建议 #

• 若历史数据量不固定，可将数组替换为ArrayList，无需限制大小
• 若需处理大量数据，可使用ArrayBlockingQueue指定队列容量，避免内存溢出
• 若有多线程读写历史数据的需求，需添加锁或使用线程安全集合（如CopyOnWriteArrayList）

内容的提问来源于stack exchange，提问作者Pavol Švančarek