chinese直男口爆体育生外卖, 99久久er热在这里只有精品99, 又色又爽又黄18禁美女裸身无遮挡, gogogo高清免费观看日本电视,私密按摩师高清版在线,人妻视频毛茸茸,91论坛 兴趣闲谈,欧美 亚洲 精品 8区,国产精品久久久久精品免费

0
  • 聊天消息
  • 系統(tǒng)消息
  • 評論與回復
登錄后你可以
  • 下載海量資料
  • 學習在線課程
  • 觀看技術(shù)視頻
  • 寫文章/發(fā)帖/加入社區(qū)
會員中心
創(chuàng)作中心

完善資料讓更多小伙伴認識你,還能領(lǐng)取20積分哦,立即完善>

3天內(nèi)不再提示

HarmonyOS CPU與I/O密集型任務開發(fā)指導

王程 ? 來源:jf_75796907 ? 作者:jf_75796907 ? 2024-02-18 10:17 ? 次閱讀
加入交流群
微信小助手二維碼

掃碼添加小助手

加入工程師交流群

一、CPU密集型任務開發(fā)指導

CPU密集型任務是指需要占用系統(tǒng)資源處理大量計算能力的任務,需要長時間運行,這段時間會阻塞線程其它事件的處理,不適宜放在主線程進行。例如圖像處理、視頻編碼、數(shù)據(jù)分析等。

基于多線程并發(fā)機制處理CPU密集型任務可以提高CPU利用率,提升應用程序響應速度。

當進行一系列同步任務時,推薦使用Worker;而進行大量或調(diào)度點較為分散的獨立任務時,不方便使用8個Worker去做負載管理,推薦采用TaskPool。接下來將以圖像直方圖處理以及后臺長時間的模型預測任務分別進行舉例。

使用TaskPool進行圖像直方圖處理

? 1. 實現(xiàn)圖像處理的業(yè)務邏輯。

? 2. 數(shù)據(jù)分段,將各段數(shù)據(jù)通過不同任務的執(zhí)行完成圖像處理。

創(chuàng)建Task,通過execute()執(zhí)行任務,在當前任務結(jié)束后,會將直方圖處理結(jié)果同時返回。

? 3. 結(jié)果數(shù)組匯總處理。

import taskpool from '@ohos.taskpool';

@Concurrent
function imageProcessing(dataSlice: ArrayBuffer) {
  // 步驟1: 具體的圖像處理操作及其他耗時操作
  return dataSlice;
}

function histogramStatistic(pixelBuffer: ArrayBuffer) {
  // 步驟2: 分成三段并發(fā)調(diào)度
  let number = pixelBuffer.byteLength / 3;
  let buffer1 = pixelBuffer.slice(0, number);
  let buffer2 = pixelBuffer.slice(number, number * 2);
  let buffer3 = pixelBuffer.slice(number * 2);

  let task1 = new taskpool.Task(imageProcessing, buffer1);
  let task2 = new taskpool.Task(imageProcessing, buffer2);
  let task3 = new taskpool.Task(imageProcessing, buffer3);

  taskpool.execute(task1).then((ret: ArrayBuffer[]) => {
    // 步驟3: 結(jié)果處理
  });
  taskpool.execute(task2).then((ret: ArrayBuffer[]) => {
    // 步驟3: 結(jié)果處理
  });
  taskpool.execute(task3).then((ret: ArrayBuffer[]) => {
    // 步驟3: 結(jié)果處理
  });
}

@Entry
@Component
struct Index {
  @State message: string = 'Hello World'

  build() {
    Row() {
      Column() {
        Text(this.message)
          .fontSize(50)
          .fontWeight(FontWeight.Bold)
          .onClick(() => {
            let data: ArrayBuffer;
            histogramStatistic(data);
          })
      }
      .width('100%')
    }
    .height('100%')
  }
}

使用Worker進行長時間數(shù)據(jù)分析

