Lines Matching refs:thread

143     let thread: ProcedureThread = new ProcedureThread(
148     thread.name = this.logicDataHandles[this.works.length - this.names.length];
149     this.sendMessage(thread);
150     thread.worker!.onmessageerror = (e) => {};
151     thread.worker!.onerror = (e) => {};
152     thread.id = this.works.length;
153     thread.busy = false;
154     this.works?.push(thread);
155     return thread;
158   private sendMessage(thread: ProcedureThread): void {
159     thread.worker!.onmessage = (event: MessageEvent) => {
160       thread.busy = false;
163           thread.worker!.postMessage({
174         if (Reflect.has(thread.taskMap, event.data.id)) {
176             let fun = thread.taskMap[event.data.id];
184       if (Reflect.has(thread.taskMap, event.data.id)) {
186           let fun = thread.taskMap[event.data.id];
190           Reflect.deleteProperty(thread.taskMap, event.data.id);
200     for (let thread of this.works) {
201       thread.worker!.terminate();
207     for (let thread of this.works) {
208       thread.queryFunc('clear', {}, undefined, () => {});
214     let thread: ProcedureThread | undefined;
217       thread = noBusyThreads[0];
218       thread!.queryFunc(type, args, transfer, handler);
220     return thread;
226       let thread: ProcedureThread | undefined;
229         thread = noBusyThreads[0];
230         thread!.queryFunc(type, args, transfer, (res: any, hover: any) => {