From 1f6b8b46aee067fb83329e2b34bf64f0de09fa3b Mon Sep 17 00:00:00 2001 From: guy Date: Wed, 11 Nov 2020 11:36:17 +0800 Subject: [PATCH] webworker --- dist/fix/worker.compact.js | 10 +++++++++- src/core/worker.js | 32 ++++++++++++++++++++++---------- 2 files changed, 31 insertions(+), 11 deletions(-) diff --git a/dist/fix/worker.compact.js b/dist/fix/worker.compact.js index 43264e284..00c5c0ad4 100644 --- a/dist/fix/worker.compact.js +++ b/dist/fix/worker.compact.js @@ -7,7 +7,7 @@ var _init = BI.Widget.prototype._init; BI.Widget.prototype._init = function () { - createWorker.call(this); + this.$destroyWorker = createWorker.call(this); try { _init.apply(this, arguments); } catch (e) { @@ -40,6 +40,7 @@ var unMount = BI.Widget.prototype.__d; BI.Widget.prototype.__d = function () { delete contexts[this.getName()]; + this.$destroyWorker && this.$destroyWorker(); try { unMount.apply(this, arguments); } catch (e) { @@ -84,6 +85,13 @@ return Reflect.set(target, key, value); } }); + return function () { + worker.postMessage({ + type: modelType, + name: name, + eventType: "destroy" + }); + }; } } }()); diff --git a/src/core/worker.js b/src/core/worker.js index 1e431b005..e23d73c5d 100644 --- a/src/core/worker.js +++ b/src/core/worker.js @@ -7,27 +7,39 @@ })); } - var models = {}; + var models = {}, watches = {}; addEventListener("message", function (e) { var data = e.data; switch (data.eventType) { case "action": models[data.name][data.action].apply(models[data.name], data.args); break; - default: + case "destroy": + BI.each(watches[data.name], function (i, unwatches) { + unwatches = BI.isArray(unwatches) ? unwatches : [unwatches]; + BI.each(unwatches, function (j, unwatch) { + unwatch(); + }); + }); + delete models[data.name]; + delete watches[data.name]; + break; + case "create": var store = models[data.name] = BI.Models.getModel(data.type, data.options); - for (var i = 0, len = data.watches.length; i < len; i++) { - var key = data.watches[i]; - createWatcher(store.model, key, function () { + watches[data.name] = []; + BI.each(data.watches, function (i, key) { + watches[data.name].push(createWatcher(store.model, key, function (newValue, oldValue) { postMessage(BI.extend({}, data, { eventType: "watch", currentWatchType: key - }, {args: [].slice.call(arguments, 0, 2)})); - }); - } - postMessage(BI.extend({ + }, {args: [newValue, oldValue]})); + })); + }); + postMessage(BI.extend({}, data, { eventType: "create" - }, data, {msg: store.model})); + }, {msg: store.model})); + break; + default: break; } }, false);