Server
toUpdateInstances
if (ephemeral) { ephemeralInstances =toUpdateInstances;} else { persistentInstances = toUpdateInstances;}
Notifier implements Runnable { BlockingQueue<key>}
Notifier.run{ key = tasks.take()； dataStore.get(key)}
client
