Реализация LocationListener в служебном потоке - PullRequest
Новая
       16

Реализация LocationListener в служебном потоке

2 голосов
/ 12 марта 2012

Я пытаюсь запустить обновления местоположения в фоновом режиме. Служба запускает рабочую поток самостоятельно, выполняя множество других вещей, таких как общение через сокеты. Я бы хотел, чтобы он также обрабатывал обновления местоположения, но, похоже, это работает только над действием. Насколько я могу прочитать, это связано с отсутствием цикла обработки сообщений на рабочем потоке. Я думаю, что мне нужно где-то использовать Looper.prepare(), но, может быть, мне нужен другой поток только для обработки запросов местоположений? Кажется, я не могу заставить эмулятор реагировать на какие-либо события, связанные с геопривязкой, поэтому я, должно быть, делаю что-то не так.

Ниже приведен сервисный код, размеченный для всех не относящихся к делу деталей. 

public class MyService extends Service implements LocationListener {
    private Thread runner;
    private volatile boolean keepRunning;
    private LocationManager locationManager = null;


    @Override
    public void onCreate() {
        keepRunning = true;

        runner = new Thread(null, new Runnable() {
            public void run() { workerLoop(); }
        });
        runner.start();
        startGps();
    }

    @Override
    public void onDestroy() {
        keepRunning = false;
        runner.interrupt();
    }

    private void workerLoop() { 
        //Looper.myLooper(); How does this work??
        //Looper.prepare();

        // Main worker loop for the service
        while (keepRunning) {
            try {
                if (commandQueue.notEmpty()) {
                    executeJob();
                } else {
                    Thread.sleep(1000);
                }
            } catch (Exception e) {
            }
        }   
        stopGps();
    }

    public void onLocationChanged(Location location) {
        // Doing something with the position...
    }       
    public void onProviderDisabled(String provider) {}
    public void onProviderEnabled(String provider) {}
    public void onStatusChanged(String provider, int status, Bundle extras) {}

    private void startGps() {
        if (locationManager == null)
            locationManager = (LocationManager) getSystemService(Context.LOCATION_SERVICE);
        if (locationManager != null) {
            Criteria criteria = new Criteria();
            criteria.setAccuracy(Criteria.ACCURACY_FINE);
            criteria.setAltitudeRequired(false);
            criteria.setBearingRequired(true);
            criteria.setCostAllowed(false);
            criteria.setSpeedRequired(true);
            String provider = locationManager.getBestProvider(criteria, true);
            if (provider != null)
                locationManager.requestLocationUpdates(provider, 10, 5, (LocationListener) this);           
        }       
    }

    private void stopGps() {
        if (locationManager != null)
            locationManager.removeUpdates((LocationListener) this);
        locationManager = null;
    }

}

1 Ответ

0 голосов
/ 12 марта 2012

LocationListener не заботится о том, находится ли он в контексте действия или службы. Вы хотите использовать местоположение uodates в вашем workerLoop (), верно? Обновления местоположения (вызов LocationListener) и workerLoop () действуют независимо друг от друга. Чтобы получить обновление местоположения для workerLoop (), вам необходимо объединить два потока. Один из способов сделать это - использовать шаблон классной доски: LocationListener записывает новое местоположение в поле вашего класса (это легко, так как оба находятся в контексте одного и того же класса): 

private Location blackboard = null;
public void onLocationChanged(final Location location) {
    if( location != null )
        this.blackboard = location;
}

private void workerLoop() {
    ...
    if( this.blackboard != null ) {
        final Location locationUpdate = this.blackboard;
        this.blackboard = null;
        // .. do something with the location
    }
    ...
}

С помощью приведенного выше кода вы можете получить условия гонки, когда LocationListener пишет на доске, пока workerLoop () читает или стирает местоположение. Эту проблему можно решить, окружив доступ к доске синхронизированным блоком, например так: 

synchronized(this) {
        this.blackboard = location
}

и аналогично в workerLoop (), и мы должны объявить классную доску изменчивой: 

private volatile Location blackboard = null;

В качестве альтернативы вы можете использовать замок, для получения более подробной информации обратитесь к документации: http://docs.oracle.com/javase/tutorial/essential/concurrency/newlocks.html

...