使用異步并發可以解決單次I/O任務阻塞的問題，但是如果遇到I/O密集型任務，同樣會阻塞線程中其它任務的執行，這時需要使用多線程并發能力來進行解決。

I/O密集型任務的性能重點通常不在于CPU的處理能力，而在于I/O操作的速度和效率。這種任務通常需要頻繁地進行磁盤讀寫、網絡通信等操作。此處以頻繁讀寫系統文件來模擬I/O密集型并發任務的處理。

定義并發函數，內部密集調用I/O能力。

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

// 定義并發函數，內部密集調用I/O能力
@Concurrent
async function concurrentTest(fileList: string[]) {
  // 寫入文件的實現
  async function write(data, filePath) {
    let file = await fs.open(filePath, fs.OpenMode.READ_WRITE);
    await fs.write(file.fd, data);
    fs.close(file);
  }
  // 循環寫文件操作
  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;
}

開始前熟悉鴻蒙文檔

使用TaskPool執行包含密集I/O的并發函數：通過調用execute()方法執行任務，并在回調中進行調度結果處理。示例中的filePath1和filePath2的獲取方式請參見獲取應用文件路徑。

import taskpool from '@ohos.taskpool';

let filePath1 = ...; // 應用文件路徑
let filePath2 = ...;

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

本文參考引用HarmonyOS官方開發文檔，基于API9。