本文通過某地區(qū)提供的房價數(shù)據(jù)訓練一個簡易的房價預測模型,該模型支持通過輸入房屋面積和房間數(shù)量去預測該區(qū)域的房價,模型需要長時間運行,房價預測需要使用前面的模型運行結(jié)果,因此需要使用Worker。

? 1. DevEco Studio提供了Worker創(chuàng)建的模板,新建一個Worker線程,例如命名為“MyWorker”。

wKgaomXPT9aAPY5fAAIhtawiAa0789.pngwKgZomXPT8SATNG3AAIhtawiAa0161.png

? 2. 在主線程中通過調(diào)用ThreadWorker的constructor()方法創(chuàng)建Worker對象,當前線程為宿主線程。

import worker from '@ohos.worker';

const workerInstance = new worker.ThreadWorker('entry/ets/workers/MyWorker.ts');

? 3. 在宿主線程中通過調(diào)用onmessage()方法接收Worker線程發(fā)送過來的消息,并通過調(diào)用postMessage()方法向Worker線程發(fā)送消息。

例如向Worker線程發(fā)送訓練和預測的消息,同時接收Worker線程發(fā)送回來的消息。

// 接收Worker子線程的結(jié)果
workerInstance.onmessage = function(e) {
  // data:主線程發(fā)送的信息
  let data = e.data;
  console.info('MyWorker.ts onmessage');
  // 在Worker線程中進行耗時操作
}

workerInstance.onerror = function (d) {
  // 接收Worker子線程的錯誤信息
}

// 向Worker子線程發(fā)送訓練消息
workerInstance.postMessage({ 'type': 0 });
// 向Worker子線程發(fā)送預測消息
workerInstance.postMessage({ 'type': 1, 'value': [90, 5] });

? 4. 在MyWorker.ts文件中綁定Worker對象,當前線程為Worker線程。

import worker, { ThreadWorkerGlobalScope, MessageEvents, ErrorEvent } from '@ohos.worker';

let workerPort: ThreadWorkerGlobalScope = worker.workerPort;

? 5. 在Worker線程中通過調(diào)用onmessage()方法接收宿主線程發(fā)送的消息內(nèi)容,并通過調(diào)用postMessage()方法向宿主線程發(fā)送消息。

如在Worker線程中定義預測模型及其訓練過程,同時與主線程進行信息交互。

import worker, { ThreadWorkerGlobalScope, MessageEvents, ErrorEvent } from '@ohos.worker';

let workerPort: ThreadWorkerGlobalScope = worker.workerPort;

// 定義訓練模型及結(jié)果 
let result;

// 定義預測函數(shù)
function predict(x) {
  return result[x];
}

// 定義優(yōu)化器訓練過程
function optimize() {
  result = {};
}

// Worker線程的onmessage邏輯
workerPort.onmessage = function (e: MessageEvents) {
  let data = e.data
  // 根據(jù)傳輸?shù)臄?shù)據(jù)的type選擇進行操作
  switch (data.type) {
    case 0:
    // 進行訓練
      optimize();
    // 訓練之后發(fā)送主線程訓練成功的消息
      workerPort.postMessage({ type: 'message', value: 'train success.' });
      break;
    case 1:
    // 執(zhí)行預測
      const output = predict(data.value);
    // 發(fā)送主線程預測的結(jié)果
      workerPort.postMessage({ type: 'predict', value: output });
      break;
    default:
      workerPort.postMessage({ type: 'message', value: 'send message is invalid' });
      break;
  }
}

? 6. 在Worker線程中完成任務之后,執(zhí)行Worker線程銷毀操作。銷毀線程的方式主要有兩種:根據(jù)需要可以在宿主線程中對Worker線程進行銷毀;也可以在Worker線程中主動銷毀Worker線程。

在宿主線程中通過調(diào)用onexit()方法定義Worker線程銷毀后的處理邏輯。

// Worker線程銷毀后,執(zhí)行onexit回調(diào)方法
workerInstance.onexit = function() {
  console.info("main thread terminate");
}

