584
585
586
587
588
589
590
591
592
593
594
595
596
597
598
|
Ok(())
}
}
impl DistributedFirstOrderProblem for MMCFProblem {
type Update = Vec<usize>;
fn create_update<U>(
&self,
state: U,
apply: impl FnOnce(Self::Update) -> result::Result<(), Self::Err> + Send + 'static,
) -> result::Result<bool, Self::Err>
where
U: ParallelUpdateState<<Self::Minorant as Minorant>::Primal>,
{
|
|
|
584
585
586
587
588
589
590
591
592
593
594
595
596
597
598
|
Ok(())
}
}
impl DistributedFirstOrderProblem for MMCFProblem {
type Update = Vec<usize>;
fn compute_update<U>(
&self,
state: U,
apply: impl FnOnce(Self::Update) -> result::Result<(), Self::Err> + Send + 'static,
) -> result::Result<bool, Self::Err>
where
U: ParallelUpdateState<<Self::Minorant as Minorant>::Primal>,
{
|