Callable Как запретить call () возвращать значение - PullRequest
Новая
       8

Callable Как запретить call () возвращать значение

0 голосов
/ 01 сентября 2018

Есть ли способ, чтобы call () не возвращал значение до тех пор, пока, например, не будет установлено логическое значение? Так что я могу контролировать, когда futureCall.get () сделано?

Main-класс: 

ExecutorService executor = Executors.newCachedThreadPool();
Future<List<Float>> futureCall = executor.submit((Callable<List<Float>>) new AxisMeasuring(2,100,this));
List<Float> jumpValues;
try {
    jumpValues = futureCall.get();
} catch (InterruptedException | ExecutionException e) {
    e.printStackTrace();
}

Callable-класс: 

public class AxisMeasuring implements SensorEventListener, Callable<List<Float>>{

    AxisMeasuring(int _axis, final int _timeDelay, Context _context) {
        axis = _axis;
        final Context context = _context;
        timeDelay = _timeDelay;

        handler = new Handler();
        runnable = new Runnable() {
            @Override
            public void run() {
                values.add(value);

                if (!hadZeroValue && value <= 1) {
                    hadZeroValue = true;
                }
                if (hadZeroValue && value >= 12) {
                    Log.d("Debug","Point reached");
                } else {
                    handler.postDelayed(runnable, timeDelay);
                }
            }
        };
        handler.post(runnable);
    }

    @Override
    public List<Float> call() throws Exception {

        return values;
    }
}

futureCall.get () мгновенно возвращает ноль.

1 Ответ

0 голосов
/ 01 сентября 2018

Да, используйте CountDownLatch с количеством 1. 

CountDownLatch latch = new CountDownLatch(1);

и передайте эту защелку AxisMeasuring: 

public class AxisMeasuring implements SensorEventListener, Callable<List<Float>>{

    private CountDownLatch latch;

    AxisMeasuring(int _axis, final int _timeDelay, Context _context, CountDownLatch latch) {
        latch = latch;
        ...
    }

    @Override
    public List<Float> call() throws Exception {
        latch.await();  // this will get blocked until you call latch.countDown after,  for example, a Boolean is set
        return values;
    }
}

в другом потоке, вы можете вызвать latch.countDown() как сигнал.

...