From 29e1af022974d22866be74f42aea88482e3df45d Mon Sep 17 00:00:00 2001 From: baishimin <2258359443@qq.com> Date: Fri, 18 Oct 2024 17:52:14 +0800 Subject: [PATCH 1/2] -s --- ylong_runtime/src/builder/multi_thread_builder.rs | 5 +++-- 1 file changed, 3 insertions(+), 2 deletions(-) diff --git a/ylong_runtime/src/builder/multi_thread_builder.rs b/ylong_runtime/src/builder/multi_thread_builder.rs index 397ab68..51ac3d3 100644 --- a/ylong_runtime/src/builder/multi_thread_builder.rs +++ b/ylong_runtime/src/builder/multi_thread_builder.rs @@ -15,7 +15,8 @@ use std::io; use std::sync::Mutex; cfg_ffrt!( - use ylong_ffrt::{ffrt_set_cpu_worker_max_num, ffrt_set_worker_stack_size, Qos}; + // use ylong_ffrt::{ffrt_set_cpu_worker_max_num, ffrt_set_worker_stack_size, Qos}; + use ylong_ffrt::{ffrt_set_worker_stack_size, Qos}; use std::collections::HashMap; use libc::{c_uint, c_ulong}; use std::time::Duration; @@ -69,7 +70,7 @@ impl MultiThreadBuilder { #[cfg(feature = "ffrt")] unsafe { for (qos, worker_num) in self.thread_num_by_qos.iter() { - ffrt_set_cpu_worker_max_num(*qos, *worker_num as c_uint); + // ffrt_set_cpu_worker_max_num(*qos, *worker_num as c_uint); } for (qos, stack_size) in self.common.stack_size_by_qos.iter() { -- Gitee From fdd461db197854244c8df8f3f5b86f3a593ea865 Mon Sep 17 00:00:00 2001 From: baishimin <2258359443@qq.com> Date: Fri, 18 Oct 2024 17:52:14 +0800 Subject: [PATCH 2/2] ffrt worker num Signed-off-by: baishimin <2258359443@qq.com> --- ylong_runtime/src/builder/multi_thread_builder.rs | 5 +++-- 1 file changed, 3 insertions(+), 2 deletions(-) diff --git a/ylong_runtime/src/builder/multi_thread_builder.rs b/ylong_runtime/src/builder/multi_thread_builder.rs index 397ab68..51ac3d3 100644 --- a/ylong_runtime/src/builder/multi_thread_builder.rs +++ b/ylong_runtime/src/builder/multi_thread_builder.rs @@ -15,7 +15,8 @@ use std::io; use std::sync::Mutex; cfg_ffrt!( - use ylong_ffrt::{ffrt_set_cpu_worker_max_num, ffrt_set_worker_stack_size, Qos}; + // use ylong_ffrt::{ffrt_set_cpu_worker_max_num, ffrt_set_worker_stack_size, Qos}; + use ylong_ffrt::{ffrt_set_worker_stack_size, Qos}; use std::collections::HashMap; use libc::{c_uint, c_ulong}; use std::time::Duration; @@ -69,7 +70,7 @@ impl MultiThreadBuilder { #[cfg(feature = "ffrt")] unsafe { for (qos, worker_num) in self.thread_num_by_qos.iter() { - ffrt_set_cpu_worker_max_num(*qos, *worker_num as c_uint); + // ffrt_set_cpu_worker_max_num(*qos, *worker_num as c_uint); } for (qos, stack_size) in self.common.stack_size_by_qos.iter() { -- Gitee