方式一:在宿主線程中通過調(diào)用terminate()方法銷毀Worker線程,并終止Worker接收消息。

// 銷毀Worker線程
workerInstance.terminate();

方式二:在Worker線程中通過調(diào)用close()方法主動銷毀Worker線程,并終止Worker接收消息。

// 銷毀線程
workerPort.close();

二、 I/O密集型任務開發(fā)指導

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

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

? 1. 定義并發(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à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)寫文件操作
  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;
}

? 2. 使用TaskPool執(zhí)行包含密集I/O的并發(fā)函數(shù):通過調(diào)用execute()方法執(zhí)行任務,并在回調(diào)中進行調(diào)度結(jié)果處理。示例中的filePath1和filePath2的獲取方式請參見獲取應用文件路徑。

import taskpool from '@ohos.taskpool';

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

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


審核編輯 黃宇

聲明:本文內(nèi)容及配圖由入駐作者撰寫或者入駐合作網(wǎng)站授權(quán)轉(zhuǎn)載。文章觀點僅代表作者本人,不代表電子發(fā)燒友網(wǎng)立場。文章及其配圖僅供工程師學習之用,如有內(nèi)容侵權(quán)或者其他違規(guī)問題,請聯(lián)系本站處理。 舉報投訴
  • cpu
    cpu
    +關(guān)注

    關(guān)注

    68

    文章

    11187

    瀏覽量

    221296
  • 圖像處理
    +關(guān)注

    關(guān)注

    27

    文章

    1337

    瀏覽量

    58901
  • 線程
    +關(guān)注

    關(guān)注

    0

    文章

    508

    瀏覽量

    20653
  • HarmonyOS
    +關(guān)注

    關(guān)注

    80

    文章

    2141

    瀏覽量

    34969
收藏 人收藏
加入交流群
微信小助手二維碼

掃碼添加小助手

