使用简单的等待/通知:
private interface RunnableLocationListener extends Runnable, LocationListener {}
@Override
public int onRunTask (TaskParams params) {
final Object monitor = new Object();
final AtomicBoolean located = new AtomicBoolean();
new Thread(new RunnableLocationListener() {
Context context = PeriodicCollector.this;
public void run() {
Criteria criteria = new Criteria();
criteria.setHorizontalAccuracy(Criteria.ACCURACY_HIGH);
LocationManager locationManager = locationManager = (LocationManager)PeriodicCollector.this.getSystemService(Context.LOCATION_SERVICE);
locationManager.requestSingleUpdate(criteria, this, Looper.getMainLooper());
}
@Override
public void onLocationChanged(Location location) {
// handle location here
synchronized (monitor) {
located.set(true);
monitor.notifyAll();
}
}
@Override public void onProviderDisabled(String s) {}
@Override public void onProviderEnabled(String s) {}
@Override public void onStatusChanged(String s, int i, Bundle b) {}
}).start();
int status = GcmNetworkManager.RESULT_FAILURE;
try {
synchronized (monitor) {
if (!located.get()) {
monitor.wait();
}
}
} catch (InterruptedException e) {
status = GcmNetworkManager.RESULT_SUCCESS;
}
return status;
}