diff --git a/multimedia/BUILD.gn b/multimedia/BUILD.gn index 1124f49924f82e95df990c9f6f55b74a5973031b..e15a0d67c4dbc455d5d2ee6083d0ea062cb01796 100644 --- a/multimedia/BUILD.gn +++ b/multimedia/BUILD.gn @@ -41,6 +41,7 @@ group("multimedia") { "image/image_js_standard/imageRGBA:image_rgba_js_hap", "image/image_js_standard/imageRaw:image_raw_js_hap", "image/image_js_standard/imageReceiver:image_receiver_js_hap", + "image/image_js_standard/imageReceiverMultiThread:image_receiver_multi_thread_hap", "image/image_js_standard/imageReceiverNDK:image_receiver_ndk_js_hap", "image/image_js_standard/imageSvg:image_svg_js_hap", "image/image_js_standard/imageWebp:image_webp_js_hap", diff --git a/multimedia/image/image_js_standard/imageReceiverMultiThread/AppScope/app.json b/multimedia/image/image_js_standard/imageReceiverMultiThread/AppScope/app.json new file mode 100644 index 0000000000000000000000000000000000000000..1923d592dc0c95746a35abbd5486a60cc209ed59 --- /dev/null +++ b/multimedia/image/image_js_standard/imageReceiverMultiThread/AppScope/app.json @@ -0,0 +1,21 @@ +{ + "app": { + "bundleName": "ohos.acts.multimedia.image.receiverMultiThread", + "vendor": "open", + "versionCode": 1000000, + "versionName": "1.0.0", + "icon": "$media:icon", + "label": "$string:app_name", + "distributedNotificationEnabled": true, + "debug": false, + "description": "$string:app_name", + "keepAlive": true, + "singleUser": true, + "minAPIVersion": 9, + "targetAPIVersion": 9, + "car": { + "apiCompatibleVersion": 9, + "singleUser": false + } + } +} \ No newline at end of file diff --git a/multimedia/image/image_js_standard/imageReceiverMultiThread/AppScope/resources/base/element/string.json b/multimedia/image/image_js_standard/imageReceiverMultiThread/AppScope/resources/base/element/string.json new file mode 100644 index 0000000000000000000000000000000000000000..7fba249de04d91bda95106e7a1f524a2f2bd2354 --- /dev/null +++ b/multimedia/image/image_js_standard/imageReceiverMultiThread/AppScope/resources/base/element/string.json @@ -0,0 +1,6 @@ +{ + "string": [{ + "name": "app_name", + "value": "imageReceiverMultiThread" + }] +} \ No newline at end of file diff --git a/multimedia/image/image_js_standard/imageReceiverMultiThread/AppScope/resources/base/media/app_icon.png b/multimedia/image/image_js_standard/imageReceiverMultiThread/AppScope/resources/base/media/app_icon.png new file mode 100644 index 0000000000000000000000000000000000000000..ce307a8827bd75456441ceb57d530e4c8d45d36c Binary files /dev/null and b/multimedia/image/image_js_standard/imageReceiverMultiThread/AppScope/resources/base/media/app_icon.png differ diff --git a/multimedia/image/image_js_standard/imageReceiverMultiThread/BUILD.gn b/multimedia/image/image_js_standard/imageReceiverMultiThread/BUILD.gn new file mode 100644 index 0000000000000000000000000000000000000000..bac73d40e53096613245b20c3f7223b38812391e --- /dev/null +++ b/multimedia/image/image_js_standard/imageReceiverMultiThread/BUILD.gn @@ -0,0 +1,43 @@ +# Copyright (C) 2023 Huawei Device Co., Ltd. +# Licensed under the Apache License, Version 2.0 (the "License"); +# you may not use this file except in compliance with the License. +# You may obtain a copy of the License at +# +# http://www.apache.org/licenses/LICENSE-2.0 +# +# Unless required by applicable law or agreed to in writing, software +# distributed under the License is distributed on an "AS IS" BASIS, +# WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. +# See the License for the specific language governing permissions and +# limitations under the License. + +import("//test/xts/tools/build/suite.gni") + +ohos_js_hap_suite("image_receiver_multi_thread_hap") { + hap_profile = "entry/src/main/module.json" + js_build_mode = "debug" + deps = [ + ":image_receiver_multi_thread_js_assets", + ":image_receiver_multi_thread_resources", + ] + ets2abc = true + certificate_profile = "signature/openharmony_sx.p7b" + hap_name = "ActsImageReceiverMultiThreadJsTest" + subsystem_name = "multimedia" + part_name = "multimedia_image_framework" +} + +ohos_app_scope("image_receiver_multi_thread_app_profile") { + app_profile = "AppScope/app.json" + sources = [ "AppScope/resources" ] +} + +ohos_js_assets("image_receiver_multi_thread_js_assets") { + source_dir = "entry/src/main/ets" +} + +ohos_resources("image_receiver_multi_thread_resources") { + sources = [ "entry/src/main/resources" ] + deps = [ ":image_receiver_multi_thread_app_profile" ] + hap_profile = "entry/src/main/module.json" +} diff --git a/multimedia/image/image_js_standard/imageReceiverMultiThread/Test.json b/multimedia/image/image_js_standard/imageReceiverMultiThread/Test.json new file mode 100644 index 0000000000000000000000000000000000000000..9b038b4f809fa00772cdc418f89e084d2a4d0ab4 --- /dev/null +++ b/multimedia/image/image_js_standard/imageReceiverMultiThread/Test.json @@ -0,0 +1,25 @@ +{ + "description": "Configuration for hjunit demo Tests", + "driver": { + "type": "OHJSUnitTest", + "test-timeout": "800000", + "bundle-name": "ohos.acts.multimedia.image.receiverMultiThread", + "module-name": "entry", + "shell-timeout": "800000" + }, + "kits": [ + { + "test-file-name": [ + "ActsImageReceiverMultiThreadJsTest.hap" + ], + "type": "AppInstallKit", + "cleanup-apps": true + }, + { + "type": "ShellKit", + "run-command": [ + "hilog -Q pidoff" + ] + } + ] +} \ No newline at end of file diff --git a/multimedia/image/image_js_standard/imageReceiverMultiThread/entry/src/main/ets/Application/AbilityStage.ts b/multimedia/image/image_js_standard/imageReceiverMultiThread/entry/src/main/ets/Application/AbilityStage.ts new file mode 100644 index 0000000000000000000000000000000000000000..df98fe9ea12f3f8d03237708bf2a485d85310e5b --- /dev/null +++ b/multimedia/image/image_js_standard/imageReceiverMultiThread/entry/src/main/ets/Application/AbilityStage.ts @@ -0,0 +1,22 @@ +/* + * Copyright (C) 2023 Huawei Device Co., Ltd. + * Licensed under the Apache License, Version 2.0 (the "License"); + * you may not use this file except in compliance with the License. + * You may obtain a copy of the License at + * + * http://www.apache.org/licenses/LICENSE-2.0 + * + * Unless required by applicable law or agreed to in writing, software + * distributed under the License is distributed on an "AS IS" BASIS, + * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. + * See the License for the specific language governing permissions and + * limitations under the License. + */ +import AbilityStage from "@ohos.app.ability.AbilityStage" + +var printLog0 = 'ImageReceiverMultiThread:AbilityStage:' +export default class MyAbilityStage extends AbilityStage { + onCreate() { + console.info(printLog0 + "onCreate") + } +} \ No newline at end of file diff --git a/multimedia/image/image_js_standard/imageReceiverMultiThread/entry/src/main/ets/MainAbility/MainAbility.ts b/multimedia/image/image_js_standard/imageReceiverMultiThread/entry/src/main/ets/MainAbility/MainAbility.ts new file mode 100644 index 0000000000000000000000000000000000000000..a8491ab34cb626f9153e007e46f85ad924daf650 --- /dev/null +++ b/multimedia/image/image_js_standard/imageReceiverMultiThread/entry/src/main/ets/MainAbility/MainAbility.ts @@ -0,0 +1,51 @@ +/* + * Copyright (C) 2023 Huawei Device Co., Ltd. + * Licensed under the Apache License, Version 2.0 (the "License"); + * you may not use this file except in compliance with the License. + * You may obtain a copy of the License at + * + * http://www.apache.org/licenses/LICENSE-2.0 + * + * Unless required by applicable law or agreed to in writing, software + * distributed under the License is distributed on an "AS IS" BASIS, + * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. + * See the License for the specific language governing permissions and + * limitations under the License. + */ +import Ability from '@ohos.app.ability.UIAbility'; + +var printLog = 'ImageReceiverMultiThread:MainAbility:' +export default class MainAbility extends Ability { + onCreate(want, launchParam) { + console.info(printLog + 'onCreate') + } + + onDestroy() { + console.info(printLog + 'onDestroy') + } + + onWindowStageCreate(windowStage) { + // Main window is created, set main page for this ability + console.info(printLog + 'onWindowStageCreate') + + windowStage.loadContent("MainAbility/pages/index", (err, data) => { + if (err.code) { + console.error('Failed to load the content. Cause:' + JSON.stringify(err)); + return; + } + console.info('Succeeded in loading the content. Data: ' + JSON.stringify(data)) + }); + } + + onWindowStageDestroy() { + console.info(printLog + 'onWindowStageDestroy') + } + + onForeground() { + console.info(printLog + 'onForeground') + } + + onBackground() { + console.info(printLog + 'onBackground') + } +}; diff --git a/multimedia/image/image_js_standard/imageReceiverMultiThread/entry/src/main/ets/MainAbility/pages/index.ets b/multimedia/image/image_js_standard/imageReceiverMultiThread/entry/src/main/ets/MainAbility/pages/index.ets new file mode 100644 index 0000000000000000000000000000000000000000..21ea88dd216d51f0ba490ead582b1c75bcc6a431 --- /dev/null +++ b/multimedia/image/image_js_standard/imageReceiverMultiThread/entry/src/main/ets/MainAbility/pages/index.ets @@ -0,0 +1,46 @@ +/* + * Copyright (C) 2023 Huawei Device Co., Ltd. + * Licensed under the Apache License, Version 2.0 (the "License"); + * you may not use this file except in compliance with the License. + * You may obtain a copy of the License at + * + * http://www.apache.org/licenses/LICENSE-2.0 + * + * Unless required by applicable law or agreed to in writing, software + * distributed under the License is distributed on an "AS IS" BASIS, + * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. + * See the License for the specific language governing permissions and + * limitations under the License. + */ +import router from '@ohos.router'; +import AbilityDelegatorRegistry from '@ohos.application.abilityDelegatorRegistry' +import { Hypium } from '@ohos/hypium' +import testsuite from '../../test/List.test' + +@Entry +@Component +struct Index { + @State message: string = 'MainAbility ImageReceiverMultiThread' + + aboutToAppear() { + console.info("start run testcase!!!!") + var abilityDelegator: any + abilityDelegator = AbilityDelegatorRegistry.getAbilityDelegator() + var abilityDelegatorArguments: any + abilityDelegatorArguments = AbilityDelegatorRegistry.getArguments() + console.info('start run testcase!!!') + Hypium.hypiumTest(abilityDelegator, abilityDelegatorArguments, testsuite) + } + + build() { + Row() { + Column() { + Text(this.message) + .fontSize(50) + .fontWeight(FontWeight.Bold) + } + .width('100%') + } + .height('100%') + } +} \ No newline at end of file diff --git a/multimedia/image/image_js_standard/imageReceiverMultiThread/entry/src/main/ets/TestAbility/TestAbility.ts b/multimedia/image/image_js_standard/imageReceiverMultiThread/entry/src/main/ets/TestAbility/TestAbility.ts new file mode 100644 index 0000000000000000000000000000000000000000..c0e4cc032a3c49fe10378e39725355a150240b59 --- /dev/null +++ b/multimedia/image/image_js_standard/imageReceiverMultiThread/entry/src/main/ets/TestAbility/TestAbility.ts @@ -0,0 +1,49 @@ +/* + * Copyright (C) 2023 Huawei Device Co., Ltd. + * Licensed under the Apache License, Version 2.0 (the "License"); + * you may not use this file except in compliance with the License. + * You may obtain a copy of the License at + * + * http://www.apache.org/licenses/LICENSE-2.0 + * + * Unless required by applicable law or agreed to in writing, software + * distributed under the License is distributed on an "AS IS" BASIS, + * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. + * See the License for the specific language governing permissions and + * limitations under the License. + */ +import Ability from '@ohos.app.ability.UIAbility' + +export default class TestAbility extends Ability { + onCreate(want, launchParam) { + console.log('TestAbility onCreate') + } + + onDestroy() { + console.log('TestAbility onDestroy') + } + + onWindowStageCreate(windowStage) { + console.log('TestAbility onWindowStageCreate') + windowStage.loadContent("TestAbility/pages/index", (err, data) => { + if (err.code) { + console.error('Failed to load the content. Cause:' + JSON.stringify(err)); + return; + } + console.info('Succeeded in loading the content. Data: ' + JSON.stringify(data)) + }); + + } + + onWindowStageDestroy() { + console.log('TestAbility onWindowStageDestroy') + } + + onForeground() { + console.log('TestAbility onForeground') + } + + onBackground() { + console.log('TestAbility onBackground') + } +}; \ No newline at end of file diff --git a/multimedia/image/image_js_standard/imageReceiverMultiThread/entry/src/main/ets/TestAbility/pages/index.ets b/multimedia/image/image_js_standard/imageReceiverMultiThread/entry/src/main/ets/TestAbility/pages/index.ets new file mode 100644 index 0000000000000000000000000000000000000000..36b6d9705609c35ce7fe060c62942130281f36c7 --- /dev/null +++ b/multimedia/image/image_js_standard/imageReceiverMultiThread/entry/src/main/ets/TestAbility/pages/index.ets @@ -0,0 +1,48 @@ +/* + * Copyright (C) 2023 Huawei Device Co., Ltd. + * Licensed under the Apache License, Version 2.0 (the "License"); + * you may not use this file except in compliance with the License. + * You may obtain a copy of the License at + * + * http://www.apache.org/licenses/LICENSE-2.0 + * + * Unless required by applicable law or agreed to in writing, software + * distributed under the License is distributed on an "AS IS" BASIS, + * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. + * See the License for the specific language governing permissions and + * limitations under the License. + */ +import router from '@ohos.router'; + +@Entry +@Component +struct Index { + aboutToAppear() { + console.info('TestAbility index aboutToAppear') + } + @State message: string = 'Hello World' + build() { + Row() { + Column() { + Text(this.message) + .fontSize(50) + .fontWeight(FontWeight.Bold) + Button() { + Text('next page') + .fontSize(20) + .fontWeight(FontWeight.Bold) + }.type(ButtonType.Capsule) + .margin({ + top: 20 + }) + .backgroundColor('#0D9FFB') + .width('35%') + .height('5%') + .onClick(() => { + }) + } + .width('100%') + } + .height('100%') + } +} \ No newline at end of file diff --git a/multimedia/image/image_js_standard/imageReceiverMultiThread/entry/src/main/ets/TestRunner/OpenHarmonyTestRunner.ts b/multimedia/image/image_js_standard/imageReceiverMultiThread/entry/src/main/ets/TestRunner/OpenHarmonyTestRunner.ts new file mode 100644 index 0000000000000000000000000000000000000000..38a435968c3e28d470c82919507a665fead064ba --- /dev/null +++ b/multimedia/image/image_js_standard/imageReceiverMultiThread/entry/src/main/ets/TestRunner/OpenHarmonyTestRunner.ts @@ -0,0 +1,77 @@ +/* + * Copyright (C) 2023 Huawei Device Co., Ltd. + * Licensed under the Apache License, Version 2.0 (the "License"); + * you may not use this file except in compliance with the License. + * You may obtain a copy of the License at + * + * http://www.apache.org/licenses/LICENSE-2.0 + * + * Unless required by applicable law or agreed to in writing, software + * distributed under the License is distributed on an "AS IS" BASIS, + * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. + * See the License for the specific language governing permissions and + * limitations under the License. + */ +import TestRunner from '@ohos.application.testRunner' +import AbilityDelegatorRegistry from '@ohos.application.abilityDelegatorRegistry' + +var abilityDelegator = undefined +var abilityDelegatorArguments = undefined + +function translateParamsToString(parameters) { + const keySet = new Set([ + '-s class', '-s notClass', '-s suite', '-s it', + '-s level', '-s testType', '-s size', '-s timeout', + '-s dryRun' + ]) + let targetParams = ''; + for (const key in parameters) { + if (keySet.has(key)) { + targetParams = `${targetParams} ${key} ${parameters[key]}` + } + } + return targetParams.trim() +} + +async function onAbilityCreateCallback() { + console.log("onAbilityCreateCallback"); +} + +async function addAbilityMonitorCallback(err: any) { + console.info("addAbilityMonitorCallback : " + JSON.stringify(err)) +} + +export default class OpenHarmonyTestRunner implements TestRunner { + constructor() { + } + + onPrepare() { + console.info("OpenHarmonyTestRunner OnPrepare ") + } + + async onRun() { + console.log('OpenHarmonyTestRunner onRun run') + abilityDelegatorArguments = AbilityDelegatorRegistry.getArguments() + abilityDelegator = AbilityDelegatorRegistry.getAbilityDelegator() + var testAbilityName = abilityDelegatorArguments.bundleName + '.MainAbility' + let lMonitor = { + abilityName: testAbilityName, + onAbilityCreate: onAbilityCreateCallback, + }; + abilityDelegator.addAbilityMonitor(lMonitor, addAbilityMonitorCallback) + var cmd = 'aa start -d 0 -a .MainAbility' + ' -b ' + abilityDelegatorArguments.bundleName + cmd += ' ' + translateParamsToString(abilityDelegatorArguments.parameters) + var debug = abilityDelegatorArguments.parameters["-D"] + if (debug == 'true') { + cmd += ' -D' + } + console.info('cmd : ' + cmd) + abilityDelegator.executeShellCommand(cmd, + (err: any, d: any) => { + console.info('executeShellCommand : err : ' + JSON.stringify(err)); + console.info('executeShellCommand : data : ' + d.stdResult); + console.info('executeShellCommand : data : ' + d.exitCode); + }) + console.info('OpenHarmonyTestRunner onRun end') + } +}; \ No newline at end of file diff --git a/multimedia/image/image_js_standard/imageReceiverMultiThread/entry/src/main/ets/test/List.test.ets b/multimedia/image/image_js_standard/imageReceiverMultiThread/entry/src/main/ets/test/List.test.ets new file mode 100644 index 0000000000000000000000000000000000000000..36de4a28679dcc2ec3bbb4091ca637ec74b6f29f --- /dev/null +++ b/multimedia/image/image_js_standard/imageReceiverMultiThread/entry/src/main/ets/test/List.test.ets @@ -0,0 +1,20 @@ +/* + * Copyright (C) 2023 Huawei Device Co., Ltd. + * Licensed under the Apache License, Version 2.0 (the "License"); + * you may not use this file except in compliance with the License. + * You may obtain a copy of the License at + * + * http://www.apache.org/licenses/LICENSE-2.0 + * + * Unless required by applicable law or agreed to in writing, software + * distributed under the License is distributed on an "AS IS" BASIS, + * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. + * See the License for the specific language governing permissions and + * limitations under the License. + */ + +import multiThreadTest from './imageMultiThread.test.ets' + +export default function List() { + multiThreadTest() +} \ No newline at end of file diff --git a/multimedia/image/image_js_standard/imageReceiverMultiThread/entry/src/main/ets/test/imageMultiThread.test.ets b/multimedia/image/image_js_standard/imageReceiverMultiThread/entry/src/main/ets/test/imageMultiThread.test.ets new file mode 100644 index 0000000000000000000000000000000000000000..b7a6266d41c45ad5166af5551fdd2d8301dae92e --- /dev/null +++ b/multimedia/image/image_js_standard/imageReceiverMultiThread/entry/src/main/ets/test/imageMultiThread.test.ets @@ -0,0 +1,114 @@ +/* + * Copyright (C) 2023 Huawei Device Co., Ltd. + * Licensed under the Apache License, Version 2.0 (the 'License') + * you may not use this file except in compliance with the License. + * You may obtain a copy of the License at + * + * http://www.apache.org/licenses/LICENSE-2.0 + * + * Unless required by applicable law or agreed to in writing, software + * distributed under the License is distributed on an 'AS IS' BASIS, + * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. + * See the License for the specific language governing permissions and + * limitations under the License. + */ + +import app from '@system.app' +import worker from "@ohos.worker" +import { describe, beforeAll, beforeEach, afterEach, afterAll, it, expect } from '@ohos/hypium' + +const THREAD_COUNT = 8; + +async function promiseCase() { + return new Promise(function (resolve, reject) { + setTimeout(function () { + resolve(0) + }, 100) + }).then(undefined, (error) => { }) +} + +async function terminateThreads(threadWorks, count) { + let a = count; + let threadExitFlags = 0; + while (a > 0) { + threadWorks[a].onexit = function () { + threadExitFlags += 1; + } + threadWorks[a].terminate(); + a -= 1; + } + while (threadExitFlags != count) { + await promiseCase(); + } +} +async function doTest(done, name, runner) { + var threadWorks = []; + let threadExitFlags = 0; + console.info("Test " + name + " start!!"); + try { + let a = 0; + while (a < THREAD_COUNT) { + threadWorks[a] = new worker.ThreadWorker(runner); + threadWorks[a].onmessage = function (e) { + console.info(name + "worker:: ending work " + e.data); + if (e.data != undefined) { + threadWorks[e.data].terminate(); + } + } + threadWorks[a].onexit = function () { + threadExitFlags += 1; + } + a += 1; + } + // For threads ready + await promiseCase(); + + let b = 0; + while (b < THREAD_COUNT) { + threadWorks[b].postMessage(b); + b += 1; + } + + while (threadExitFlags != THREAD_COUNT) { + await promiseCase(); + } + done(); + } catch (error) { + console.info('Case error, ' + JSON.stringify(error)); + await terminateThreads(threadWorks, THREAD_COUNT); + done(); + } +} +export default function multiThreadTest() { + describe('multiThreadTest', function () { + afterAll(function () { + console.info('total case over'); + }) + + /** + * @tc.number : SUB_GRAPHIC_IMAGE_RECEIVER_MULTI_THREAD_0100 + * @tc.name : multiple thread + * @tc.desc : 1.create receiver.js + * 2.invoked simultaneously by multiple thread + * @tc.size : MEDIUM + * @tc.type : Functional + * @tc.level : Level 0 + */ + it('SUB_GRAPHIC_IMAGE_RECEIVER_MULTI_THREAD_0100', 0, async function (done) { + await doTest(done, "SUB_GRAPHIC_IMAGE_RECEIVER_MULTI_THREAD_0100", "entry/ets/workers/receiver.js"); + }) + + /** + * @tc.number : SUB_GRAPHIC_IMAGE_RECEIVER_MULTI_THREAD_0200 + * @tc.name : multiple thread + * @tc.desc : 1.create creator.js + * 2.invoked simultaneously by multiple thread + * @tc.size : MEDIUM + * @tc.type : Functional + * @tc.level : Level 0 + */ + it('SUB_GRAPHIC_IMAGE_RECEIVER_MULTI_THREAD_0200', 0, async function (done) { + await doTest(done, "SUB_GRAPHIC_IMAGE_RECEIVER_MULTI_THREAD_0200", "entry/ets/workers/creator.js"); + }) + }) +} \ No newline at end of file diff --git a/multimedia/image/image_js_standard/imageReceiverMultiThread/entry/src/main/ets/workers/creator.js b/multimedia/image/image_js_standard/imageReceiverMultiThread/entry/src/main/ets/workers/creator.js new file mode 100644 index 0000000000000000000000000000000000000000..473be73432fe4af0ca1ec1e9ccd3f9f67bdacd80 --- /dev/null +++ b/multimedia/image/image_js_standard/imageReceiverMultiThread/entry/src/main/ets/workers/creator.js @@ -0,0 +1,77 @@ +/* + * Copyright (C) 2023 Huawei Device Co., Ltd. + * Licensed under the Apache License, Version 2.0 (the "License"); + * you may not use this file except in compliance with the License. + * You may obtain a copy of the License at + * + * http://www.apache.org/licenses/LICENSE-2.0 + * + * Unless required by applicable law or agreed to in writing, software + * distributed under the License is distributed on an "AS IS" BASIS, + * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. + * See the License for the specific language governing permissions and + * limitations under the License. + */ + +import worker from '@ohos.worker'; +import imageApi from "@ohos.multimedia.image"; + +const parentPort = worker.workerPort; +console.info("worker:: new version") + +const WIDTH = 8192; +const HEIGHT = 8; +const CAPACITY = 8; +const { JPEG: FORMATJPEG } = imageApi.ImageFormat; + +function createCreator(threadId) { + const id = threadId + const creator = imageApi.createImageCreator(WIDTH, HEIGHT, FORMATJPEG, CAPACITY) + if (creator == undefined) { + return creator + } + creator.on("imageRelease", () => { + console.info("worker::creator imageRelease IN"); + }) + creator.dequeueImage((err1, img) => { + try { + if (err1 || img == undefined) { + console.info('dequeueImage fail: ' + err1); + return; + } + console.info('dequeueImage Success: ' + id); + creator.queueImage(img, (err2) => { + if (err2) { + console.info('queueImage failerr: ' + err2); + return; + } + console.info('queueImage Success ' + id); + var dummy = creator.test; + parentPort.postMessage(id); + }) + } catch (error0) { + console.info('dequeueImage catch: ' + error0); + } + }) + return creator; +} + +parentPort.onclose = function () { + console.info("worker::worker.js onclose"); +} + +parentPort.onmessage = function (e) { + let data = e.data; + console.info("worker:: worker2 thread worker data is " + data); + var dummy = createCreator(data); +} + +// Deserialization error +parentPort.onmessageerror = function () { + console.info("worker:: worker.js onmessageerror"); +} + +// js execution error +parentPort.onerror = function (data) { + console.info("worker:: worker.js onerror " + data.lineno + ", msg = " + data.message + ", filename = " + data.filename + ", colno = " + data.colno); +} \ No newline at end of file diff --git a/multimedia/image/image_js_standard/imageReceiverMultiThread/entry/src/main/ets/workers/receiver.js b/multimedia/image/image_js_standard/imageReceiverMultiThread/entry/src/main/ets/workers/receiver.js new file mode 100644 index 0000000000000000000000000000000000000000..60aabc274957af20b095fe35a39af2eae93a13d0 --- /dev/null +++ b/multimedia/image/image_js_standard/imageReceiverMultiThread/entry/src/main/ets/workers/receiver.js @@ -0,0 +1,74 @@ +/* + * Copyright (C) 2023 Huawei Device Co., Ltd. + * Licensed under the Apache License, Version 2.0 (the "License"); + * you may not use this file except in compliance with the License. + * You may obtain a copy of the License at + * + * http://www.apache.org/licenses/LICENSE-2.0 + * + * Unless required by applicable law or agreed to in writing, software + * distributed under the License is distributed on an "AS IS" BASIS, + * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. + * See the License for the specific language governing permissions and + * limitations under the License. + */ + +import worker from '@ohos.worker'; +import imageApi from "@ohos.multimedia.image"; + +const parentPort = worker.workerPort; +console.info("worker:: new version") + +const WIDTH = 8192; +const HEIGHT = 8; +const CAPACITY = 8; +const { JPEG: FORMATJPEG } = imageApi.ImageFormat; +const { JPEG } = imageApi.ComponentType; +let isFirstlisten = false; + +function createRecriver(threadId) { + const id = threadId + const receiver = imageApi.createImageReceiver(WIDTH, HEIGHT, FORMATJPEG, CAPACITY); + if (receiver == undefined) { + return receiver + } + receiver.on("imageArrival", () => { + console.info("worker::on in " + id); + if (isFirstlisten) { + return + } + console.info("worker::on in in " + id); + isFirstlisten = true; + receiver.readLatestImage((err, img) => { + console.info("worker::readLatestImage " + id); + img.getComponent(JPEG, (err2, component) => { + console.info("worker::getComponent err " + JSON.stringify(err2)); + parentPort.postMessage(id); + }); + }); + }) + return receiver; +} + +parentPort.onclose = function () { + console.info("worker::worker.js onclose"); +} + +parentPort.onmessage = function (e) { + let data = e.data; + console.info("worker:: worker thread worker data is " + data); + let receiver = createRecriver(data); + if (receiver != undefined) { + var dummy = receiver.test; + } +} + +// Deserialization error +parentPort.onmessageerror = function () { + console.info("worker:: worker.js onmessageerror"); +} + +// js execution error +parentPort.onerror = function (data) { + console.info("worker:: worker.js onerror " + data.lineno + ", msg = " + data.message + ", filename = " + data.filename + ", colno = " + data.colno); +} \ No newline at end of file diff --git a/multimedia/image/image_js_standard/imageReceiverMultiThread/entry/src/main/module.json b/multimedia/image/image_js_standard/imageReceiverMultiThread/entry/src/main/module.json new file mode 100644 index 0000000000000000000000000000000000000000..9acb2daaa148b20cd2ff293fe13ca28a63a0389b --- /dev/null +++ b/multimedia/image/image_js_standard/imageReceiverMultiThread/entry/src/main/module.json @@ -0,0 +1,36 @@ +{ + "module": { + "name": "entry", + "type": "entry", + "srcEntrance": "./ets/Application/AbilityStage.ts", + "description": "$string:entry_desc", + "mainElement": ".MainAbility", + "deviceTypes": [ + "default", + "tablet" + ], + "deliveryWithInstall": true, + "installationFree": false, + "pages": "$profile:main_pages", + "uiSyntax": "ets", + "abilities": [{ + "name": ".MainAbility", + "srcEntrance": "./ets/MainAbility/MainAbility.ts", + "description": "$string:MainAbility_desc", + "icon": "$media:icon", + "label": "$string:MainAbility_label", + "startWindowIcon": "$media:icon", + "startWindowBackground": "$color:white", + "visible": true, + "orientation": "portrait", + "skills": [{ + "entities": [ + "entity.system.home" + ], + "actions": [ + "action.system.home" + ] + }] + }] + } +} \ No newline at end of file diff --git a/multimedia/image/image_js_standard/imageReceiverMultiThread/entry/src/main/resources/base/element/color.json b/multimedia/image/image_js_standard/imageReceiverMultiThread/entry/src/main/resources/base/element/color.json new file mode 100644 index 0000000000000000000000000000000000000000..1bbc9aa9617e97c45440e1d3d66afc1154837012 --- /dev/null +++ b/multimedia/image/image_js_standard/imageReceiverMultiThread/entry/src/main/resources/base/element/color.json @@ -0,0 +1,8 @@ +{ + "color": [ + { + "name": "white", + "value": "#FFFFFF" + } + ] +} \ No newline at end of file diff --git a/multimedia/image/image_js_standard/imageReceiverMultiThread/entry/src/main/resources/base/element/string.json b/multimedia/image/image_js_standard/imageReceiverMultiThread/entry/src/main/resources/base/element/string.json new file mode 100644 index 0000000000000000000000000000000000000000..b8416b237de5fe166d47eb8720d73a089b6d9fe0 --- /dev/null +++ b/multimedia/image/image_js_standard/imageReceiverMultiThread/entry/src/main/resources/base/element/string.json @@ -0,0 +1,24 @@ +{ + "string": [ + { + "name": "entry_desc", + "value": "description" + }, + { + "name": "MainAbility_desc", + "value": "description" + }, + { + "name": "MainAbility_label", + "value": "label" + }, + { + "name": "form_FormAbility_desc", + "value": "form_description" + }, + { + "name": "form_FormAbility_label", + "value": "form_label" + } + ] +} \ No newline at end of file diff --git a/multimedia/image/image_js_standard/imageReceiverMultiThread/entry/src/main/resources/base/media/icon.png b/multimedia/image/image_js_standard/imageReceiverMultiThread/entry/src/main/resources/base/media/icon.png new file mode 100644 index 0000000000000000000000000000000000000000..ce307a8827bd75456441ceb57d530e4c8d45d36c Binary files /dev/null and b/multimedia/image/image_js_standard/imageReceiverMultiThread/entry/src/main/resources/base/media/icon.png differ diff --git a/multimedia/image/image_js_standard/imageReceiverMultiThread/entry/src/main/resources/base/profile/main_pages.json b/multimedia/image/image_js_standard/imageReceiverMultiThread/entry/src/main/resources/base/profile/main_pages.json new file mode 100644 index 0000000000000000000000000000000000000000..c1858c216308ad312862a877139a8ba6908ec3c6 --- /dev/null +++ b/multimedia/image/image_js_standard/imageReceiverMultiThread/entry/src/main/resources/base/profile/main_pages.json @@ -0,0 +1,5 @@ +{ + "src": [ + "MainAbility/pages/index" + ] +} diff --git a/multimedia/image/image_js_standard/imageReceiverMultiThread/signature/openharmony_sx.p7b b/multimedia/image/image_js_standard/imageReceiverMultiThread/signature/openharmony_sx.p7b new file mode 100644 index 0000000000000000000000000000000000000000..b31ad72ef0583ace68b111bf83aa919665ca5ab7 Binary files /dev/null and b/multimedia/image/image_js_standard/imageReceiverMultiThread/signature/openharmony_sx.p7b differ