Skip to content

Commit 97c58d2

Browse files
actions-useractions-user
committed
Update consolidated snippets
1 parent b8af7f6 commit 97c58d2

File tree

1 file changed

+85
-0
lines changed

1 file changed

+85
-0
lines changed

‎public/consolidated/rust.json

+85
Original file line numberDiff line numberDiff line change
@@ -1,4 +1,40 @@
11
[
2+
{
3+
"categoryName": "Advanced Patterns",
4+
"snippets": [
5+
{
6+
"title": "Type-Safe Builder Pattern",
7+
"description": "Implements a compile-time type-safe builder pattern using phantom types",
8+
"author": "pyyupsk",
9+
"tags": [
10+
"rust",
11+
"design-pattern",
12+
"builder",
13+
"type-safe"
14+
],
15+
"contributors": [],
16+
"code": "use std::marker::PhantomData;\n\n#[derive(Debug)]\npub struct Builder<Name, Age> {\n name: Option<String>,\n age: Option<u32>,\n _name: PhantomData<Name>,\n _age: PhantomData<Age>,\n}\n\npub struct Missing;\npub struct Set;\n\n#[derive(Debug)]\npub struct Person {\n name: String,\n age: u32,\n}\n\nimpl Default for Builder<Missing, Missing> {\n fn default() -> Self {\n Self {\n name: None,\n age: None,\n _name: PhantomData,\n _age: PhantomData,\n }\n }\n}\n\nimpl<Age> Builder<Missing, Age> {\n pub fn name(self, name: impl Into<String>) -> Builder<Set, Age> {\n Builder {\n name: Some(name.into()),\n age: self.age,\n _name: PhantomData,\n _age: PhantomData,\n }\n }\n}\n\nimpl<Name> Builder<Name, Missing> {\n pub fn age(self, age: u32) -> Builder<Name, Set> {\n Builder {\n name: self.name,\n age: Some(age),\n _name: PhantomData,\n _age: PhantomData,\n }\n }\n}\n\nimpl Builder<Set, Set> {\n pub fn build(self) -> Person {\n Person {\n name: self.name.unwrap(),\n age: self.age.unwrap(),\n }\n }\n}\n\n// Usage:\nlet person = Builder::default()\n .name(\"John\")\n .age(30)\n .build();\n"
17+
}
18+
]
19+
},
20+
{
21+
"categoryName": "Async Programming",
22+
"snippets": [
23+
{
24+
"title": "Async Rate Limiter",
25+
"description": "Implementation of a token bucket rate limiter for async operations",
26+
"author": "pyyupsk",
27+
"tags": [
28+
"rust",
29+
"async",
30+
"rate-limiter",
31+
"tokio"
32+
],
33+
"contributors": [],
34+
"code": "use std::sync::Arc;\nuse tokio::sync::Semaphore;\nuse tokio::time::{interval, Duration};\n\npub struct RateLimiter {\n semaphore: Arc<Semaphore>,\n}\n\nimpl RateLimiter {\n pub fn new(rate: u32, interval: Duration) -> Self {\n let semaphore = Arc::new(Semaphore::new(rate as usize));\n let sem_clone = semaphore.clone();\n\n tokio::spawn(async move {\n let mut ticker = interval(interval);\n loop {\n ticker.tick().await;\n sem_clone.add_permits(rate as usize);\n }\n });\n\n RateLimiter { semaphore }\n }\n\n pub async fn acquire(&self) -> RateLimit {\n let permit = self.semaphore.acquire().await.unwrap();\n RateLimit { _permit: permit }\n }\n}\n\npub struct RateLimit<'a> {\n _permit: tokio::sync::SemaphorePermit<'a>,\n}\n\n// Usage:\nasync fn example() {\n let limiter = RateLimiter::new(10, Duration::from_secs(1));\n\n for i in 0..20 {\n let _permit = limiter.acquire().await;\n println!(\"Executing task {}\", i);\n }\n}\n"
35+
}
36+
]
37+
},
238
{
339
"categoryName": "Basics",
440
"snippets": [
@@ -17,6 +53,24 @@
1753
}
1854
]
1955
},
56+
{
57+
"categoryName": "Concurrency",
58+
"snippets": [
59+
{
60+
"title": "Thread Pool Implementation",
61+
"description": "A simple thread pool implementation for parallel task execution",
62+
"author": "pyyupsk",
63+
"tags": [
64+
"rust",
65+
"concurrency",
66+
"thread-pool",
67+
"parallel"
68+
],
69+
"contributors": [],
70+
"code": "use std::sync::{mpsc, Arc, Mutex};\nuse std::thread;\n\ntype Job = Box<dyn FnOnce() + Send + 'static>;\n\npub struct ThreadPool {\n workers: Vec<Worker>,\n sender: Option<mpsc::Sender<Job>>,\n}\n\nstruct Worker {\n id: usize,\n thread: Option<thread::JoinHandle<()>>,\n}\n\nimpl ThreadPool {\n pub fn new(size: usize) -> ThreadPool {\n assert!(size > 0);\n\n let (sender, receiver) = mpsc::channel();\n let receiver = Arc::new(Mutex::new(receiver));\n let mut workers = Vec::with_capacity(size);\n\n for id in 0..size {\n workers.push(Worker::new(id, Arc::clone(&receiver)));\n }\n\n ThreadPool {\n workers,\n sender: Some(sender),\n }\n }\n\n pub fn execute<F>(&self, f: F)\n where\n F: FnOnce() + Send + 'static,\n {\n let job = Box::new(f);\n self.sender.as_ref().unwrap().send(job).unwrap();\n }\n}\n\nimpl Worker {\n fn new(id: usize, receiver: Arc<Mutex<mpsc::Receiver<Job>>>) -> Worker {\n let thread = thread::spawn(move || loop {\n let message = receiver.lock().unwrap().recv();\n\n match message {\n Ok(job) => {\n println!(\"Worker {id} got a job; executing.\");\n job();\n }\n Err(_) => {\n println!(\"Worker {id} disconnected; shutting down.\");\n break;\n }\n }\n });\n\n Worker {\n id,\n thread: Some(thread),\n }\n }\n}\n\nimpl Drop for ThreadPool {\n fn drop(&mut self) {\n drop(self.sender.take());\n\n for worker in &mut self.workers {\n if let Some(thread) = worker.thread.take() {\n thread.join().unwrap();\n }\n }\n }\n}\n"
71+
}
72+
]
73+
},
2074
{
2175
"categoryName": "File Handling",
2276
"snippets": [
@@ -47,6 +101,24 @@
47101
}
48102
]
49103
},
104+
{
105+
"categoryName": "Memory Management",
106+
"snippets": [
107+
{
108+
"title": "Custom Smart Pointer",
109+
"description": "Implementation of a custom reference-counted smart pointer with interior mutability",
110+
"author": "pyyupsk",
111+
"tags": [
112+
"rust",
113+
"smart-pointer",
114+
"memory-management",
115+
"unsafe"
116+
],
117+
"contributors": [],
118+
"code": "use std::cell::UnsafeCell;\nuse std::ops::{Deref, DerefMut};\nuse std::sync::atomic::{AtomicUsize, Ordering};\nuse std::sync::Arc;\n\npub struct Interior<T> {\n ref_count: AtomicUsize,\n data: UnsafeCell<T>,\n}\n\npub struct SmartPtr<T> {\n ptr: Arc<Interior<T>>,\n}\n\nimpl<T> SmartPtr<T> {\n pub fn new(data: T) -> Self {\n SmartPtr {\n ptr: Arc::new(Interior {\n ref_count: AtomicUsize::new(1),\n data: UnsafeCell::new(data),\n }),\n }\n }\n\n pub fn get_ref_count(&self) -> usize {\n self.ptr.ref_count.load(Ordering::SeqCst)\n }\n}\n\nimpl<T> Clone for SmartPtr<T> {\n fn clone(&self) -> Self {\n self.ptr.ref_count.fetch_add(1, Ordering::SeqCst);\n SmartPtr {\n ptr: Arc::clone(&self.ptr),\n }\n }\n}\n\nimpl<T> Drop for SmartPtr<T> {\n fn drop(&mut self) {\n if self.ptr.ref_count.fetch_sub(1, Ordering::SeqCst) == 1 {\n // Last reference is being dropped\n unsafe {\n drop(Box::from_raw(self.ptr.data.get()));\n }\n }\n }\n}\n\nimpl<T> Deref for SmartPtr<T> {\n type Target = T;\n\n fn deref(&self) -> &Self::Target {\n unsafe { &*self.ptr.data.get() }\n }\n}\n\nimpl<T> DerefMut for SmartPtr<T> {\n fn deref_mut(&mut self) -> &mut Self::Target {\n unsafe { &mut *self.ptr.data.get() }\n }\n}\n\n// Usage:\nlet ptr = SmartPtr::new(42);\nlet cloned = ptr.clone();\nassert_eq!(ptr.get_ref_count(), 2);\nassert_eq!(*ptr, 42);\n"
119+
}
120+
]
121+
},
50122
{
51123
"categoryName": "String Manipulation",
52124
"snippets": [
@@ -62,6 +134,19 @@
62134
],
63135
"contributors": [],
64136
"code": "fn capitalized(str: &str) -> String {\n let mut chars = str.chars();\n match chars.next() {\n None => String::new(),\n Some(f) => f.to_uppercase().chain(chars).collect(),\n }\n}\n\n// Usage:\nassert_eq!(capitalized(\"lower_case\"), \"Lower_case\")\n"
137+
},
138+
{
139+
"title": "String to Vec<char>",
140+
"description": "Convert a String into a vector of characters",
141+
"author": "pyyupsk",
142+
"tags": [
143+
"rust",
144+
"string",
145+
"vector",
146+
"chars"
147+
],
148+
"contributors": [],
149+
"code": "fn string_to_chars(s: &str) -> Vec<char> {\n s.chars().collect()\n}\n\n// Usage:\nlet chars = string_to_chars(\"Hello\"); // ['H', 'e', 'l', 'l', 'o']\n"
65150
}
66151
]
67152
}

0 commit comments

Comments
 (0)