在Kotlin中,觀察者模式可以通過使用接口和擴展函數來實現。為了處理觀察者之間的依賴關系,我們可以使用以下方法:
interface Observer {
fun update(data: Any)
}
interface Subject {
fun registerObserver(observer: Observer)
fun removeObserver(observer: Observer)
fun notifyObservers(data: Any)
}
class ConcreteSubject : Subject {
private val observers = mutableListOf<Observer>()
private var data: Any? = null
override fun registerObserver(observer: Observer) {
observers.add(observer)
}
override fun removeObserver(observer: Observer) {
observers.remove(observer)
}
override fun notifyObservers(data: Any) {
this.data = data
observers.forEach { it.update(data) }
}
fun setData(data: Any) {
this.data = data
notifyObservers(data)
}
}
class ConcreteObserverA : Observer {
override fun update(data: Any) {
println("ConcreteObserverA received data: $data")
}
}
class ConcreteObserverB : Observer {
override fun update(data: Any) {
println("ConcreteObserverB received data: $data")
}
}
fun main() {
val subject = ConcreteSubject()
val observerA = ConcreteObserverA()
val observerB = ConcreteObserverB()
subject.registerObserver(observerA)
subject.registerObserver(observerB)
subject.setData("Hello, observers!")
subject.removeObserver(observerA)
subject.setData("Goodbye, observerA!")
}
在這個例子中,我們創建了一個具體的主題類ConcreteSubject
,它維護了一個觀察者列表。當主題的數據發生變化時,它會通知所有注冊的觀察者。我們還創建了兩個具體的觀察者類ConcreteObserverA
和ConcreteObserverB
,它們實現了update
方法以處理接收到的數據。
在main
函數中,我們創建了一個主題實例和兩個觀察者實例。我們將觀察者注冊到主題中,然后更改主題的數據。這將導致所有注冊的觀察者收到通知并處理數據。最后,我們從主題中刪除一個觀察者,并再次更改主題的數據,以便僅通知剩余的觀察者。