recv.rs

use std::net::Shutdown;
use std::os::unix::net::UnixDatagram;
use std::{sync::Arc, thread};

fn main() -> std::io::Result<()> {
    let sock = Arc::new(UnixDatagram::bind("./my-unix-socket")?);
    let mut buf = vec![0; 10];

    let builder = thread::Builder::new()
        .name("foo".into())
        .stack_size(32 * 1024);
    let sock2 = sock.clone();
    let handler = builder
        .spawn(move || {
            std::thread::sleep(std::time::Duration::from_secs(3));
            sock2.shutdown(Shutdown::Both);
        })
        .unwrap();
    sock.recv(buf.as_mut_slice()).expect("recv function failed");

    Ok(())
}