Как можно избежать циклических зависимостей при использовании обратных вызовов?
-
02-07-2019 - |
Вопрос
Как вы можете избежать циклических зависимостей при разработке двух классов с отношениями производитель / потребитель?Здесь ListenerImpl нужна ссылка на Broadcaster, чтобы зарегистрироваться / отменить регистрацию, а Broadcaster нужна обратная ссылка на Слушателей, чтобы отправлять сообщения.Этот пример написан на Java, но он может быть применим к любому OO-языку.
public interface Listener {
void callBack(Object arg);
}
public class ListenerImpl implements Listener {
public ListenerImpl(Broadcaster b) { b.register(this); }
public void callBack(Object arg) { ... }
public void shutDown() { b.unregister(this); }
}
public class Broadcaster {
private final List listeners = new ArrayList();
public void register(Listener lis) { listeners.add(lis); }
public void unregister(Listener lis) {listeners.remove(lis); }
public void broadcast(Object arg) { for (Listener lis : listeners) { lis.callBack(arg); } }
}
Решение
Я не вижу в этом циклической зависимости.
Слушатель ни от чего не зависит.
ListenerImpl зависит от Слушателя и Вещателя
Вещатель зависит от Слушателя.
Listener
^ ^
/ \
/ \
Broadcaster <-- ListenerImpl
Все стрелки заканчиваются на Listener.Здесь нет цикла.Так что, я думаю, с тобой все в порядке.
Другие советы
Какой-нибудь язык ООП?ОК.Вот десятиминутная версия на английском языке.
Структура вещания
(defclass broadcaster ()
((listeners :accessor listeners
:initform '())))
(defgeneric add-listener (broadcaster listener)
(:documentation "Add a listener (a function taking one argument)
to a broadcast's list of interested parties"))
(defgeneric remove-listener (broadcaster listener)
(:documentation "Reverse of add-listener"))
(defgeneric broadcast (broadcaster object)
(:documentation "Broadcast an object to all registered listeners"))
(defmethod add-listener (broadcaster listener)
(pushnew listener (listeners broadcaster)))
(defmethod remove-listener (broadcaster listener)
(let ((listeners (listeners broadcaster)))
(setf listeners (remove listener listeners))))
(defmethod broadcast (broadcaster object)
(dolist (listener (listeners broadcaster))
(funcall listener object)))
Пример подкласса
(defclass direct-broadcaster (broadcaster)
((latest-broadcast :accessor latest-broadcast)
(latest-broadcast-p :initform nil))
(:documentation "I broadcast the latest broadcasted object when a new listener is added"))
(defmethod add-listener :after ((broadcaster direct-broadcaster) listener)
(when (slot-value broadcaster 'latest-broadcast-p)
(funcall listener (latest-broadcast broadcaster))))
(defmethod broadcast :after ((broadcaster direct-broadcaster) object)
(setf (slot-value broadcaster 'latest-broadcast-p) t)
(setf (latest-broadcast broadcaster) object))
Пример кода
Lisp> (let ((broadcaster (make-instance 'broadcaster)))
(add-listener broadcaster
#'(lambda (obj) (format t "I got myself a ~A object!~%" obj)))
(add-listener broadcaster
#'(lambda (obj) (format t "I has object: ~A~%" obj)))
(broadcast broadcaster 'cheezburger))
I has object: CHEEZBURGER
I got myself a CHEEZBURGER object!
Lisp> (defparameter *direct-broadcaster* (make-instance 'direct-broadcaster))
(add-listener *direct-broadcaster*
#'(lambda (obj) (format t "I got myself a ~A object!~%" obj)))
(broadcast *direct-broadcaster* 'kitty)
I got myself a KITTY object!
Lisp> (add-listener *direct-broadcaster*
#'(lambda (obj) (format t "I has object: ~A~%" obj)))
I has object: KITTY
К сожалению, Lisp решает большинство проблем с шаблонами проектирования (таких как ваша), устраняя необходимость в них.
В отличие от ответа Гермса, я делай видите петлю.Это не цикл зависимостей, это ссылочный цикл:LI содержит объект B, объект B содержит (массив) объектов LI.Они нелегко освобождаются, и необходимо позаботиться о том, чтобы они освобождались, когда это возможно.
Один из обходных путей заключается просто в том, чтобы объект LI содержал слабую ссылку на вещателя.Теоретически, если вещатель ушел, отменять регистрацию все равно не с чем, поэтому при снятии с регистрации вы просто проверите, есть ли вещатель, у которого нужно отменить регистрацию, и сделаете это, если есть.
Я не разработчик Java, но что-то вроде этого:
public class ListenerImpl implements Listener {
public Foo() {}
public void registerWithBroadcaster(Broadcaster b){ b.register(this); isRegistered = true;}
public void callBack(Object arg) { if (!isRegistered) throw ... else ... }
public void shutDown() { isRegistered = false; }
}
public class Broadcaster {
private final List listeners = new ArrayList();
public void register(Listener lis) { listeners.add(lis); }
public void unregister(Listener lis) {listeners.remove(lis); }
public void broadcast(Object arg) { for (Listener lis : listeners) { if (lis.isRegistered) lis.callBack(arg) else unregister(lis); } }
}
Используйте слабые ссылки, чтобы разорвать цикл.
Видишь этот ответ.
Вот пример в Lua (я использую свой собственный Библиотека Ооп здесь смотрите ссылки на "Объект" в коде).
Как и в примере с CLOS Микаэля Янссона, вы можете использовать функции напрямую, устраняя необходимость определения слушателей (обратите внимание на использование '...', это переменные Lua):
Broadcaster = Object:subclass()
function Broadcaster:initialize()
self._listeners = {}
end
function Broadcaster:register(listener)
self._listeners[listener] = true
end
function Broadcaster:unregister(listener)
self._listeners[listener] = nil
end
function Broadcaster:broadcast(...)
for listener in pairs(self._listeners) do
listener(...)
end
end
Придерживаясь вашей реализации, вот пример, который, я думаю, может быть написан на любом динамическом языке:
--# Listener
Listener = Object:subclass()
function Listener:callback(arg)
self:subclassResponsibility()
end
--# ListenerImpl
function ListenerImpl:initialize(broadcaster)
self._broadcaster = broadcaster
broadcaster:register(this)
end
function ListenerImpl:callback(arg)
--# ...
end
function ListenerImpl:shutdown()
self._broadcaster:unregister(self)
end
--# Broadcaster
function Broadcaster:initialize()
self._listeners = {}
end
function Broadcaster:register(listener)
self._listeners[listener] = true
end
function Broadcaster:unregister(listener)
self._listeners[listener] = nil
end
function Broadcaster:broadcast(arg)
for listener in pairs(self._listeners) do
listener:callback(arg)
end
end