Home
last modified time | relevance | path

Searched refs:num (Results 1 - 25 of 41) sorted by relevance

12

/commonlibrary/rust/ylong_runtime/ylong_runtime/tests/
H A Dspawn.rs14 async fn test_future(num: usize) -> usize {
15 num
31 let num = 1000; in sdv_one_core_test()
33 let mut handles = Vec::with_capacity(num); in sdv_one_core_test()
35 for i in 0..num { in sdv_one_core_test()
48 let num = 1000; in sdv_two_core_test()
50 let mut handles = Vec::with_capacity(num); in sdv_two_core_test()
52 for i in 0..num { in sdv_two_core_test()
65 let num = 1000; in sdv_three_core_test()
67 let mut handles = Vec::with_capacity(num); in sdv_three_core_test()
[all...]
H A Dspawn_blocking.rs25 let num = 1000; in ffrt_spawn_blocking_test()
27 let mut handles = Vec::with_capacity(num); in ffrt_spawn_blocking_test()
28 for i in 0..num { in ffrt_spawn_blocking_test()
40 let mut handles = Vec::with_capacity(num); in ffrt_spawn_blocking_test()
42 for i in 0..num { in ffrt_spawn_blocking_test()
66 let num = 1000; in test_spawn()
68 let mut handles = Vec::with_capacity(num); in test_spawn()
69 for i in 0..num { in test_spawn()
80 let mut handles = Vec::with_capacity(num); in test_spawn()
81 for i in 0..num { in test_spawn()
[all...]
H A Dsignal.rs68 let num = Arc::new(AtomicUsize::new(0)); in sdv_signal_recv_multi_thread_test()
71 let num_clone = num.clone(); in sdv_signal_recv_multi_thread_test()
78 while num.load(Acquire) < 10 {} in sdv_signal_recv_multi_thread_test()
112 let num = Arc::new(AtomicUsize::new(0)); in sdv_signal_poll_recv_multi_thread_test()
115 let num_clone = num.clone(); in sdv_signal_poll_recv_multi_thread_test()
122 while num.load(Acquire) < 10 {} in sdv_signal_poll_recv_multi_thread_test()
H A Dbuilder.rs21 async fn test_future(num: usize) -> usize {
22 num
H A Dsingleton_runtime.rs21 async fn test_future(num: usize) -> usize {
22 num
/commonlibrary/rust/ylong_runtime/ylong_runtime/examples/
H A Dylong_tokio_schedule.rs34 fn ylong_schedule_task(num: usize) { in ylong_schedule_task()
35 let mut handlers = Vec::with_capacity(num); in ylong_schedule_task()
36 for _ in 0..num { in ylong_schedule_task()
47 fn tokio_schedule_task(num: usize) { in tokio_schedule_task()
52 let mut handlers = Vec::with_capacity(num); in tokio_schedule_task()
53 for _ in 0..num { in tokio_schedule_task()
64 fn ylong_schedule_fibbo_task(num: usize) { in ylong_schedule_fibbo_task()
65 let mut handlers = Vec::with_capacity(num); in ylong_schedule_fibbo_task()
66 for _ in 0..num { in ylong_schedule_fibbo_task()
78 fn tokio_schedule_fibbo_task(num
[all...]
H A Dylong_runtime_signal.rs39 let num = Arc::new(AtomicUsize::new(0)); in run_multi_thread_signal()
42 let num_clone = num.clone(); in run_multi_thread_signal()
49 while num.load(Acquire) < 10 {} in run_multi_thread_signal()
58 let num = Arc::new(AtomicUsize::new(0)); in run_multi_thread_signal()
61 let num_clone = num.clone(); in run_multi_thread_signal()
69 while num.load(Acquire) < 10 {} in run_multi_thread_signal()
H A Dylong_runtime_multi_runtimes.rs19 async fn test_future(num: usize) -> usize {
20 num
/commonlibrary/rust/ylong_runtime/ylong_runtime/benches/
H A Dylong_tokio_signal.rs28 ($runtime: expr, $bench: ident, $kind: expr, $sig: ident, $num: literal) => {
34 let num = Arc::new(AtomicUsize::new(0));
35 let mut handlers = Vec::with_capacity($num);
36 for _ in 0..$num {
37 let num_clone = num.clone();
44 while num.load(Acquire) < 10 {}
56 ($runtime: expr, $bench: ident, $kind: expr, $sig: ident, $num: literal) => {
64 for _ in 0..$num {
77 ($runtime: expr, $bench: ident, $kind: expr, $sig: ident, $num: literal) => {
83 let num
[all...]
H A Dylong_tokio_spawn_blocking.rs25 ($runtime: expr, $bench: ident, $num: literal, $upper: literal) => {
30 let mut handlers = Vec::with_capacity($num);
31 for _ in 0..$num {
47 ($bench: ident, $num: literal, $upper: literal) => {
51 let mut handlers = Vec::with_capacity($num);
52 for _ in 0..$num {
H A Dylong_tokio_mutex.rs30 ($runtime: expr, $bench: ident, $mutex: ident, $num: literal) => {
37 let mut handlers = Vec::with_capacity($num);
38 for _ in 0..$num {
53 assert_eq!(*n, $num * 1000);
62 ($bench: ident, $mutex: ident, $num: literal) => {
67 let mut handlers = Vec::with_capacity($num);
68 for _ in 0..$num {
83 assert_eq!(*n, $num * 1000);
H A Dylong_tokio_schedule.rs22 ($runtime: expr, $bench: ident, $num: literal, $upper: literal) => {
27 let mut handlers = Vec::with_capacity($num);
28 for _ in 0..$num {
45 ($bench: ident, $num: literal, $upper: literal) => {
49 let mut handlers = Vec::with_capacity($num);
50 for _ in 0..$num {
H A Dylong_tokio_bounded_mpsc.rs25 ($runtime: expr, $bench: ident, $num: literal, $loop_num: literal) => {
33 for _ in 0..$num * $loop_num {
40 for _ in 0..$num {
60 ($bench: ident, $num: literal, $loop_num: literal) => {
67 for _ in 0..$num * $loop_num {
74 for _ in 0..$num {
H A Dylong_tokio_unbounded_mpsc.rs25 ($runtime: expr, $bench: ident, $num: literal, $loop_num: literal) => {
33 for _ in 0..$num * $loop_num {
40 for _ in 0..$num {
60 ($bench: ident, $num: literal, $loop_num: literal) => {
67 for _ in 0..$num * $loop_num {
74 for _ in 0..$num {
/commonlibrary/rust/ylong_runtime/ylong_runtime/src/builder/
H A Dmulti_thread_builder.rs98 pub fn max_worker_num_by_qos(mut self, qos: Qos, num: u32) -> Self { in max_worker_num_by_qos()
99 let worker = match num { in max_worker_num_by_qos()
326 let num = builder.thread_num_by_qos.get(&UserInteractive).unwrap(); in ut_set_max_worker()
327 assert_eq!(*num, 1); in ut_set_max_worker()
330 let num = builder.thread_num_by_qos.get(&UserInteractive).unwrap(); in ut_set_max_worker()
331 assert_eq!(*num, 20); in ut_set_max_worker()
334 let num = builder.thread_num_by_qos.get(&Default).unwrap(); in ut_set_max_worker()
335 assert_eq!(*num, 8); in ut_set_max_worker()
353 let num = builder in ut_set_stack_size()
358 assert_eq!(*num, 1 in ut_set_stack_size()
[all...]
/commonlibrary/memory_utils/libsync/src/
H A Dsync.c20 int SyncWait(int num, int time) in SyncWait() argument
25 if (num < 0) { in SyncWait()
30 work.fd = num; in SyncWait()
/commonlibrary/rust/ylong_runtime/ylong_ffrt/src/
H A Dconfig.rs22 pub fn ffrt_set_cpu_worker_max_num(qos: Qos, num: c_uint); in ffrt_set_cpu_worker_max_num()
25 pub fn ffrt_set_worker_stack_size(qos: Qos, num: c_ulong); in ffrt_set_worker_stack_size()
/commonlibrary/rust/ylong_http/ylong_http/src/util/
H A Dtest_util.rs25 Ok(num) => vec.push(num), in decode()
/commonlibrary/ets_utils/js_sys_module/test/
H A Dtest_process.cpp566 int32_t num = 0; in HWTEST_F() local
567 napi_get_value_int32(env, result, &num); in HWTEST_F()
569 if (num >= 0) { in HWTEST_F()
589 int32_t num = 0; in HWTEST_F() local
590 napi_get_value_int32(env, result, &num); in HWTEST_F()
592 if (num == -1) { in HWTEST_F()
629 double num = 0; in HWTEST_F() local
630 napi_get_value_double(env, result, &num); in HWTEST_F()
632 if (num != 0) { in HWTEST_F()
648 int32_t num in HWTEST_F() local
670 int32_t num = 0; HWTEST_F() local
698 int32_t num = 0; HWTEST_F() local
[all...]
/commonlibrary/memory_utils/libsync/include/
H A Dsync.h18 int SyncWait(int num, int time);
/commonlibrary/rust/ylong_http/ylong_http/src/body/mime/common/
H A Dmod.rs78 let num = (&src[*src_idx..]).read(buf)?;
79 *src_idx += num;
81 return Ok(TokenStatus::Complete(num));
83 Ok(TokenStatus::Partial(num))
/commonlibrary/rust/ylong_runtime/ylong_io/src/
H A Dinterest.rs14 use std::num::NonZeroU8;
83 use std::num::NonZeroU8; in ut_interest_to_io_event()
/commonlibrary/rust/ylong_runtime/ylong_runtime/src/
H A Dfastrand.rs20 use std::num::Wrapping;
/commonlibrary/ets_utils/js_api_module/url/
H A Djs_url.cpp516 bool IsRadix(std::string num, std::string radix) in IsRadix() argument
518 size_t len = num.size(); in IsRadix()
520 if (radix.find(num[i]) == std::string::npos) { in IsRadix()
527 bool IsNumber(std::string num, int &radix) in IsNumber() argument
529 size_t len = num.size(); in IsNumber()
530 if (len >= 2 && num[0] == '0' && (num[1] == 'x' || num[1] == 'X')) { // 2:hex head length in IsNumber()
532 std::string subStr = num.substr(2); // 2:jump 0x in IsNumber()
537 } else if (len >= 1 && num[ in IsNumber()
551 BinaryConversion(std::string num, int radix) BinaryConversion() argument
630 SplitNum(std::string num, size_t& number) SplitNum() argument
[all...]
/commonlibrary/rust/ylong_runtime/ylong_runtime/src/executor/
H A Dqueue.rs65 fn unwrap(num: u32) -> (u16, u16) { in unwrap()
66 let head_pos = num & u16::MAX as u32; in unwrap()
67 let steal_pos = num >> 16; in unwrap()
477 let num = cmp::min(len / worker_num, limit);
489 for _ in 1..num {

Completed in 11 milliseconds

12