Rust

// Güvenli Eşzamanlılık ve Hata Yönetimi
use std::sync::Arc;
use tokio::sync::Mutex;

#[derive(Debug, Clone)]
pub struct ClusterNode {
    pub id: u64,
    pub address: String,
    pub active_connections: usize,
}

impl ClusterNode {
    pub fn new(id: u64, address: impl Into<String>) -> Self {
        Self {
            id,
            address: address.into(),
            active_connections: 0,
        }
    }
}

#[tokio::main]
async fn main() -> Result<(), Box<dyn std::error::Error>> {
    let node = Arc::new(Mutex::new(ClusterNode::new(1, "10.0.0.42:9000")));
    
    let node_clone = Arc::clone(&node);
    tokio::spawn(async move {
        let mut locked = node_clone.lock().await;
        locked.active_connections += 1;
        println!("[Node-1] Aktif Bağlantı: {}", locked.active_connections);
    }).await?;

    Ok(())
}