使用異步并發(fā)可以解決單次I/O任務(wù)阻塞的問(wèn)題，但是如果遇到I/O密集型任務(wù)，同樣會(huì)阻塞線程中其它任務(wù)的執(zhí)行，這時(shí)需要使用多線程并發(fā)能力來(lái)進(jìn)行解決。

I/O密集型任務(wù)的性能重點(diǎn)通常不在于CPU的處理能力，而在于I/O操作的速度和效率。這種任務(wù)通常需要頻繁地進(jìn)行磁盤(pán)讀寫(xiě)、網(wǎng)絡(luò)通信等操作。此處以頻繁讀寫(xiě)系統(tǒng)文件來(lái)模擬I/O密集型并發(fā)任務(wù)的處理。

定義并發(fā)函數(shù)，內(nèi)部密集調(diào)用I/O能力。

import fs from '@ohos.file.fs';

// 定義并發(fā)函數(shù)，內(nèi)部密集調(diào)用I/O能力
@Concurrent
async function concurrentTest(fileList: string[]) {
  // 寫(xiě)入文件的實(shí)現(xiàn)
  async function write(data, filePath) {
    let file = await fs.open(filePath, fs.OpenMode.READ_WRITE);
    await fs.write(file.fd, data);
    fs.close(file);
  }
  // 循環(huán)寫(xiě)文件操作
  for (let i = 0; i < fileList.length; i++) {
    write('Hello World!', fileList[i]).then(() = > {
      console.info(`Succeeded in writing the file. FileList: ${fileList[i]}`);
    }).catch((err) = > {
      console.error(`Failed to write the file. Code is ${err.code}, message is ${err.message}`)
      return false;
    })
  }
  return true;
}

開(kāi)始前熟悉鴻蒙文檔

使用TaskPool執(zhí)行包含密集I/O的并發(fā)函數(shù)：通過(guò)調(diào)用execute()方法執(zhí)行任務(wù)，并在回調(diào)中進(jìn)行調(diào)度結(jié)果處理。示例中的filePath1和filePath2的獲取方式請(qǐng)參見(jiàn)獲取應(yīng)用文件路徑。

import taskpool from '@ohos.taskpool';

let filePath1 = ...; // 應(yīng)用文件路徑
let filePath2 = ...;

// 使用TaskPool執(zhí)行包含密集I/O的并發(fā)函數(shù)
// 數(shù)組較大時(shí)，I/O密集型任務(wù)任務(wù)分發(fā)也會(huì)搶占主線程，需要使用多線程能力
taskpool.execute(concurrentTest, [filePath1, filePath2]).then((ret) = > {
  // 調(diào)度結(jié)果處理
  console.info(`The result: ${ret}`);
})

本文參考引用HarmonyOS官方開(kāi)發(fā)文檔，基于API9。