use std::fmt::Debug;
use std::marker::PhantomData;
use solverforge_core::domain::PlanningSolution;
use solverforge_scoring::Director;
use crate::heuristic::r#move::{ListChangeMove, ListMoveImpl};
use super::entity::EntitySelector;
use super::move_selector::MoveSelector;
pub trait CrossEntityDistanceMeter<S>: Send + Sync {
fn distance(
&self,
solution: &S,
src_entity: usize,
src_pos: usize,
dst_entity: usize,
dst_pos: usize,
) -> f64;
}
#[derive(Debug, Clone, Copy)]
pub struct DefaultCrossEntityDistanceMeter;
impl Default for DefaultCrossEntityDistanceMeter {
fn default() -> Self {
Self
}
}
impl<S> CrossEntityDistanceMeter<S> for DefaultCrossEntityDistanceMeter {
fn distance(
&self,
_solution: &S,
src_entity: usize,
src_pos: usize,
dst_entity: usize,
dst_pos: usize,
) -> f64 {
if src_entity == dst_entity {
(src_pos as f64 - dst_pos as f64).abs()
} else {
f64::INFINITY
}
}
}
pub struct NearbyListChangeMoveSelector<S, V, D, ES> {
entity_selector: ES,
distance_meter: D,
max_nearby: usize,
list_len: fn(&S, usize) -> usize,
list_remove: fn(&mut S, usize, usize) -> Option<V>,
list_insert: fn(&mut S, usize, usize, V),
variable_name: &'static str,
descriptor_index: usize,
_phantom: PhantomData<(fn() -> S, fn() -> V)>,
}
impl<S, V: Debug, D, ES: Debug> Debug for NearbyListChangeMoveSelector<S, V, D, ES> {
fn fmt(&self, f: &mut std::fmt::Formatter<'_>) -> std::fmt::Result {
f.debug_struct("NearbyListChangeMoveSelector")
.field("entity_selector", &self.entity_selector)
.field("distance_meter", &"<distance_meter>")
.field("max_nearby", &self.max_nearby)
.field("variable_name", &self.variable_name)
.field("descriptor_index", &self.descriptor_index)
.finish()
}
}
impl<S, V, D, ES> NearbyListChangeMoveSelector<S, V, D, ES> {
#[allow(clippy::too_many_arguments)]
pub fn new(
entity_selector: ES,
distance_meter: D,
max_nearby: usize,
list_len: fn(&S, usize) -> usize,
list_remove: fn(&mut S, usize, usize) -> Option<V>,
list_insert: fn(&mut S, usize, usize, V),
variable_name: &'static str,
descriptor_index: usize,
) -> Self {
Self {
entity_selector,
distance_meter,
max_nearby,
list_len,
list_remove,
list_insert,
variable_name,
descriptor_index,
_phantom: PhantomData,
}
}
}
impl<S, V, D, ES> MoveSelector<S, ListChangeMove<S, V>>
for NearbyListChangeMoveSelector<S, V, D, ES>
where
S: PlanningSolution,
V: Clone + PartialEq + Send + Sync + Debug + 'static,
D: CrossEntityDistanceMeter<S>,
ES: EntitySelector<S>,
{
fn iter_moves<'a, SD: Director<S>>(
&'a self,
score_director: &'a SD,
) -> impl Iterator<Item = ListChangeMove<S, V>> + 'a {
let solution = score_director.working_solution();
let list_len = self.list_len;
let list_remove = self.list_remove;
let list_insert = self.list_insert;
let variable_name = self.variable_name;
let descriptor_index = self.descriptor_index;
let max_nearby = self.max_nearby;
let entities: Vec<usize> = self
.entity_selector
.iter(score_director)
.map(|r| r.entity_index)
.collect();
let route_lens: Vec<usize> = entities.iter().map(|&e| list_len(solution, e)).collect();
let mut moves = Vec::new();
for (src_idx, &src_entity) in entities.iter().enumerate() {
let src_len = route_lens[src_idx];
if src_len == 0 {
continue;
}
for src_pos in 0..src_len {
let mut candidates: Vec<(usize, usize, f64)> = Vec::new();
for dst_pos in 0..src_len {
if dst_pos == src_pos || dst_pos == src_pos + 1 {
continue; }
let dist = self
.distance_meter
.distance(solution, src_entity, src_pos, src_entity, dst_pos);
if dist.is_finite() {
candidates.push((src_entity, dst_pos, dist));
}
}
for (dst_idx, &dst_entity) in entities.iter().enumerate() {
if dst_idx == src_idx {
continue;
}
let dst_len = route_lens[dst_idx];
for dst_pos in 0..=dst_len {
let ref_pos = dst_pos.min(dst_len.saturating_sub(1));
let dist = self
.distance_meter
.distance(solution, src_entity, src_pos, dst_entity, ref_pos);
if dist.is_finite() {
candidates.push((dst_entity, dst_pos, dist));
}
}
}
candidates
.sort_by(|a, b| a.2.partial_cmp(&b.2).unwrap_or(std::cmp::Ordering::Equal));
candidates.truncate(max_nearby);
for (dst_entity, dst_pos, _) in candidates {
moves.push(ListChangeMove::new(
src_entity,
src_pos,
dst_entity,
dst_pos,
list_len,
list_remove,
list_insert,
variable_name,
descriptor_index,
));
}
}
}
moves.into_iter()
}
fn size<SD: Director<S>>(&self, score_director: &SD) -> usize {
let solution = score_director.working_solution();
let list_len = self.list_len;
let total_elements: usize = self
.entity_selector
.iter(score_director)
.map(|r| list_len(solution, r.entity_index))
.sum();
total_elements * self.max_nearby
}
}
pub struct ListMoveNearbyListChangeSelector<S, V, D, ES> {
inner: NearbyListChangeMoveSelector<S, V, D, ES>,
}
impl<S, V: Debug, D, ES: Debug> Debug for ListMoveNearbyListChangeSelector<S, V, D, ES> {
fn fmt(&self, f: &mut std::fmt::Formatter<'_>) -> std::fmt::Result {
f.debug_struct("ListMoveNearbyListChangeSelector")
.field("inner", &self.inner)
.finish()
}
}
impl<S, V, D, ES> ListMoveNearbyListChangeSelector<S, V, D, ES> {
pub fn new(inner: NearbyListChangeMoveSelector<S, V, D, ES>) -> Self {
Self { inner }
}
}
impl<S, V, D, ES> MoveSelector<S, ListMoveImpl<S, V>>
for ListMoveNearbyListChangeSelector<S, V, D, ES>
where
S: PlanningSolution,
V: Clone + PartialEq + Send + Sync + Debug + 'static,
D: CrossEntityDistanceMeter<S>,
ES: EntitySelector<S>,
{
fn iter_moves<'a, SD: Director<S>>(
&'a self,
score_director: &'a SD,
) -> impl Iterator<Item = ListMoveImpl<S, V>> + 'a {
self.inner
.iter_moves(score_director)
.map(ListMoveImpl::ListChange)
}
fn size<SD: Director<S>>(&self, score_director: &SD) -> usize {
self.inner.size(score_director)
}
}