Просмотр переменной на предмет изменений без опроса - PullRequest
11 голосов
/ 13 мая 2010

Я использую инфраструктуру под названием Processing, которая в основном является Java-апплетом. У этого есть способность сделать ключевые события, потому что Апплет может. Вы также можете свернуть свои собственные обратные вызовы в родительский. Я не занимаюсь этим прямо сейчас и, возможно, это решение. Сейчас я ищу более POJO-решение. Поэтому я написал несколько примеров, иллюстрирующих мой вопрос.

Пожалуйста, не используйте ключевые события в командной строке (консоли). Конечно, это было бы очень чистым решением, но это невозможно в командной строке, и мое настоящее приложение не является приложением командной строки. На самом деле, ключевое событие было бы хорошим решением для меня, но я пытаюсь понять события и опросы, помимо проблем, связанных только с клавиатурой.

Оба эти примера переворачивают логическое значение. Когда логическое значение переворачивается, я хочу запустить что-то один раз. Я мог бы обернуть логическое значение в объект, чтобы, если объект изменился, я мог также инициировать событие. Я просто не хочу без необходимости опрашивать оператор if ().

import java.io.BufferedReader;
import java.io.IOException;
import java.io.InputStreamReader;

/*
 * Example of checking a variable for changes.
 * Uses dumb if() and polls continuously.
 */
public class NotAvoidingPolling {

    public static void main(String[] args) {

        boolean typedA = false;
        String input = "";

        System.out.println("Type 'a' please.");

        while (true) {
            InputStreamReader isr = new InputStreamReader(System.in);
            BufferedReader br = new BufferedReader(isr);

            try {
                input = br.readLine();
            } catch (IOException ioException) {
                System.out.println("IO Error.");
                System.exit(1);
            }

            // contrived state change logic
            if (input.equals("a")) {
                typedA = true;
            } else {
                typedA = false;
            }

            // problem: this is polling.
            if (typedA) System.out.println("Typed 'a'.");
        }
    }
}

Запуск этих выходов:

Type 'a' please. 
a
Typed 'a'.

На некоторых форумах люди предлагали использовать Observer. И хотя это отделяет обработчик событий от наблюдаемого класса, у меня все еще есть if () в цикле forever.

import java.io.BufferedReader;
import java.io.IOException;
import java.io.InputStreamReader;
import java.util.Observable;
import java.util.Observer;

/* 
 * Example of checking a variable for changes.
 * This uses an observer to decouple the handler feedback 
 * out of the main() but still is polling.
 */
public class ObserverStillPolling {

    boolean typedA = false;

    public static void main(String[] args) {

        // this
        ObserverStillPolling o = new ObserverStillPolling();

        final MyEvent myEvent = new MyEvent(o);
        final MyHandler myHandler = new MyHandler();
        myEvent.addObserver(myHandler); // subscribe

        // watch for event forever
        Thread thread = new Thread(myEvent);
        thread.start();

        System.out.println("Type 'a' please.");

        String input = "";

        while (true) {
            InputStreamReader isr = new InputStreamReader(System.in);
            BufferedReader br = new BufferedReader(isr);

            try {
                input = br.readLine();
            } catch (IOException ioException) {
                System.out.println("IO Error.");
                System.exit(1);
            }

            // contrived state change logic
            // but it's decoupled now because there's no handler here.
            if (input.equals("a")) {
                o.typedA = true;
            }
        }
    }
}

class MyEvent extends Observable implements Runnable {
    // boolean typedA;
    ObserverStillPolling o;

    public MyEvent(ObserverStillPolling o) {
        this.o = o;
    }

    public void run() {

        // watch the main forever
        while (true) {

            // event fire
            if (this.o.typedA) {
                setChanged();

                // in reality, you'd pass something more useful
                notifyObservers("You just typed 'a'.");

                // reset
                this.o.typedA = false;
            }

        }
    }
}

class MyHandler implements Observer {
    public void update(Observable obj, Object arg) {

        // handle event
        if (arg instanceof String) {
            System.out.println("We received:" + (String) arg);
        }
    }
}

Запуск этих выходов:

Type 'a' please.
a
We received:You just typed 'a'.

Я был бы в порядке, если бы if () был NOOP на процессоре. Но это действительно сравнение каждого прохода. Я вижу реальную загрузку процессора. Это так же плохо, как опрос. Я могу, возможно, задушить его обратно во сне или сравнить прошедшее время с момента последнего обновления, но это не обусловлено событиями. Это просто меньше опросов. Так как я могу сделать это умнее? Как я могу посмотреть POJO на изменения без опроса?

В C #, кажется, есть что-то интересное, называемое свойствами. Я не C # парень, так что, может быть, это не так волшебно, как я думаю.

