Function createWorkerScript

packages/core/src/ECS/Systems/WorkerEntitySystem.ts:375–431

* @zh 创建 Worker 脚本 * @en Create Worker script

()

     * @en Create Worker script
     */
    private createWorkerScript(): string {
        const functionBody = this.extractFunctionBody(this.workerProcess.toString());
        const sharedProcessBody = this.getSharedProcessFunctionBody();
        const entityDataSize = this.config.entityDataSize;

        return `
            let sharedFloatArray = null;
            const ENTITY_DATA_SIZE = ${entityDataSize};

            self.onmessage = function(e) {
                const { type, id, entities, deltaTime, systemConfig, startIndex, endIndex, sharedBuffer } = e.data;

                try {
                    if (type === 'init' && sharedBuffer) {
                        sharedFloatArray = new Float32Array(sharedBuffer);
                        self.postMessage({ type: 'init', success: true });
                        return;
                    }

                    if (type === 'shared') {
                        if (!sharedFloatArray) {
                            self.postMessage({ id, error: 'SharedArrayBuffer not initialized' });
                            return;
                        }
                        processSharedArrayBuffer(startIndex, endIndex, deltaTime, systemConfig);
                        self.postMessage({ id, result: null });
                        return;
                    }

                    if (entities) {
                        function workerProcess(entities, deltaTime, systemConfig) {
                            ${functionBody}
                        }

                        const result = workerProcess(entities, deltaTime, systemConfig);

                        if (result && typeof result.then === 'function') {
                            result.then(finalResult => {
                                self.postMessage({ id, result: finalResult });
                            }).catch(error => {
                                self.postMessage({ id, error: error.message });
                            });
                        } else {
                            self.postMessage({ id, result });
                        }
                    }
                } catch (error) {
                    self.postMessage({ id, error: error.message });
                }
            };

            function processSharedArrayBuffer(startIndex, endIndex, deltaTime, systemConfig) {
                if (!sharedFloatArray) return;
                ${sharedProcessBody}
            }
        `;
    }