alexxbb

#![allow(unused)]

use std::any::Any;
use std::marker::PhantomData;

struct NumericAttr<T> {
    _m: PhantomData<T>,
}

impl<T> NumericAttr<T> {

alexxbb

// This will spawn 2 producer threads which will try to keep up to NUM_SESSIONS Sessions available for consumers

use flume::Receiver;
use once_cell::sync::OnceCell;

#[derive(Debug, Clone)]
struct Session;

const NUM_SESSIONS: usize = 10;

alexxbb

// Parallel iterator over a contiguous array of i32 values given a raw pointer and size;
use rayon::prelude::*;


fn var_1(ptr: *mut i32, len: usize) {
    // With a stdlib slice
    let data_sl = unsafe { std::slice::from_raw_parts_mut(ptr, len) };
    data_sl.into_par_iter().for_each(|i| *i *= *i);
}