private void SendPropertyChanging(string property)
{
  if (this.PropertyChanging != null) {
    this.PropertyChanging(this, new PropertyChangingEventArgs(property));
  }
}

Ответы [ 4 ]

7 голосов
/ 13 мая 2010

Да, обработка событий - ключ к вашей проблеме. Фрагмент C #, который вы показываете, также использует обработку событий, чтобы сообщить слушателям, что свойство изменено. У Java также есть эти PropertyChangeEvent, который используется для большинства Бинов. (Например: компоненты Swing используют их).

Однако вы можете сделать это вручную: (хотя это больше не POJO, а скорее Java Bean)

EventBean.java

import java.util.LinkedList;
import java.util.List;

public class EventBean {

    private final List<Listener> listeners = new LinkedList<Listener>();

    protected final <T> void firePropertyChanged(final String property,
            final T oldValue, final T newValue) {
        assert(property != null);
        if((oldValue != null && oldValue.equals(newValue))
                || (oldValue == null && newValue == null))
            return;
        for(final Listener listener : this.listeners) {
            try {
                if(listener.getProperties().contains(property))
                    listener.propertyChanged(property, oldValue, newValue);
            } catch(Exception ex) {
                // log these, to help debugging
                ex.printStackTrace();
            }
        }
    }

    public final boolean addListener(final Listener x) {
        if(x == null) return false;
        return this.listeners.add(x);
    }
    public final boolean removeListener(final Listener x) {
        return this.listeners.remove(x);
    }

}

Listener.java :

import java.util.Collections;
import java.util.Set;
import java.util.TreeSet;

// Must be in same package as EventBean!
public abstract class Listener {

    private final Set<String> properties;

    public Listener(String... properties) {
        Collections.addAll(this.properties = new TreeSet<String>(), properties);
    }

    protected final Set<String> getProperties() {
        return this.properties;
    }

    public abstract <T> void propertyChanged(final String property,
            final T oldValue, final T newValue);
}

И реализуйте свой класс так:

public class MyBean extends EventBean {

    private boolean typedA;

    public void setTypedA(final boolean newValue) {
        // you can do validation on the newValue here
        final boolean oldValue = typedA;
        super.firePropertyChanged("typedA", oldValue, newValue);
        this.typedA = newValue;
    }
    public boolean getTypedA() { return this.typedA; }

}

Который вы можете использовать как:

MyBean x = new MyBean();
x.addListener(new Listener("typedA") {
    public <T> void propertyChanged(final String p,
                 final T oldValue, final T newValue) {
        System.out.println(p + " changed: " + oldValue + " to " + newValue);
        // TODO
    }
});

x.setTypedA(true);
x.setTypedA(false);
x.setTypedA(true);
x.setTypedA(true);
7 голосов
/ 13 мая 2010

Вы неправильно понимаете шаблон наблюдателя, если ваша реализация использует опрос. В шаблоне наблюдателя метод, который изменяет состояние субъекта, будет вызывать уведомление подписанных наблюдателей до его завершения.

Очевидно, это означает, что субъект должен поддерживать шаблон наблюдателя, вы не можете использовать какой-либо простой старый Java-объект в качестве субъекта в шаблоне наблюдателя.

Возможно, вы также захотите взглянуть на пример википедии для шаблона наблюдателя .

1 голос
/ 13 мая 2010

На самом деле лишняя нить не нужна. Вы должны позволить ObserverStillPolling расширить Observable и уведомить наблюдателей, когда input.equals("a").

Да, это означает, что само POJO должно расширить Observable и уведомить об этом самих наблюдателей.


Тем не менее, Observer/Observable на самом деле плохо спроектированы. Я бы предложил доморощить свой собственный interface PropertyChangeListener и позволить вашему POJO реализовать его. Затем пусть POJO зарегистрирует себя у наблюдателя во время строительства или сделает это динамически, проверив где-нибудь значение instanceof PropertyChangeListener, если применимо.

0 голосов
/ 13 мая 2010

Возможно, решение - wait() / notify() или одна из утилит параллелизма Java. Эти конструкции избегают опроса «занят-ждать», который, похоже, является предметом вопроса.

Они используются с несколькими потоками. Один поток доставляет событие, другие отвечают на него. Вот пример:

class SyncQueue {

  private final Object lock = new Object();

  private Object o;

  /* One thread sends "event" ... */
  void send(Object o)
    throws InterruptedException
  {
    if (o == null)
      throw new IllegalArgumentException();
    synchronized (lock) {
      while (this.o != null)
        lock.wait();
      this.o = o;
      lock.notifyAll();
    }
  }

  /* Another blocks (without burning CPU) until event is received. */
  Object recv()
    throws InterruptedException
  {
    Object o;
    synchronized (lock) {
      while (this.o == null)
        lock.wait();
      o = this.o;
      this.o = null;
      lock.notifyAll();
    }
    return o;
  }

}
...