kirigaya/digital-ide
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

修改线程调度逻辑

Browse Source
This commit is contained in:
锦恢 2024-09-28 21:42:43 +08:00
parent 1db2ff4986
commit d2755e0a05
2 changed files with 28 additions and 33 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

58
src/hdlParser/core.ts
View File

@ -1,4 +1,5 @@
import * as vscode from 'vscode';
import * as os from 'os';
import { AbsPath, IProgress, opeParam } from '../global';
import { HdlLangID } from '../global/enum';
@ -245,45 +246,42 @@ class HdlParam {
const { t } = vscode.l10n;
let count: number = 0;
let fileNum = hdlFiles.length;
const parallelChunk = 5;
// TODO: 找出最合理的核心数
const parallelChunk = Math.min(os.cpus().length, 32);
console.log("use cpu: " + parallelChunk);
const pools: { id: number, promise: Promise<void>, path: string }[] = [];
const reportTitle = t('progress.build-module-tree');
progress?.report({ message: reportTitle + ` ${1}/${fileNum}`, increment: 0 });
async function consumePools() {
for (const p of pools) {
const increment = Math.floor(p.id / fileNum * 100);
await p.promise;
console.log("handle id " + p.id + ' increment: ' + increment);
progress?.report({ message: reportTitle + ` ${p.id}/${fileNum}`, increment });
}
pools.length = 0;
}
for (const path of hdlFiles) {
count ++;
await this.doHdlFast(path);
}
// async function consumePools() {
// for (const p of pools) {
// const increment = Math.floor(p.id / fileNum * 100);
// console.log('wait ' + p.path);
// await p.promise;
// console.log("handle id " + p.id + ' increment: ' + increment);
// progress?.report({ message: reportTitle + ` ${p.id}/${fileNum}`, increment });
// }
// pools.length = 0;
// }
// for (const path of hdlFiles) {
// count ++;
// console.log('send request: ' + path);
console.log('send request: ' + path);
// const p = this.doHdlFast(path);
// pools.push({ id: count, promise: p, path });
// if (pools.length % parallelChunk === 0) {
// // 消费并发池
// await consumePools();
// }
// }
const p = this.doHdlFast(path);
pools.push({ id: count, promise: p, path });
if (pools.length % parallelChunk === 0) {
// 消费并发池
await consumePools();
}
}
// if (pools.length > 0) {
// await consumePools();
// }
if (pools.length > 0) {
await consumePools();
}
}

3
src/hdlParser/util.ts
View File

@ -11,10 +11,7 @@ async function doFastApi(path: string): Promise<Fast | undefined> {
const client = LspClient.MainClient;
const langID = hdlFile.getLanguageId(path);
if (client) {
console.log('send request ' + path);
const response = await client.sendRequest(DoFastRequestType, { path });
console.log('receive response ' + path);
response.languageId = langID;
return response;
}