Struct Seq

Source
pub struct Seq<G: RandomAccessGraph> { /* private fields */ }
Expand description

A sequential breadth-first visit.

This implementation uses an algorithm that is slightly different from the classical textbook algorithm, as we do not store parents or distances of the nodes from the root: Parents and distances are computed on the fly and passed to the callback function by visiting nodes when they are discovered, rather than when they are extracted from the queue.

This approach requires inserting a level separator between nodes at different distances: to obtain this result in a compact way, nodes are represented using NonMaxUsize, so the None variant of Option<NonMaxUsize> can be used as a separator.

§Examples

Let’s compute the distances from 0:

use webgraph_algo::visits::*;
use webgraph::graphs::vec_graph::VecGraph;
use webgraph::labels::proj::Left;
use std::ops::ControlFlow::Continue;
use no_break::NoBreak;

let graph = VecGraph::from_arcs([(0, 1), (1, 2), (2, 0), (1, 3)]);
let mut visit = breadth_first::Seq::new(&graph);
let mut d = [0; 4];
visit.visit(
    [0],
    |event| {
         // Set distance from 0
         if let breadth_first::EventPred::Unknown { node, distance, .. } = event {
             d[node] = distance;
         }
         Continue(())
    },
).continue_value_no_break();

assert_eq!(d, [0, 1, 2, 2]);

Here instead we compute the size of the ball of radius two around node 0: to minimize resource usage, we count nodes in the filter function, rather than as the result of an event. In this way, node at distance two are counted but not included in the queue, as it would happen if we were counting during an EventPred::Unknown event.

use std::convert::Infallible;
use webgraph_algo::visits::*;
use webgraph::graphs::vec_graph::VecGraph;
use webgraph::labels::proj::Left;
use std::ops::ControlFlow::Continue;
use no_break::NoBreak;

let graph = VecGraph::from_arcs([(0, 1), (1, 2), (2, 3), (3, 0), (2, 4)]);
let mut visit = breadth_first::Seq::new(&graph);
let mut count = 0;
visit.visit_filtered(
    [0],
    |event| { Continue(()) },
    |breadth_first::FilterArgsPred { distance, .. }| {
        if distance > 2 {
            false
        } else {
            count += 1;
            true
        }
    },
).continue_value_no_break();
assert_eq!(count, 3);

Implementations§

Source§

impl<G: RandomAccessGraph> Seq<G>

Source

pub fn new(graph: G) -> Self

Creates a new sequential visit.

§Arguments
  • graph: an immutable reference to the graph to visit.

Trait Implementations§

Source§

impl<G: RandomAccessGraph> Sequential<EventPred> for Seq<G>

Source§

fn visit_filtered_with<R: IntoIterator<Item = usize>, T, E, C: FnMut(&mut T, EventPred) -> ControlFlow<E, ()>, F: FnMut(&mut T, FilterArgsPred) -> bool>( &mut self, roots: R, init: T, callback: C, filter: F, ) -> ControlFlow<E, ()>

Visits the graph from the specified nodes with an initialization value and a filter function. Read more
Source§

fn reset(&mut self)

Resets the visit status, making it possible to reuse it.
Source§

fn visit_filtered<R: IntoIterator<Item = usize>, E, C: FnMut(A) -> ControlFlow<E, ()>, F: FnMut(A::FilterArgs) -> bool>( &mut self, roots: R, callback: C, filter: F, ) -> ControlFlow<E, ()>

Visits the graph from the specified nodes with a filter function. Read more
Source§

fn visit_with<R: IntoIterator<Item = usize>, T, E, C: FnMut(&mut T, A) -> ControlFlow<E, ()>>( &mut self, roots: R, init: T, callback: C, ) -> ControlFlow<E, ()>

Visits the graph from the specified nodes with an initialization value. Read more
Source§

fn visit<R: IntoIterator<Item = usize>, E, C: FnMut(A) -> ControlFlow<E, ()>>( &mut self, roots: R, callback: C, ) -> ControlFlow<E, ()>

Visits the graph from the specified nodes. Read more

Auto Trait Implementations§

§

impl<G> Freeze for Seq<G>
where G: Freeze,

§

impl<G> RefUnwindSafe for Seq<G>
where G: RefUnwindSafe,

§

impl<G> Send for Seq<G>
where G: Send,

§

impl<G> Sync for Seq<G>
where G: Sync,

§

impl<G> Unpin for Seq<G>
where G: Unpin,

§

impl<G> UnwindSafe for Seq<G>
where G: UnwindSafe,

Blanket Implementations§

Source§

impl<T> Any for T
where T: 'static + ?Sized,

Source§

fn type_id(&self) -> TypeId

Gets the TypeId of self. Read more
Source§

