{"id":36755,"date":"2025-05-12T07:36:07","date_gmt":"2025-05-11T23:36:07","guid":{"rendered":"https:\/\/www.wsisp.com\/helps\/36755.html"},"modified":"2025-05-12T07:36:07","modified_gmt":"2025-05-11T23:36:07","slug":"%e7%94%a8-rust-%e6%90%ad%e5%bb%ba%e4%b8%80%e4%b8%aa%e4%bc%98%e9%9b%85%e7%9a%84%e5%a4%9a%e7%ba%bf%e7%a8%8b%e6%9c%8d%e5%8a%a1%e5%99%a8%ef%bc%9a%e4%bb%8e%e9%9b%b6%e5%bc%80%e5%a7%8b%e7%9a%84%e8%af%a6","status":"publish","type":"post","link":"https:\/\/www.wsisp.com\/helps\/36755.html","title":{"rendered":"\u7528 Rust \u642d\u5efa\u4e00\u4e2a\u4f18\u96c5\u7684\u591a\u7ebf\u7a0b\u670d\u52a1\u5668\uff1a\u4ece\u96f6\u5f00\u59cb\u7684\u8be6\u7ec6\u6307\u5357"},"content":{"rendered":"

\u563f，\u5c0f\u4f19\u4f34\u4eec！\u4eca\u5929\u54b1\u4eec\u6765\u804a\u804a\u600e\u4e48\u7528 Rust \u642d\u5efa\u4e00\u4e2a\u725b\u6c14\u54c4\u54c4\u7684\u591a\u7ebf\u7a0b\u670d\u52a1\u5668，\u8fd8\u80fd\u5728\u9700\u8981\u7684\u65f6\u5019\u4f18\u96c5\u5730\u5173\u673a\u3002\u4e3a\u5565\u8981\u7528 Rust \u5462？\u56e0\u4e3a Rust \u662f\u4e2a\u8d85\u7ea7\u9760\u8c31\u7684\u8bed\u8a00，\u5b83\u80fd\u4fdd\u8bc1\u5185\u5b58\u5b89\u5168，\u5199\u5e76\u53d1\u4ee3\u7801\u7684\u65f6\u5019\u4e0d\u7528\u62c5\u5fc3\u90a3\u4e9b\u8ba9\u4eba\u5934\u75bc\u7684\u5e76\u53d1\u95ee\u9898，\u6bd4\u5982\u6570\u636e\u7ade\u4e89\u548c\u6b7b\u9501\u3002\u800c\u4e14，Rust \u7684\u6807\u51c6\u5e93\u63d0\u4f9b\u4e86\u8d85\u597d\u7528\u7684\u7f51\u7edc\u7f16\u7a0b\u5de5\u5177，\u80fd\u5e2e\u54b1\u4eec\u8f7b\u677e\u641e\u5b9a\u7f51\u7edc\u670d\u52a1\u3002<\/p>\n

\u4e00\u3001\u5148\u641e\u4e2a\u7ebf\u7a0b\u6c60<\/h3>\n

\u7ebf\u7a0b\u6c60\u8fd9\u4e1c\u897f，\u5c31\u50cf\u662f\u4e2a\u201c\u4efb\u52a1\u5206\u914d\u4e2d\u5fc3\u201d，\u80fd\u5e2e\u54b1\u4eec\u628a\u4efb\u52a1\u5408\u7406\u5206\u914d\u7ed9\u7ebf\u7a0b，\u907f\u514d\u7ebf\u7a0b\u9891\u7e41\u521b\u5efa\u548c\u9500\u6bc1，\u8282\u7701\u8d44\u6e90，\u63d0\u5347\u6027\u80fd\u3002\u60f3\u8c61\u4e00\u4e0b，\u5982\u679c\u4f60\u6bcf\u6b21\u6709\u4efb\u52a1\u5c31\u65b0\u5efa\u4e00\u4e2a\u7ebf\u7a0b，\u90a3\u7ebf\u7a0b\u521b\u5efa\u548c\u9500\u6bc1\u7684\u5f00\u9500\u4f1a\u8ba9\u4f60\u7684\u7a0b\u5e8f\u6162\u5f97\u50cf\u8717\u725b\u3002\u6709\u4e86\u7ebf\u7a0b\u6c60，\u8fd9\u4e9b\u7ebf\u7a0b\u5c31\u50cf\u662f\u4e00\u7fa4\u968f\u65f6\u5f85\u547d\u7684\u5de5\u4eba，\u4efb\u52a1\u4e00\u6765，\u7acb\u9a6c\u5c31\u80fd\u5f00\u5de5\u3002<\/p>\n

\u4e0b\u9762\u5c31\u662f\u4e2a\u7b80\u5355\u7684\u7ebf\u7a0b\u6c60\u4ee3\u7801，\u7785\u7785：<\/p>\n

use<\/span> std::<\/span>sync::<\/span><\/span>{<\/span>mpsc,<\/span> Arc<\/span>,<\/span> Mutex<\/span>}<\/span>;<\/span>
\nuse<\/span> std::<\/span><\/span>thread;<\/span><\/p>\n

pub<\/span> struct<\/span> ThreadPool<\/span> {<\/span>
\n workers:<\/span> Vec<\/span><<\/span>Worker<\/span>><\/span>,<\/span>
\n sender:<\/span> Option<\/span><<\/span>mpsc::<\/span><\/span>Sender<\/span><<\/span>Job<\/span>>><\/span>,<\/span>
\n}<\/span><\/p>\n

type<\/span> Job<\/span> =<\/span> Box<\/span><<\/span>dyn<\/span> FnOnce<\/span>(<\/span>)<\/span> +<\/span> Send<\/span> +<\/span> 'static<\/span>><\/span>;<\/span><\/p>\n

impl<\/span> ThreadPool<\/span> {<\/span>
\n pub<\/span> fn<\/span> new<\/span>(<\/span>size:<\/span> usize<\/span>)<\/span> -><\/span> ThreadPool<\/span> {<\/span>
\n assert!<\/span>(<\/span>size ><\/span> 0<\/span>)<\/span>;<\/span><\/p>\n

let<\/span> (<\/span>sender,<\/span> receiver)<\/span> =<\/span> mpsc::<\/span><\/span>channel<\/span>(<\/span>)<\/span>;<\/span><\/p>\n

let<\/span> receiver =<\/span> Arc<\/span>::<\/span>new<\/span>(<\/span>Mutex<\/span>::<\/span>new<\/span>(<\/span>receiver)<\/span>)<\/span>;<\/span><\/p>\n

let<\/span> mut<\/span> workers =<\/span> Vec<\/span>::<\/span>with_capacity<\/span>(<\/span>size)<\/span>;<\/span><\/p>\n

for<\/span> id in<\/span> 0<\/span>..<\/span>size {<\/span>
\n workers.<\/span>push<\/span>(<\/span>Worker<\/span>::<\/span>new<\/span>(<\/span>id,<\/span> Arc<\/span>::<\/span>clone<\/span>(<\/span>&<\/span>receiver)<\/span>)<\/span>)<\/span>;<\/span>
\n }<\/span><\/p>\n

ThreadPool<\/span> {<\/span>
\n workers,<\/span>
\n sender:<\/span> Some<\/span>(<\/span>sender)<\/span>,<\/span>
\n }<\/span>
\n }<\/span><\/p>\n

pub<\/span> fn<\/span> execute<\/span><<\/span>F<\/span>><\/span>(<\/span>&<\/span>self<\/span>,<\/span> f:<\/span> F<\/span>)<\/span>
\n where<\/span>
\n F<\/span>:<\/span> FnOnce<\/span>(<\/span>)<\/span> +<\/span> Send<\/span> +<\/span> 'static<\/span>,<\/span>
\n {<\/span>
\n let<\/span> job =<\/span> Box<\/span>::<\/span>new<\/span>(<\/span>f)<\/span>;<\/span><\/p>\n

self<\/span>.<\/span>sender.<\/span>as_ref<\/span>(<\/span>)<\/span>.<\/span>unwrap<\/span>(<\/span>)<\/span>.<\/span>send<\/span>(<\/span>job)<\/span>.<\/span>unwrap<\/span>(<\/span>)<\/span>;<\/span>
\n }<\/span>
\n}<\/span><\/p>\n

impl<\/span> Drop<\/span> for<\/span> ThreadPool<\/span> {<\/span>
\n fn<\/span> drop<\/span>(<\/span>&<\/span>mut<\/span> self<\/span>)<\/span> {<\/span>
\n drop<\/span>(<\/span>self<\/span>.<\/span>sender.<\/span>take<\/span>(<\/span>)<\/span>)<\/span>;<\/span><\/p>\n

for<\/span> worker in<\/span> &<\/span>mut<\/span> self<\/span>.<\/span>workers {<\/span>
\n println!<\/span>(<\/span>"Shutting down worker {}"<\/span>,<\/span> worker.<\/span>id)<\/span>;<\/span><\/p>\n

if<\/span> let<\/span> Some<\/span>(<\/span>thread)<\/span> =<\/span> worker.<\/span>thread.<\/span>take<\/span>(<\/span>)<\/span> {<\/span>
\n thread.<\/span>join<\/span>(<\/span>)<\/span>.<\/span>unwrap<\/span>(<\/span>)<\/span>;<\/span>
\n }<\/span>
\n }<\/span>
\n }<\/span>
\n}<\/span><\/p>\n

struct<\/span> Worker<\/span> {<\/span>
\n id:<\/span> usize<\/span>,<\/span>
\n thread:<\/span> Option<\/span><<\/span>thread::<\/span><\/span>JoinHandle<\/span><<\/span>(<\/span>)<\/span>>><\/span>,<\/span>
\n}<\/span><\/p>\n

impl<\/span> Worker<\/span> {<\/span>
\n fn<\/span> new<\/span>(<\/span>id:<\/span> usize<\/span>,<\/span> receiver:<\/span> Arc<\/span><<\/span>Mutex<\/span><<\/span>mpsc::<\/span><\/span>Receiver<\/span><<\/span>Job<\/span>>><\/span>><\/span>)<\/span> -><\/span> Worker<\/span> {<\/span>
\n let<\/span> thread =<\/span> thread::<\/span><\/span>spawn<\/span>(<\/span>move<\/span> |<\/span>|<\/span><\/span> loop<\/span> {<\/span>
\n let<\/span> message =<\/span> receiver.<\/span>lock<\/span>(<\/span>)<\/span>.<\/span>unwrap<\/span>(<\/span>)<\/span>.<\/span>recv<\/span>(<\/span>)<\/span>;<\/span><\/p>\n

match<\/span> message {<\/span>
\n Ok<\/span>(<\/span>job)<\/span> =><\/span> {<\/span>
\n println!<\/span>(<\/span>"Worker {id} got a job; executing."<\/span>)<\/span>;<\/span>
\n job<\/span>(<\/span>)<\/span>;<\/span>
\n }<\/span>
\n Err<\/span>(<\/span>_)<\/span> =><\/span> {<\/span>
\n println!<\/span>(<\/span>"Worker {id} disconnected; shutting down."<\/span>)<\/span>;<\/span>
\n break<\/span>;<\/span>
\n }<\/span>
\n }<\/span>
\n }<\/span>)<\/span>;<\/span><\/p>\n

Worker<\/span> {<\/span>
\n id,<\/span>
\n thread:<\/span> Some<\/span>(<\/span>thread)<\/span>,<\/span>
\n }<\/span>
\n }<\/span>
\n}<\/span><\/p>\n

\u91cd\u70b9\u6765\u4e86<\/h4>\n