From 6e3a7599d2eb6a692a7380df87b07c016c42aba4 Mon Sep 17 00:00:00 2001 From: guy Date: Wed, 11 Nov 2020 21:04:24 +0800 Subject: [PATCH] =?UTF-8?q?webworker=E5=85=BC=E5=AE=B9=E6=94=AF=E6=8C=81?= =?UTF-8?q?=E4=B8=8D=E6=94=AF=E6=8C=81=E9=83=BD=E5=8F=AF=E4=BB=A5=E4=B8=80?= =?UTF-8?q?=E6=A0=B7=E4=BD=BF=E7=94=A8?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- demo.worker.js | 6 +- dist/fix/worker.compact.js | 130 ++++++++++++++++++++++++++----------- worker.html | 6 +- 3 files changed, 100 insertions(+), 42 deletions(-) diff --git a/demo.worker.js b/demo.worker.js index 5f2491f3e..89a22ccb9 100644 --- a/demo.worker.js +++ b/demo.worker.js @@ -1,5 +1,7 @@ -importScripts("./dist/fineui_without_jquery_polyfill.js"); -BI.initWorker(); +if (this.importScripts) { + importScripts("./dist/fineui_without_jquery_polyfill.js"); + BI.initWorker(); +} var Model = BI.inherit(Fix.Model, { state: function () { return { diff --git a/dist/fix/worker.compact.js b/dist/fix/worker.compact.js index 00c5c0ad4..ecc7903ff 100644 --- a/dist/fix/worker.compact.js +++ b/dist/fix/worker.compact.js @@ -1,9 +1,9 @@ ;(function () { var contexts = {}; - var worker; + var WORKER; BI.useWorker = function (wk) { - worker = wk; + WORKER = wk; var _init = BI.Widget.prototype._init; BI.Widget.prototype._init = function () { @@ -29,7 +29,7 @@ } }; BI.Widget.prototype._initRender = function () { - if (_global.Worker && this._worker) { + if (WORKER && this._worker) { this.__asking = true; this.__async = true; } else { @@ -48,50 +48,104 @@ } }; - worker.addEventListener("message", function (e) { - var data = e.data; - postMessage.apply(contexts[data.name], [data]); - }, false); + if (WORKER) { + WORKER.addEventListener("message", function (e) { + var data = e.data; + postMessage.apply(contexts[data.name], [data]); + }, false); + } }; function createWorker () { var self = this; - if (_global.Worker && this._worker) { + if (this._worker) { var name = this.getName(); - contexts[name] = this; var modelType = this._worker(); - worker.postMessage({ - type: modelType, - name: name, - eventType: "create", - watches: BI.map(this.watch, function (key) { - return key; - }) - }); - var store = {}; - this.store = new Proxy(store, { - get (target, key) { - return function () { - worker.postMessage({ - type: modelType, - name: name, - eventType: "action", - action: key, - args: [].slice.call(arguments) - }); - }; - }, - set (target, key, value) { - return Reflect.set(target, key, value); - } - }); - return function () { - worker.postMessage({ + if (WORKER) { + contexts[name] = this; + WORKER.postMessage({ type: modelType, name: name, - eventType: "destroy" + eventType: "create", + watches: BI.map(this.watch, function (key) { + return key; + }) }); - }; + var store = {}; + this.store = new Proxy(store, { + get (target, key) { + return function () { + WORKER.postMessage({ + type: modelType, + name: name, + eventType: "action", + action: key, + args: [].slice.call(arguments) + }); + }; + }, + set (target, key, value) { + return Reflect.set(target, key, value); + } + }); + return function () { + WORKER.postMessage({ + type: modelType, + name: name, + eventType: "destroy" + }); + }; + } else { + this.store = BI.Models.getModel(modelType); + this.store && (this.store._widget = this); + if (this.store instanceof Fix.Model) { + this.model = this.store.model; + } else { + this.model = this.store; + } + initWatch(this, this.watch); + return function () { + this.store && BI.isFunction(this.store.destroy) && this.store.destroy(); + BI.each(this._watchers, function (i, unwatches) { + unwatches = BI.isArray(unwatches) ? unwatches : [unwatches]; + BI.each(unwatches, function (j, unwatch) { + unwatch(); + }); + }); + this._watchers && (this._watchers = []); + if (this.store) { + this.store._parent && (this.store._parent = null); + this.store._widget && (this.store._widget = null); + this.store = null; + } + }; + } + + } + } + + function initWatch (vm, watch) { + vm._watchers || (vm._watchers = []); + for (var key in watch) { + var handler = watch[key]; + if (BI.isArray(handler)) { + for (var i = 0; i < handler.length; i++) { + vm._watchers.push(createWatcher(vm, key, handler[i])); + } + } else { + vm._watchers.push(createWatcher(vm, key, handler)); + } + } + } + + function createWatcher (vm, keyOrFn, cb, options) { + if (BI.isPlainObject(cb)) { + options = cb; + cb = cb.handler; } + options = options || {}; + return Fix.watch(vm.model, keyOrFn, _.bind(cb, vm), BI.extend(options, { + store: vm.store + })); } }()); diff --git a/worker.html b/worker.html index 11f95b90c..3753d622d 100644 --- a/worker.html +++ b/worker.html @@ -7,12 +7,14 @@ +