impl<T> Borrow<T> for T
where T: ?Sized,

Source§

fn borrow(&self) -> &T

Immutably borrows from an owned value. Read more
Source§

impl<T> BorrowMut<T> for T
where T: ?Sized,

Source§

fn borrow_mut(&mut self) -> &mut T

Mutably borrows from an owned value. Read more
Source§

impl<T> CastableFrom<T> for T

Source§

fn cast_from(value: T) -> T

Call Self as W
Source§

impl<T> CastableFrom<T> for T

Source§

fn cast_from(value: T) -> T

Call Self as W
Source§

impl<T, U> CastableInto<U> for T
where U: CastableFrom<T>,

Source§

fn cast(self) -> U

Call W::cast_from(self)
Source§

impl<T, U> CastableInto<U> for T
where U: CastableFrom<T>,

Source§

fn cast(self) -> U

Call W::cast_from(self)
Source§

impl<T> DowncastableFrom<T> for T

Source§

fn downcast_from(value: T) -> T

Truncate the current UnsignedInt to a possibly smaller size
Source§

impl<T> DowncastableFrom<T> for T

Source§

fn downcast_from(value: T) -> T

Truncate the current UnsignedInt to a possibly smaller size
Source§

impl<T, U> DowncastableInto<U> for T
where U: DowncastableFrom<T>,

Source§

fn downcast(self) -> U

Call W::downcast_from(self)
Source§

impl<T, U> DowncastableInto<U> for T
where U: DowncastableFrom<T>,

Source§

fn downcast(self) -> U

Call W::downcast_from(self)
Source§

impl<T> From<T> for T

Source§

fn from(t: T) -> T

Returns the argument unchanged.

Source§

impl<T, U> Into<U> for T
where U: From<T>,

Source§

fn into(self) -> U

Calls U::from(self).

That is, this conversion is whatever the implementation of From<T> for U chooses to do.

Source§

impl<T> IntoEither for T

Source§

fn into_either(self, into_left: bool) -> Either<Self, Self>

Converts self into a Left variant of Either<Self, Self> if into_left is true. Converts self into a Right variant of Either<Self, Self> otherwise. Read more
Source§

fn into_either_with<F>(self, into_left: F) -> Either<Self, Self>
where F: FnOnce(&Self) -> bool,

Converts self into a Left variant of Either<Self, Self> if into_left(&self) returns true. Converts self into a Right variant of Either<Self, Self> otherwise. Read more
Source§

impl<T> Pointable for T

Source§

const ALIGN: usize

The alignment of pointer.
Source§

type Init = T

The type for initializers.
Source§

unsafe fn init(init: <T as Pointable>::Init) -> usize

Initializes a with the given initializer. Read more
Source§

unsafe fn deref<'a>(ptr: usize) -> &'a T

Dereferences the given pointer. Read more
Source§

unsafe fn deref_mut<'a>(ptr: usize) -> &'a mut T

Mutably dereferences the given pointer. Read more
Source§

unsafe fn drop(ptr: usize)

Drops the object pointed to by the given pointer. Read more
Source§

impl<T> Splat<T> for T

Source§

fn splat(value: T) -> T

Source§

impl<T> Splat<T> for T

Source§

fn splat(value: T) -> T

Source§

impl<T> To<T> for T

Source§

fn to(self) -> T

Source§

impl<T> To<T> for T

Source§

fn to(self) -> T

Source§

impl<T, U> TryFrom<U> for T
where U: Into<T>,

Source§

type Error = Infallible

The type returned in the event of a conversion error.
Source§

fn try_from(value: U) -> Result<T, <T as TryFrom<U>>::Error>

Performs the conversion.
Source§

impl<T, U> TryInto<U> for T
where U: TryFrom<T>,

Source§

type Error = <U as TryFrom<T>>::Error

The type returned in the event of a conversion error.
Source§

fn try_into(self) -> Result<U, <U as TryFrom<T>>::Error>

Performs the conversion.
Source§

impl<T> UpcastableFrom<T> for T

Source§

fn upcast_from(value: T) -> T

Extend the current UnsignedInt to a possibly bigger size.
Source§

impl<T> UpcastableFrom<T> for T

Source§

fn upcast_from(value: T) -> T

Extend the current UnsignedInt to a possibly bigger size.
Source§

impl<T, U> UpcastableInto<U> for T
where U: UpcastableFrom<T>,

Source§

fn upcast(self) -> U

Call W::upcast_from(self)
Source§

impl<T, U> UpcastableInto<U> for T
where U: UpcastableFrom<T>,

Source§

fn upcast(self) -> U

Call W::upcast_from(self)
Source§

impl<V, T> VZip<V> for T
where V: MultiLane<T>,

Source§

fn vzip(self) -> V