PerThreadMailboxes

public class PerThreadMailboxes<
  Message: MergeableMessage,
  Graph: GraphProtocol
>: MailboxesProtocol where Graph.VertexId: IdIndexable

Mailboxes that allow communication without synchronization.

Note: messages are delivered only once.

Show on GitHub

init(vertexCount:threadCount:)
Initializes self for a given graph size.
Declaration
Swift

public init(vertexCount: Int, threadCount: Int)
Show on GitHub
Mailbox
A mailbox that merges messages together.
See more
Declaration
Swift

public struct Mailbox : MailboxProtocol
Show on GitHub
deliver()
Transfers messages that were previously sent into the inboxes of the verticies.
Declaration
Swift

public func deliver() -> Bool
Show on GitHub


                    
                    
                    withMailbox(for:_:)

Executes fn passing in the Mailbox for vertex.

Declaration

Swift

public func withMailbox(for vertex: Graph.VertexId, _ fn: (inout Mailbox) throws -> Void) rethrows

Show on GitHub


                    
                    
                    init(for:sending:)

Initialize mailboxes for graph for messageType messages.

This initializer helps the type inference algorithm along.

Declaration

Swift

public convenience init<SequentialGraph: VertexListGraph & ParallelGraph>(
  for graph: __shared SequentialGraph,
  sending messageType: Type<Message> = .init()
) where SequentialGraph.ParallelProjection == Graph

Show on GitHub