/** * A thread is a running stack context and all the metadata needed. * @param {?string} firstBlock First block to execute in the thread. * @constructor */ function Thread (firstBlock) { /** * ID of top block of the thread * @type {!string} */ this.topBlock = firstBlock; /** * Stack for the thread. When the sequencer enters a control structure, * the block is pushed onto the stack so we know where to exit. * @type {Array.} */ this.stack = []; /** * Stack frames for the thread. Store metadata for the executing blocks. * @type {Array.} */ this.stackFrames = []; /** * Status of the thread, one of three states (below) * @type {number} */ this.status = 0; /* Thread.STATUS_RUNNING */ /** * Target of this thread. * @type {?Target} */ this.target = null; /** * Whether the thread requests its script to glow during this frame. * @type {boolean} */ this.requestScriptGlowInFrame = false; /** * Which block ID should glow during this frame, if any. * @type {?string} */ this.blockGlowInFrame = null; /** * A timer for when the thread enters warp mode. * Substitutes the sequencer's count toward WORK_TIME on a per-thread basis. * @type {?Timer} */ this.warpTimer = null; } /** * Thread status for initialized or running thread. * This is the default state for a thread - execution should run normally, * stepping from block to block. * @const */ Thread.STATUS_RUNNING = 0; /** * Threads are in this state when a primitive is waiting on a promise; * execution is paused until the promise changes thread status. * @const */ Thread.STATUS_PROMISE_WAIT = 1; /** * Thread status for yield. * @const */ Thread.STATUS_YIELD = 2; /** * Thread status for a single-tick yield. This will be cleared when the * thread is resumed. * @const */ Thread.STATUS_YIELD_TICK = 3; /** * Thread status for a finished/done thread. * Thread is in this state when there are no more blocks to execute. * @const */ Thread.STATUS_DONE = 4; /** * Push stack and update stack frames appropriately. * @param {string} blockId Block ID to push to stack. */ Thread.prototype.pushStack = function (blockId) { this.stack.push(blockId); // Push an empty stack frame, if we need one. // Might not, if we just popped the stack. if (this.stack.length > this.stackFrames.length) { // Copy warp mode from any higher level. var warpMode = false; if (this.stackFrames[this.stackFrames.length - 1]) { warpMode = this.stackFrames[this.stackFrames.length - 1].warpMode; } this.stackFrames.push({ isLoop: false, // Whether this level of the stack is a loop. warpMode: warpMode, // Whether this level is in warp mode. reported: {}, // Collects reported input values. waitingReporter: null, // Name of waiting reporter. params: {}, // Procedure parameters. executionContext: {} // A context passed to block implementations. }); } }; /** * Pop last block on the stack and its stack frame. * @return {string} Block ID popped from the stack. */ Thread.prototype.popStack = function () { this.stackFrames.pop(); return this.stack.pop(); }; /** * Get top stack item. * @return {?string} Block ID on top of stack. */ Thread.prototype.peekStack = function () { return this.stack[this.stack.length - 1]; }; /** * Get top stack frame. * @return {?Object} Last stack frame stored on this thread. */ Thread.prototype.peekStackFrame = function () { return this.stackFrames[this.stackFrames.length - 1]; }; /** * Get stack frame above the current top. * @return {?Object} Second to last stack frame stored on this thread. */ Thread.prototype.peekParentStackFrame = function () { return this.stackFrames[this.stackFrames.length - 2]; }; /** * Push a reported value to the parent of the current stack frame. * @param {*} value Reported value to push. */ Thread.prototype.pushReportedValue = function (value) { var parentStackFrame = this.peekParentStackFrame(); if (parentStackFrame) { var waitingReporter = parentStackFrame.waitingReporter; parentStackFrame.reported[waitingReporter] = value; } }; /** * Add a parameter to the stack frame. * Use when calling a procedure with parameter values. * @param {!string} paramName Name of parameter. * @param {*} value Value to set for parameter. */ Thread.prototype.pushParam = function (paramName, value) { var stackFrame = this.peekStackFrame(); stackFrame.params[paramName] = value; }; /** * Get a parameter at the lowest possible level of the stack. * @param {!string} paramName Name of parameter. * @return {*} value Value for parameter. */ Thread.prototype.getParam = function (paramName) { for (var i = this.stackFrames.length - 1; i >= 0; i--) { var frame = this.stackFrames[i]; if (frame.params.hasOwnProperty(paramName)) { return frame.params[paramName]; } } return null; }; /** * Whether the current execution of a thread is at the top of the stack. * @return {Boolean} True if execution is at top of the stack. */ Thread.prototype.atStackTop = function () { return this.peekStack() === this.topBlock; }; /** * Switch the thread to the next block at the current level of the stack. * For example, this is used in a standard sequence of blocks, * where execution proceeds from one block to the next. */ Thread.prototype.goToNextBlock = function () { var nextBlockId = this.target.blocks.getNextBlock(this.peekStack()); // Copy warp mode to next block. var warpMode = this.peekStackFrame().warpMode; // The current block is on the stack - pop it and push the next. // Note that this could push `null` - that is handled by the sequencer. this.popStack(); this.pushStack(nextBlockId); if (this.peekStackFrame()) { this.peekStackFrame().warpMode = warpMode; } }; /** * Attempt to determine whether a procedure call is recursive, * by examining the stack. * @param {!string} procedureCode Procedure code of procedure being called. * @return {boolean} True if the call appears recursive. */ Thread.prototype.isRecursiveCall = function (procedureCode) { var callCount = 5; // Max number of enclosing procedure calls to examine. var sp = this.stack.length - 1; for (var i = sp - 1; i >= 0; i--) { var block = this.target.blocks.getBlock(this.stack[i]); if (block.opcode == 'procedures_callnoreturn' && block.mutation.proccode == procedureCode) { return true; } if (--callCount < 0) return false; } return false; }; module.exports = Thread;