GuanM/NapCatQQ
1
0
Fork 0
mirror of https://github.com/NapNeko/NapCatQQ.git synced 2024-11-21 09:36:35 +00:00
Code Issues Actions Packages Projects Releases Wiki Activity

fix: rkey cached

Browse Source
This commit is contained in:
linyuchen 2024-05-06 19:44:25 +08:00
parent ad251a7682
commit a566dd390b
1 changed files with 8 additions and 6 deletions

14
src/common/utils/AsyncQueue.ts

@ -1,6 +1,6 @@
import { sleep } from '@/common/utils/helper'; import { sleep } from '@/common/utils/helper';
type AsyncQueueTask = (() => void) | Promise<void> ; type AsyncQueueTask = (() => void) | (()=>Promise<void>);
export class AsyncQueue { export class AsyncQueue {
@ -8,20 +8,22 @@ export class AsyncQueue {
public addTask(task: AsyncQueueTask) { public addTask(task: AsyncQueueTask) {
this.tasks.push(task); this.tasks.push(task);
// console.log('addTask', this.tasks.length);
if (this.tasks.length === 1) { if (this.tasks.length === 1) {
this.runQueue().then().catch(()=>{}); this.runQueue().then().catch(()=>{});
} }
} }
private async runQueue() { private async runQueue() {
// console.log('runQueue', this.tasks.length);
while (this.tasks.length > 0) { while (this.tasks.length > 0) {
const task = this.tasks[0]; const task = this.tasks[0];
// console.log('typeof task', typeof task);
try { try {
if (task instanceof Promise) { const taskRet = task();
await task; // console.log('type of taskRet', typeof taskRet, taskRet);
} if (taskRet instanceof Promise) {
else{ await taskRet;
task();
} }
} catch (e) { } catch (e) {
console.error(e); console.error(e);