YunFeiyang
/
noname
1
0
Fork 0
Code Issues Pull Requests Packages Projects Releases Wiki Activity

fix announce cache memory collection.

This commit is contained in:
Rintim 2023-10-05 20:10:06 +08:00
parent 608f396d71
commit e50f757d77
No known key found for this signature in database
GPG Key ID: BE9E1EA615BACFCF
1 changed files with 18 additions and 10 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

28
game/game.js
View File

@ -339,7 +339,7 @@
announce:{ announce:{
init(){ init(){
_status._announce=document.createElement("Announce"); _status._announce=document.createElement("Announce");
_status._announce_cache=new WeakMap(); _status._announce_cache=new Map();
delete lib.announce.init; delete lib.announce.init;
}, },
//推送一个对象给所有监听了name的订阅者。 //推送一个对象给所有监听了name的订阅者。
@ -350,18 +350,20 @@
return values; return values;
}, },
//订阅name相关的事件。 //订阅name相关的事件。
subscribe(name,method,once){ subscribe(name,method){
if(_status._announce&&_status._announce_cache) { if(_status._announce&&_status._announce_cache) {
let subscribeFunction; let subscribeFunction;
if(_status._announce_cache.has(method)){ if(_status._announce_cache.has(method)){
subscribeFunction=_status._announce_cache.get(method); let records=_status._announce_cache.get(method);
subscribeFunction=records.get("Listener");
records.get("EventTargets").add(name);
} }
else{ else{
subscribeFunction=event=>{ subscribeFunction=event=>method(event.detail);
method(event.detail); let records=new Map();
if(once) _status._announce.removeEventListener(subscribeFunction); records.set("Listener",subscribeFunction);
}; records.set("EventTargets",[name]);
_status._announce_cache.set(method,subscribeFunction); _status._announce_cache.set(method,records);
} }
_status._announce.addEventListener(name,subscribeFunction); _status._announce.addEventListener(name,subscribeFunction);
} }
@ -369,8 +371,14 @@
}, },
//取消对事件name的订阅 //取消对事件name的订阅
unsubscribe(name,method){ unsubscribe(name,method){
if(_status._announce&&_status._announce_cache&&_status._announce_cache.has(method)) if(_status._announce&&_status._announce_cache&&_status._announce_cache.has(method)){
_status._announce.removeEventListener(name,_status._announce_cache.get(method)); let records=_status._announce_cache.get(method);
const listener=records.get("Listener");
let eventTargets=records.get("EventTargets");
eventTargets.remove(name);
if(eventTargets.length<=0) _status._announce_cache.remove(method);
_status._announce.removeEventListener(name,listener);
}
return method; return method;
} }
}, },