等待异步函数阻塞主线程

Question

我正在用 JavaScript 构建一个不和谐的音乐机器人（我昨天刚开始学习，所以代码可能有点乱）。到目前为止，我已经将歌曲添加到队列中，播放歌曲，然后在当前歌曲完成后移至下一首歌曲。但是，我遇到了一个小问题：每次我将一首歌曲添加到队列中时，机器人的音乐都会暂停一秒钟，而一首歌曲已经在播放。我发现这是因为 yt-search，这是我用来在 youtube 上搜索特定视频的模块。

这是 main.js 中的相关代码，通过 Node 运行的实际文件。

    else if (cmd === 'play') {
    const connection = getVoiceConnection(msg.guildId);

    if (!connection) {
        const join = await client.modules.backend.join(msg);

        if (!join) return console.log('Unable to join');
    }

    if (!qMap.get(msg.guildId)) {
        console.log('No queue for this server, creating a new one');

        await client.modules.queue.construct(qMap, msg.guildId, msg.member.voice.channel, connection);
    }

    client.modules.queue.add(msg, qMap.get(msg.guildId), args, player);

有人使用“播放”命令播放歌曲；他们的搜索词与其他一些变量一起作为 args 传递给 queue.add。 queue.add 是从另一个模块导入的；这是代码：

async function queueAddSong(msg, queue, terms, player) {

song = searchForVideo(msg, terms);

console.log(`Adding to queue: ${song.title}`);

queue.songs.push(song);

if (player.state.status === 'idle') startQueue(queue, player);
}

这里是searchForVideo()，它会进行实际搜索：

async function searchForVideo(msg, query) {

let song = {};

// Was a valid URL passed? If yes, use ytdl. Otherwise, search.
if (ytdl.validateURL(query[0])) {
    songInfo = await ytdl.getInfo(query[0]);

    song = {
        title: songInfo.videoDetails.title,
        url: songInfo.videoDetails.video_url
    };
} else {
    // Search
    const vidResults = await ytSearch(query.join(' '));

    if (vidResults.videos.length > 1) {
        song = {
            title: vidResults.videos[0].title,
            url: vidResults.videos[0].url
        };
    } else {
        msg.reply(':x: No results found');
        return null;
    }
}

return song;
}

这里是startQueue()，它将歌曲转换为可用的流并播放它

function startQueue(queue, player) {
console.log(`Starting a new queue with song: ${queue.songs[0].title}`);
// Start a queue. Behavior is different from just switching songs, so I've made this a separate function.

const connection = getVoiceConnection(queue.voiceChannel.guildId);
const stream = ytdl(queue.songs[0].url, {
    filter: 'audioonly'
});
const resource = createAudioResource(stream, {
    inputType: StreamType.Arbitrary
});

// Play first song
player.play(resource);
connection.subscribe(player);

// Add event listener to play next song
player.on(AudioPlayerStatus.Idle, () => {
    if (queue.songs.length > 1) {
        console.log(`Song finished. Moving to: ${queue.songs[1].title}`);

        queue.songs.shift();
        playInQueue(queue, 0, player);
    } else {
        console.log(`Queue finished.`);
    }
});
}

似乎ytsearch 的强度足以让整个线程停止足够长的时间以引起注意。如何独立于主线程运行搜索，以便无论搜索花费多少时间或处理能力，音乐在搜索时继续播放？

Answer 1

其实我的标题是错的；导致口吃的不是await 部分，而是ytSearch() 函数本身。似乎调用它的强度足以让整个线程停止足够长的时间以引起注意。虽然仅仅搜索 youtube 可能有点过头了，但我设法通过给 searchForVideo() 一个与主线程分开的工作线程来解决这个问题。我还不能接受我自己的答案，所以我暂时把它留在这里。

Answer 2

考虑删除 async 和 await 并用正常的承诺解决方法替换它们。

function searchForVideo(msg, query) {
  if (ytdl.validateURL(query[0])) {
    return ytdl.getInfo(query[0])
      .then(songInfo => {
        return {
          title: songInfo.videoDetails.title,
          url: songInfo.videoDetails.video_url
        }
      });
  } else {
    return ytSearch(query.join(' '))
      .then(vidResults => {
        if (vidResults.videos.length > 1) {
          return {
            title: vidResults.videos[0].title,
            url: vidResults.videos[0].url
          };
        } else {
          msg.reply(':x: No results found');
          return null;
        }
      });
  }
}

然后在您的 queueAddSong 函数中，解决承诺。

function queueAddSong(msg, queue, terms, player) {
  searchForVideo(msg, terms).then(song => {
    console.log(`Adding to queue: ${song.title}`);
    queue.songs.push(song);
  });
  if (player.state.status === 'idle') startQueue(queue, player);
}