Проблемы с чтением данных на onSensorChanged

Question

Имеется данные на onSensorChanged , которые поступают непрерывно , пока датчик включен.

Я хочу:

1. Включите датчик на 10 секунд и считывайте данные каждые 10 секунд.
2. Выключите датчик на 20 секунд.
3. Повторяйте одно и то же непрерывно (шаги с 1 по 2).

Я использую ScheduledExecutorService.scheduleAtFixedRate для периодического чтения данных из onSensorChanged , но это не работает. Какое решение?

public class ProximityService extends Service {

    @Override
    public void onCreate() {
        HandlerThread t = new HandlerThread("ProximityServiceHandler", THREAD_PRIORITY_BACKGROUND);
        t.start();
        _serviceLooper = t.getLooper();
        _serviceHandler = new ProximityServiceHandler(_serviceLooper, this);
    }


    private final class ProximityServiceHandler extends Handler {
        private static final int ON_TIME = 10000;   // 10 seconds
        private static final int OFF_TIME = 20000;  // 20 seconds

        private void parseSensor(SensorEvent sensorEvent) {
            // data processing
        }

        @Override
        public void handleMessage(Message msg) {
            _sensorManager = ((SensorManager) getSystemService(SENSOR_SERVICE));
            if (_sensorManager != null) {

                _sensor = _sensorManager.getDefaultSensor(Sensor.TYPE_PROXIMITY);
                if (_sensor != null) {

                    _sensorEventListener = new SensorEventListener() {
                        @Override
                        public void onSensorChanged(SensorEvent sensorEvent) {

                            if (sensorEvent != null) {
                                // collect data..
                                // data available in here, but not in _sensorScheduler?
                                parseSensor(sensorEvent); 
                            }
                        }

                        @Override
                        public void onAccuracyChanged(Sensor sensor, int i) {       
                            //
                        }
                    };

                    // why this function doesn't worked ?
                    _sensorScheduler = Executors.newScheduledThreadPool(1);
                    _sensorScheduler.scheduleAtFixedRate(
                            new Runnable() {
                                @Override
                                public void run() {
                                    try {
                                        // turnon sensor
                                        _sensorManager.registerListener(_sensorEventListener, _sensor, SensorManager.SENSOR_DELAY_NORMAL);

                                        // wait to collect data from sensor
                                        Thread.sleep(ON_TIME);

                                        // send data to main thread but data not available in here?
                                         sendData(sensorEvent)

                                        // turn off sensor
                                        _sensorManager.unregisterListener(_sensorEventListener, _sensor);

                                    } catch (InterruptedException e) {
                                        e.printStackTrace();
                                    }
                                }
                            }, 0, OFF_TIME, TimeUnit.MILLISECONDS);
                }
            }
        }

    }
}

Answer 1

Я нашел решение, вызвав toast в sendData (sensorEvent) , который заставляет датчик перестать работать.

Я изменил тост , чтобы можно было вызывать из фонового потока , например:

public static void showToast(final Context context, final String text, final int duration) {
    if (context != null && text != null) {
        new Handler(context.getMainLooper()).post(new Runnable() {

            @Override
            public void run() {
                Toast.makeText(context, text, duration).show();
            }               
        });
    }
}