1# I/O密集型任务开发指导 (TaskPool) 2 3 4使用异步并发可以解决单次I/O任务阻塞的问题，但是如果遇到I/O密集型任务，同样会阻塞线程中其它任务的执行，这时需要使用多线程并发能力来进行解决。 5 6 7I/O密集型任务的性能重点通常不在于CPU的处理能力，而在于I/O操作的速度和效率。这种任务通常需要频繁地进行磁盘读写、网络通信等操作。此处以频繁读写系统文件来模拟I/O密集型并发任务的处理。 8 9 101. 定义并发函数，内部密集调用I/O能力。 11 ```ts 12 // a.ts 13 import fs from '@ohos.file.fs'; 14 15 // 定义并发函数，内部密集调用I/O能力 16 // 写入文件的实现 17 export async function write(data: string, filePath: string): Promise<void> { 18 let file: fs.File = await fs.open(filePath, fs.OpenMode.READ_WRITE); 19 await fs.write(file.fd, data); 20 fs.close(file); 21 } 22 ``` 23 24 ```ts 25 import { write } from './a' 26 import { BusinessError } from '@ohos.base'; 27 28 @Concurrent 29 async function concurrentTest(fileList: string[]): Promise<boolean> { 30 // 循环写文件操作 31 for (let i: number = 0; i < fileList.length; i++) { 32 write('Hello World!', fileList[i]).then(() => { 33 console.info(`Succeeded in writing the file. FileList: ${fileList[i]}`); 34 }).catch((err: BusinessError) => { 35 console.error(`Failed to write the file. Code is ${err.code}, message is ${err.message}`) 36 return false; 37 }) 38 } 39 return true; 40 } 41 ``` 42 432. 使用TaskPool执行包含密集I/O的并发函数：通过调用[execute()](../reference/apis-arkts/js-apis-taskpool.md#taskpoolexecute)方法执行任务，并在回调中进行调度结果处理。示例中的filePath1和filePath2的获取方式请参见[获取应用文件路径](../application-models/application-context-stage.md#获取应用文件路径)。 44 45 ```ts 46 import taskpool from '@ohos.taskpool'; 47 48 let filePath1: string = "path1"; // 应用文件路径 49 let filePath2: string = "path2"; 50 51 // 使用TaskPool执行包含密集I/O的并发函数 52 // 数组较大时，I/O密集型任务任务分发也会抢占主线程，需要使用多线程能力 53 taskpool.execute(concurrentTest, [filePath1, filePath2]).then(() => { 54 // 调度结果处理 55 }) 56 ``` 57