مكتبة crossbeam في Rust: أدوات البرمجة المتزامنة

مرحبًا بكم في PythonLib! اليوم سنغوص في عالم البرمجة المتزامنة في Rust باستخدام مكتبة crossbeam. تُعد هذه المكتبة من أهم المكتبات الأساسية في النظام البيئي، حيث توفر أدوات قوية وآمنة للتعامل مع تعدد الخيوط، والقنوات، وجمع القمامة القائم على العصور (epoch-based garbage collection)، وهياكل البيانات الخالية من الأقفال.

1. ما هي crossbeam ولماذا تحتاجها؟

Crossbeam هي مجموعة من الأدوات للبرمجة المتزامنة والمتوازية في Rust. صُممت لجعل البرمجة متعددة الخيوط آمنة وفعالة وسهلة. على عكس المكتبة القياسية في Rust التي توفر بدائيات مزامنة أساسية (Mutex, Arc, قنوات mpsc)، تقدم crossbeam بدائل متقدمة وعالية الأداء.

لماذا تحتاج crossbeam؟ أولاً، تحل مشكلة المشاركة الزائفة (false sharing) في ذاكرة التخزين المؤقت للمعالج من خلال هياكل بياناتها. ثانيًا، توفر جمع القمامة القائم على العصور (epoch-based reclamation) لإدارة الذاكرة بأمان في الهياكل الخالية من الأقفال. ثالثًا، قنواتها (channels) متعددة المستهلكين والمنتجين (MPMC)، على عكس القنوات أحادية المستهلك في المكتبة القياسية. أخيرًا، تحتوي crossbeam على العديد من الأدوات المفيدة مثل WaitGroup و Barrier و ShardedLock التي تبسط كتابة الخوارزميات المتزامنة المعقدة.

تُستخدم هذه المكتبة بنشاط في المشاريع الصناعية مثل Tokio و Rayon و TiKV. إذا كنت تكتب خوادم عالية التحميل، أو قواعد بيانات، أو أي أنظمة أخرى تتطلب أقصى أداء على المعالجات متعددة النوى، فستكون crossbeam مساعدك الذي لا غنى عنه.

2. التثبيت

Crossbeam هي مكتبة للغة Rust، لذا يتم تثبيتها عبر مدير الحزم Cargo. أضف السطر التالي إلى ملف Cargo.toml الخاص بك:

[dependencies]
crossbeam = "0.8"

ثم نفذ الأمر:

cargo build

إذا كنت تحتاج فقط إلى مكونات معينة (مثل القنوات فقط أو جامع القمامة القائم على العصور فقط)، يمكنك استخدام الحزم الفرعية:

[dependencies]
crossbeam-channel = "0.5"
crossbeam-epoch = "0.9"
crossbeam-utils = "0.8"
crossbeam-deque = "0.8"
crossbeam-queue = "0.3"

ولكن في معظم الحالات، يكفي إضافة crossbeam = "0.8".

3. بداية سريعة — مثال عملي بسيط

لنبدأ بمثال بسيط: سننشئ خيطين يتبادلان البيانات عبر قناة متعددة المستهلكين من crossbeam.

use crossbeam::channel;
use std::thread;

fn main() {
    // إنشاء قناة بمخزن مؤقت غير محدود
    let (sender, receiver) = channel::unbounded();

    // خيط المرسل
    thread::spawn(move || {
        sender.send("مرحبًا من crossbeam!").unwrap();
        println!("تم إرسال الرسالة");
    });

    // خيط المستقبل
    thread::spawn(move || {
        let msg = receiver.recv().unwrap();
        println!("تم الاستلام: {}", msg);
    });

    // إعطاء الخيوط وقتًا للتنفيذ
    thread::sleep(std::time::Duration::from_millis(100));
}

يوضح هذا المثال الآلية الأساسية: channel::unbounded() تنشئ زوجًا (مرسل، مستقبل). يرسل المرسل سلسلة نصية، ويستقبلها المستقبل. على عكس std::sync::mpsc، هنا يمكن أن يكون هناك عدة مرسلين وعدة مستقبلين.

4. أهم الدوال/الوظائف/الفئات

دعنا نستعرض 8 مكونات رئيسية لمكتبة crossbeam مع أمثلة مفصلة.

4.1. channel::unbounded()

التوقيع: p