Home
last modified time | relevance | path

Searched refs:with_capacity (Results 1 - 25 of 36) sorted by relevance

12

/commonlibrary/rust/ylong_runtime/ylong_runtime/tests/
H A Dspawn.rs33 let mut handles = Vec::with_capacity(num); in sdv_one_core_test()
50 let mut handles = Vec::with_capacity(num); in sdv_two_core_test()
67 let mut handles = Vec::with_capacity(num); in sdv_three_core_test()
84 let mut handles = Vec::with_capacity(num); in sdv_four_core_test()
101 let mut handles = Vec::with_capacity(num); in sdv_eight_core_test()
118 let mut handles = Vec::with_capacity(num); in sdv_max_core_test()
135 let mut handles = Vec::with_capacity(num); in sdv_multi_future_in_async()
153 let mut handles = Vec::with_capacity(num); in sdv_multi_async_in_async()
H A Dspawn_blocking.rs27 let mut handles = Vec::with_capacity(num); in ffrt_spawn_blocking_test()
40 let mut handles = Vec::with_capacity(num); in ffrt_spawn_blocking_test()
68 let mut handles = Vec::with_capacity(num); in test_spawn()
80 let mut handles = Vec::with_capacity(num); in test_spawn()
93 let mut handles = Vec::with_capacity(num); in test_spawn()
H A Dsingleton_runtime.rs48 let mut handles = Vec::with_capacity(SPAWN_NUM); in sdv_concurrently_runtime_spawn_async_in_async_task()
76 let mut handles = Vec::with_capacity(SPAWN_NUM); in sdv_concurrently_spawn_async_in_async_task()
104 let mut handles = Vec::with_capacity(SPAWN_NUM); in sdv_concurrently_task_builder_spawn_async_in_async_task()
H A Dasync_buf_write.rs50 let mut buf_writer = AsyncBufWriter::with_capacity(10, tcp); in sdv_buf_writer_write()
92 let mut buf_writer = AsyncBufWriter::with_capacity(3, tcp); in sdv_buf_writer_write_vectored()
188 let mut buf_writer = AsyncBufWriter::with_capacity(30, tcp); in sdv_buf_writer_write_vectored_2()
/commonlibrary/rust/ylong_runtime/ylong_runtime/examples/
H A Dylong_tokio_schedule.rs35 let mut handlers = Vec::with_capacity(num); in ylong_schedule_task()
52 let mut handlers = Vec::with_capacity(num); in tokio_schedule_task()
65 let mut handlers = Vec::with_capacity(num); in ylong_schedule_fibbo_task()
83 let mut handlers = Vec::with_capacity(num); in tokio_schedule_fibbo_task()
/commonlibrary/rust/ylong_runtime/ylong_runtime/benches/
H A Dylong_tokio_rwlock.rs54 let mut handlers = Vec::with_capacity(6); in tokio_rwlock_read()
79 let mut handlers = Vec::with_capacity(6); in ylong_rwlock_read()
103 let mut handlers = Vec::with_capacity(6); in tokio_rwlock_write()
128 let mut handlers = Vec::with_capacity(6); in ylong_rwlock_write()
154 let mut handlers = Vec::with_capacity(12); in tokio_rwlock_write_read()
186 let mut handlers = Vec::with_capacity(12); in ylong_rwlock_write_read()
H A Dylong_tokio_spawn_blocking.rs30 let mut handlers = Vec::with_capacity($num);
51 let mut handlers = Vec::with_capacity($num);
H A Dylong_tokio_schedule.rs27 let mut handlers = Vec::with_capacity($num);
49 let mut handlers = Vec::with_capacity($num);
H A Dylong_tokio_mutex.rs37 let mut handlers = Vec::with_capacity($num);
67 let mut handlers = Vec::with_capacity($num);
H A Dylong_tokio_signal.rs35 let mut handlers = Vec::with_capacity($num);
84 let mut handlers = Vec::with_capacity($num);
H A Dsync_benchmarks.rs37 let handlers: Vec<[u8; TASK_NUM]> = black_box(Vec::with_capacity(TASK_NUM)); in single_thread_run_1000_fibbo()
/commonlibrary/rust/ylong_runtime/ylong_runtime/src/fs/
H A Dfile_buf.rs26 pub(crate) fn with_capacity(n: usize) -> FileBuf {
28 buf: Vec::with_capacity(n),
/commonlibrary/rust/ylong_runtime/ylong_runtime/benches/bin/
H A Dylong_tokio_spawn.rs49 let mut handles = Vec::with_capacity(1000); in ylong_spawn()
66 let mut handles = Vec::with_capacity(1000); in tokio_spawn()
84 let mut handles = Vec::with_capacity(1000); in std_spawn()
/commonlibrary/rust/ylong_runtime/ylong_runtime/src/io/buffered/
H A Dasync_buf_writer.rs56 AsyncBufWriter::with_capacity(DEFAULT_BUF_SIZE, inner) in new()
69 /// let reader = AsyncBufWriter::with_capacity(1000, f);
72 pub fn with_capacity(cap: usize, inner: W) -> AsyncBufWriter<W> { in with_capacity() functions
75 buf: Vec::with_capacity(cap), in with_capacity()
H A Dasync_buf_reader.rs58 AsyncBufReader::with_capacity(DEFAULT_BUF_SIZE, inner) in new()
71 /// let reader = AsyncBufReader::with_capacity(1000, f);
74 pub fn with_capacity(capacity: usize, inner: R) -> AsyncBufReader<R> { in with_capacity() functions
155 /// let reader = AsyncBufReader::with_capacity(10, f);
/commonlibrary/rust/ylong_runtime/ylong_io/src/sys/unix/
H A Dkqueue.rs77 let mut events = Vec::with_capacity(2); in register()
95 let mut events = Vec::with_capacity(2); in reregister()
224 pub fn with_capacity(capacity: usize) -> Self { in with_capacity() functions
225 Events(Vec::with_capacity(capacity)) in with_capacity()
/commonlibrary/rust/ylong_http/ylong_http_client/src/async_impl/
H A Dpool.rs103 h2_conn: Arc::new(crate::runtime::AsyncMutex::new(Vec::with_capacity(1))), in new()
106 h3_conn: Arc::new(crate::runtime::AsyncMutex::new(Vec::with_capacity(1))), in new()
/commonlibrary/rust/ylong_runtime/ylong_io/src/sys/windows/
H A Devents.rs65 pub fn with_capacity(cap: usize) -> Events { in with_capacity() functions
68 events: Vec::with_capacity(cap), in with_capacity()
/commonlibrary/rust/ylong_runtime/ylong_runtime/src/util/
H A Dslots.rs81 Slots::with_capacity(0) in new()
224 /// let slots: Slots<i32> = Slots::with_capacity(0);
226 pub fn with_capacity(capacity: usize) -> Slots<T> { in with_capacity() functions
228 entries: Vec::with_capacity(capacity), in with_capacity()
/commonlibrary/rust/ylong_runtime/ylong_io/examples/
H A Dylong_io_tcp_server.rs34 let mut events = Events::with_capacity(128); in main()
/commonlibrary/rust/ylong_runtime/ylong_runtime/src/executor/
H A Dsleeper.rs28 idle_list: Mutex::new(Vec::with_capacity(num_workers)), in new()
H A Dqueue.rs178 let mut buffer = Vec::with_capacity(cap as usize); in new()
314 let mut tmp_buf = Vec::with_capacity(count);
/commonlibrary/rust/ylong_runtime/ylong_runtime/src/io/
H A Dstdio.rs41 inner: Vec::with_capacity(0), in new()
/commonlibrary/rust/ylong_http/ylong_http/src/request/uri/
H A Dpercent_encoding.rs247 url: String::with_capacity(size),
/commonlibrary/rust/ylong_http/ylong_http/src/h3/qpack/format/
H A Dencoder.rs796 let mut dst = Vec::with_capacity(src.len()); in new()

Completed in 10 milliseconds

12