3 releases (breaking)
0.2.0 | Oct 25, 2021 |
---|---|
0.1.0 | Sep 1, 2019 |
0.0.1 | Aug 30, 2019 |
#13 in #connection-manager
7KB
75 lines
r2d2-jfs
r2d2-jfs
JSON file store (jfs
) support for the
r2d2
connection pool.
Example
use std::thread;
use serde::{Serialize, Deserialize};
use r2d2_jfs::JfsConnectionManager;
#[derive(Serialize, Deserialize)]
struct Data { x: i32 }
fn main() {
let manager = JfsConnectionManager::file("file.json").unwrap();
let pool = r2d2::Pool::builder().max_size(5).build(manager).unwrap();
let mut threads = vec![];
for i in 0..10 {
let pool = pool.clone();
threads.push(thread::spawn(move || {
let d = Data { x: i };
let conn = pool.get().unwrap();
conn.save(&d).unwrap();
}));
}
for c in threads {
c.join().unwrap();
}
}
License: Apache-2.0 OR MIT
lib.rs
:
r2d2-jfs
JSON file store (jfs
) support for the
r2d2
connection pool.
Example
use std::thread;
use serde::{Serialize, Deserialize};
use r2d2_jfs::JfsConnectionManager;
#[derive(Serialize, Deserialize)]
struct Data { x: i32 }
let manager = JfsConnectionManager::file("file.json").unwrap();
let pool = r2d2::Pool::builder().max_size(5).build(manager).unwrap();
let mut threads = vec![];
for i in 0..10 {
let pool = pool.clone();
threads.push(thread::spawn(move || {
let d = Data { x: i };
let conn = pool.get().unwrap();
conn.save(&d).unwrap();
}));
}
for c in threads {
c.join().unwrap();
}
Dependencies
~1.2–7.5MB
~40K SLoC