Tengo una aplicación express en ejecución que escucha las solicitudes GET. Cualquier solicitud GET devuelve inmediatamente una respuesta exitosa y ejecuta una función asyncForLoop() que devuelve una promesa que se resuelve después de 5 segundos.
Problema: aunque se llama a asyncForLoop( asyncForLoop() después de res.json() cualquier solicitud GET posterior se retrasa hasta que se resuelve la promesa en asyncForLoop() .
const express = require("express"); const app = express(); app.listen(3005, () => { console.log(new Date().getTime() + " running on port 3005."); }); app.get("/*", (req, res) => { myResponse(req, res); }); function myResponse(req, res) { console.log(new Date().getTime() + " GET request => " + req.originalUrl); res.json({ success: true }); // this function blocks any following request until it is resolved asyncForLoop().then(res => { console.log(new Date().getTime() + " finished for-loop."); }); } function asyncForLoop() { return new Promise(function(resolve, reject) { // simulate a long synchronous action using wait() in a for-loop for (let i=0; i<5; i++) { console.log(i); wait(1000); } resolve(); }); } function wait(ms) { let start = Date.now(), now = start; while (now - start < ms) { now = Date.now(); } } Puede probar el código anterior ejecutando el script usando el node y abriendo dos pestañas con la dirección localhost:3005 en un navegador. La primera pestaña obtendrá una respuesta de inmediato mientras que la segunda pestaña se carga durante 5 segundos.
Pregunta: ¿Por qué la promesa dentro asyncForLoop() retrasa las próximas solicitudes? ¿No debería manejarse de forma asíncrona porque está dentro de una promesa? ¿Cómo puedo evitar esta segunda solicitud retrasada?
¡Gracias!
JavaScript es de un solo subproceso. Un ciclo de ejecución prolongada bloqueará todo su código. Puede usar una función de wait asincrónica:
const express = require("express"); const app = express(); app.get("/*", (req, res) => { myResponse(req, res); }); async function myResponse(req, res) { console.log(new Date().getTime() + " GET request => " + req.originalUrl); res.json({ success: true }); await asyncForLoop(); console.log(new Date().getTime() + " finished for-loop."); } async function asyncForLoop() { for (let i=0; i<5; i++) { console.log(i); await wait(1000); } } function wait(ms) { return new Promise(resolve => setTimeout(resolve, ms)); } app.listen(3005, () => { console.log(new Date().getTime() + " running on port 3005."); });