加入工程師交流群

    評論

    相關(guān)推薦
    熱點推薦

    鴻蒙OS開發(fā)實例:【ArkTS類庫多線程CPU密集型任務TaskPool】

    CPU密集型任務是指需要占用系統(tǒng)資源處理大量計算能力的任務,需要長時間運行,這段時間會阻塞線程其它事件的處理,不適宜放在主線程進行。例如圖像處理、視頻編碼、數(shù)據(jù)分析等。 基于多線
    的頭像 發(fā)表于 04-01 22:25 ?1581次閱讀
    鴻蒙OS<b class='flag-5'>開發(fā)</b>實例:【ArkTS類庫多線程<b class='flag-5'>CPU</b><b class='flag-5'>密集型</b><b class='flag-5'>任務</b>TaskPool】

    鴻蒙原生應用開發(fā)-ArkTS語言基礎(chǔ)類庫多線程CPU密集型任務TaskPool

    CPU密集型任務是指需要占用系統(tǒng)資源處理大量計算能力的任務,需要長時間運行,這段時間會阻塞線程其它事件的處理,不適宜放在主線程進行。例如圖像處理、視頻編碼、數(shù)據(jù)分析等。 基于多線程并發(fā)
    發(fā)表于 03-19 14:14

    鴻蒙原生應用開發(fā)-ArkTS語言基礎(chǔ)類庫多線程I/O密集型任務開發(fā)

    使用異步并發(fā)可以解決單次I/O任務阻塞的問題,但是如果遇到I/O密集型
    發(fā)表于 03-21 14:57

    請問如何在Python中實現(xiàn)多線程與多進程的協(xié)作?

    大家好!我最近在開發(fā)一個Python項目時,需要同時處理多個任務,且每個任務需要不同的計算資源。我想通過多線程和多進程的組合來實現(xiàn)并發(fā),但遇到了一些問題。 具體來說,我有兩個任務,一個
    發(fā)表于 03-11 06:57

    CPU密集型任務開發(fā)指導

    CPU密集型任務是指需要占用系統(tǒng)資源處理大量計算能力的任務,需要長時間運行,這段時間會阻塞線程其它事件的處理,不適宜放在主線程進行。例如圖像處理、視頻編碼、數(shù)據(jù)分析等。 基于多線程并發(fā)
    發(fā)表于 06-19 06:05

    I/O密集型任務開發(fā)指導

    使用異步并發(fā)可以解決單次I/O任務阻塞的問題,但是如果遇到I/O密集型
    發(fā)表于 06-19 07:19

    計算密集型的程序簡析

    人工智能學習1. 人工智能應用場景網(wǎng)絡安全、電子商務、計算模擬、社交網(wǎng)絡 … …2. 人工智能必備三要素數(shù)據(jù),算法,計算力計算力之CPU、GPU對比:CPU主要適合I\O
    發(fā)表于 09-07 06:14

    HarmonyOS如何使用異步并發(fā)能力進行開發(fā)

    UI的同時,后臺也能執(zhí)行耗時操作,從而避免應用出現(xiàn)卡頓。 并發(fā)能力在多種場景中都有應用,其中包括單次I/O任務、CPU密集型
    發(fā)表于 09-22 17:35

    HarmonyOS CPUI/O密集型任務開發(fā)指導

    workerPort.close(); 二、I/O密集型任務開發(fā)指導 使用異步并發(fā)可以解決單次I
    發(fā)表于 09-26 16:29

    HarmonyOS語言基礎(chǔ)類庫開發(fā)指南上線啦!

    /cpu-intensive-task-development-0000001681369757-V3?? **I/O密集型任務
    發(fā)表于 10-18 16:36

    I/O密集型虛擬機的域間通信優(yōu)化方法

    I/O密集型虛擬機需要頻繁地進行域間通信,為解決現(xiàn)有虛擬機域間通信效率低、延遲大的問題,提出一種基于雙環(huán)形緩沖區(qū)的用戶域與驅(qū)動域域間通信優(yōu)化方法。在用戶域中建立與驅(qū)動域共享的雙環(huán)形緩沖區(qū),由虛擬機
    發(fā)表于 03-01 15:42 ?0次下載
    <b class='flag-5'>I</b>/<b class='flag-5'>O</b><b class='flag-5'>密集型</b>虛擬機的域間通信優(yōu)化方法

    FPGA執(zhí)行計算密集型任務性能表現(xiàn)及優(yōu)勢有哪些

    FPGA可用于處理多元計算密集型任務,依托流水線并行結(jié)構(gòu)體系,F(xiàn)PGA相對GPU、CPU在計算結(jié)果返回時延方面具備技術(shù)優(yōu)勢。
    的頭像 發(fā)表于 11-10 09:49 ?1446次閱讀

    云優(yōu)化性能:使用基于閃存的存儲的I/O密集型工作負載

    電子發(fā)燒友網(wǎng)站提供《云優(yōu)化性能:使用基于閃存的存儲的I/O密集型工作負載.pdf》資料免費下載
    發(fā)表于 08-28 10:04 ?0次下載
    云優(yōu)化性能:使用基于閃存的存儲的<b class='flag-5'>I</b>/<b class='flag-5'>O</b><b class='flag-5'>密集型</b>工作負載

    鴻蒙OS開發(fā)實例:【ArkTS類庫多線程I/O密集型任務開發(fā)

    使用異步并發(fā)可以解決單次I/O任務阻塞的問題,但是如果遇到I/O密集型
    的頭像 發(fā)表于 04-01 16:32 ?1098次閱讀
    鴻蒙OS<b class='flag-5'>開發(fā)</b>實例:【ArkTS類庫多線程<b class='flag-5'>I</b>/<b class='flag-5'>O</b><b class='flag-5'>密集型</b><b class='flag-5'>任務</b><b class='flag-5'>開發(fā)</b>】

    怎么在JAVA中確定線性池大小

    在JAVA中確定線性池大小,分別介紹CPU密集型任務I/O密集型
    的頭像 發(fā)表于 10-24 14:02 ?651次閱讀