/// Run a function (which installs a pipeline) on the first core in the system, blocking. 
Run a function (which installs a pipeline) on the first core in the system, blocking.
Run a function ( which installs a pipeline ) on the first core in the system blocking .
pub fn run<T>(&mut self, run: Arc<T>, npkts: u64)
    where
        T: Fn(Vec<AlignedSimulateQueue>, &mut StandaloneScheduler) + Send + Sync + 'static,
    {
        let mut sched = StandaloneScheduler::new(npkts);
        let boxed_run = run.clone();
        let ports = self.rx_queues.clone();
        sched.run(Arc::new(move |s| {
            boxed_run(ports.clone(), s)
        }));
        sched.execute_loop();
    }
pub fn run < T > ( & mut self , run : Arc < T > , npkts : u64 ) where T : Fn ( Vec < AlignedSimulateQueue > , & mut StandaloneScheduler ) + Send + Sync + ' static , { let mut sched = StandaloneScheduler :: new ( npkts ) ; let boxed_run = run . clone ( ) ; let ports = self . rx_queues . clone ( ) ; sched . run ( Arc :: new ( move | s | { boxed_run ( ports . clone ( ) , s ) } ) ) ; sched . execute_loop ( ) ; }
Run a function (which installs a pipeline) on the first core in the system, blocking.
Run a function ( which installs a pipeline ) on the first core in the system blocking .
&mut self
run
Arc<T>
npkts
u64