class Promise { constructor(executor) { this.state = 'pending'; this.value = undefined; this.reason = undefined; this.onFulfilledCallbacks = []; this.onRejectedCallbacks = []; let resolve = value => { if (this.state === 'pending') { this.state = 'fulfilled'; this.value = value; this.onFulfilledCallbacks.forEach(callback => callback(value)); } }; let reject = reason => { if (this.state === 'pending') { this.state = 'rejected'; this.reason = reason; this.onRejectedCallbacks.forEach(callback => callback(reason)); } }; try { // 立即执行函数 executor(resolve, reject); } catch (err) { reject(err); } } then(onFulfilled, onRejected) { return new Promise((resolve, reject) => { if (this.state === 'fulfilled') { try { let x = onFulfilled(this.value); this.handleThenCallback(x, resolve, reject); } catch (err) { reject(err); } } if (this.state === 'rejected') { try { let x = onRejected(this.reason); this.handleThenCallback(x, resolve, reject); } catch (err) { reject(err); } } if (this.state === 'pending') { this.onFulfilledCallbacks.push(value => { try { let x = onFulfilled(value); this.handleThenCallback(x, resolve, reject); } catch (err) { reject(err); } }); this.onRejectedCallbacks.push(reason => { try { let x = onRejected(reason); this.handleThenCallback(x, resolve, reject); } catch (err) { reject(err); } }); } }); } handleThenCallback(x, resolve, reject) { if (x instanceof Promise) { // 如果 x 是一个 Promise,则等待其状态变更 x.then(resolve, reject); } else { // 如果 x 是普通值,则直接将其作为新 Promise 的值进行 resolve resolve(x); } } // 可以添加其他方法,如 catch、finally 等 } // 使用示例 const promise = new Promise((resolve, reject) => { setTimeout(() => { const randomNumber = Math.random(); if (randomNumber > 0.5) { resolve('Success!'); } else { reject('Failure!'); } }, 1000); }); promise .then( value => { console.log('Resolved:', value); return 'New Value'; }, reason => { console.log('Rejected:', reason); throw new Error('New Error'); } ) .then( value => { console.log('Resolved:', value); }, reason => { console.log('Rejected:', reason.message); } );
网友回复