mirror of
https://github.com/tmrts/go-patterns.git
synced 2024-11-30 00:46:01 +03:00
1062 lines
26 KiB
HTML
1062 lines
26 KiB
HTML
|
|
||
|
|
<!DOCTYPE HTML>
|
||
|
|
<html lang="" >
|
||
|
|
<head>
|
||
|
|
<meta charset="UTF-8">
|
||
|
|
<meta content="text/html; charset=utf-8" http-equiv="Content-Type">
|
||
|
|
<title>Fan-In · GitBook</title>
|
||
|
|
<meta http-equiv="X-UA-Compatible" content="IE=edge" />
|
||
|
|
<meta name="description" content="">
|
||
|
|
<meta name="generator" content="GitBook 3.2.2">
|
||
|
|
|
||
|
|
|
||
|
|
|
||
|
|
|
||
|
|
<link rel="stylesheet" href="../gitbook/style.css">
|
||
|
|
|
||
|
|
|
||
|
|
|
||
|
|
|
||
|
|
<link rel="stylesheet" href="../gitbook/gitbook-plugin-highlight/website.css">
|
||
|
|
|
||
|
|
|
||
|
|
|
||
|
|
<link rel="stylesheet" href="../gitbook/gitbook-plugin-fontsettings/website.css">
|
||
|
|
|
||
|
|
|
||
|
|
|
||
|
|
|
||
|
|
|
||
|
|
|
||
|
|
|
||
|
|
|
||
|
|
|
||
|
|
|
||
|
|
|
||
|
|
|
||
|
|
|
||
|
|
|
||
|
|
|
||
|
|
|
||
|
|
|
||
|
|
|
||
|
|
|
||
|
|
|
||
|
|
|
||
|
|
|
||
|
|
|
||
|
|
<meta name="HandheldFriendly" content="true"/>
|
||
|
|
<meta name="viewport" content="width=device-width, initial-scale=1, user-scalable=no">
|
||
|
|
<meta name="apple-mobile-web-app-capable" content="yes">
|
||
|
|
<meta name="apple-mobile-web-app-status-bar-style" content="black">
|
||
|
|
<link rel="apple-touch-icon-precomposed" sizes="152x152" href="../gitbook/images/apple-touch-icon-precomposed-152.png">
|
||
|
|
<link rel="shortcut icon" href="../gitbook/images/favicon.ico" type="image/x-icon">
|
||
|
|
|
||
|
|
|
||
|
|
<link rel="next" href="fan_out.html" />
|
||
|
|
|
||
|
|
|
||
|
|
<link rel="prev" href="../" />
|
||
|
|
|
||
|
|
|
||
|
|
</head>
|
||
|
|
<body>
|
||
|
|
|
||
|
|
<div class="book">
|
||
|
|
<div class="book-summary">
|
||
|
|
|
||
|
|
|
||
|
|
|
||
|
|
<nav role="navigation">
|
||
|
|
|
||
|
|
|
||
|
|
|
||
|
|
<ul class="summary">
|
||
|
|
|
||
|
|
|
||
|
|
|
||
|
|
|
||
|
|
|
||
|
|
|
||
|
|
|
||
|
|
|
||
|
|
|
||
|
|
<li class="chapter " data-level="1.1" data-path="../">
|
||
|
|
|
||
|
|
<a href="../">
|
||
|
|
|
||
|
|
|
||
|
|
Go Patterns
|
||
|
|
|
||
|
|
</a>
|
||
|
|
|
||
|
|
|
||
|
|
|
||
|
|
<ul class="articles">
|
||
|
|
|
||
|
|
|
||
|
|
<li class="chapter " data-level="1.1.1" data-path="../">
|
||
|
|
|
||
|
|
<a href="../#creational-patterns">
|
||
|
|
|
||
|
|
|
||
|
|
Creational Patterns
|
||
|
|
|
||
|
|
</a>
|
||
|
|
|
||
|
|
|
||
|
|
|
||
|
|
<ul class="articles">
|
||
|
|
|
||
|
|
|
||
|
|
<li class="chapter " data-level="1.1.1.1" data-path="../creational/abstract_factory.md">
|
||
|
|
|
||
|
|
<span>
|
||
|
|
|
||
|
|
|
||
|
|
Abstract Factory
|
||
|
|
|
||
|
|
</a>
|
||
|
|
|
||
|
|
|
||
|
|
|
||
|
|
</li>
|
||
|
|
|
||
|
|
<li class="chapter " data-level="1.1.1.2" data-path="../creational/builder.html">
|
||
|
|
|
||
|
|
<a href="../creational/builder.html">
|
||
|
|
|
||
|
|
|
||
|
|
Builder
|
||
|
|
|
||
|
|
</a>
|
||
|
|
|
||
|
|
|
||
|
|
|
||
|
|
</li>
|
||
|
|
|
||
|
|
<li class="chapter " data-level="1.1.1.3" data-path="../creational/factory.html">
|
||
|
|
|
||
|
|
<a href="../creational/factory.html">
|
||
|
|
|
||
|
|
|
||
|
|
Factory Method
|
||
|
|
|
||
|
|
</a>
|
||
|
|
|
||
|
|
|
||
|
|
|
||
|
|
</li>
|
||
|
|
|
||
|
|
<li class="chapter " data-level="1.1.1.4" data-path="../creational/object-pool.html">
|
||
|
|
|
||
|
|
<a href="../creational/object-pool.html">
|
||
|
|
|
||
|
|
|
||
|
|
Object Pool
|
||
|
|
|
||
|
|
</a>
|
||
|
|
|
||
|
|
|
||
|
|
|
||
|
|
</li>
|
||
|
|
|
||
|
|
<li class="chapter " data-level="1.1.1.5" data-path="../creational/singleton.html">
|
||
|
|
|
||
|
|
<a href="../creational/singleton.html">
|
||
|
|
|
||
|
|
|
||
|
|
Singleton
|
||
|
|
|
||
|
|
</a>
|
||
|
|
|
||
|
|
|
||
|
|
|
||
|
|
</li>
|
||
|
|
|
||
|
|
|
||
|
|
</ul>
|
||
|
|
|
||
|
|
</li>
|
||
|
|
|
||
|
|
<li class="chapter " data-level="1.1.2" data-path="../">
|
||
|
|
|
||
|
|
<a href="../#structural-patterns">
|
||
|
|
|
||
|
|
|
||
|
|
Structural Patterns
|
||
|
|
|
||
|
|
</a>
|
||
|
|
|
||
|
|
|
||
|
|
|
||
|
|
<ul class="articles">
|
||
|
|
|
||
|
|
|
||
|
|
<li class="chapter " data-level="1.1.2.1" data-path="../structural/bridge.md">
|
||
|
|
|
||
|
|
<span>
|
||
|
|
|
||
|
|
|
||
|
|
Bridge
|
||
|
|
|
||
|
|
</a>
|
||
|
|
|
||
|
|
|
||
|
|
|
||
|
|
</li>
|
||
|
|
|
||
|
|
<li class="chapter " data-level="1.1.2.2" data-path="../structural/composite.md">
|
||
|
|
|
||
|
|
<span>
|
||
|
|
|
||
|
|
|
||
|
|
Composite
|
||
|
|
|
||
|
|
</a>
|
||
|
|
|
||
|
|
|
||
|
|
|
||
|
|
</li>
|
||
|
|
|
||
|
|
<li class="chapter " data-level="1.1.2.3" data-path="../structural/decorator.html">
|
||
|
|
|
||
|
|
<a href="../structural/decorator.html">
|
||
|
|
|
||
|
|
|
||
|
|
Decorator
|
||
|
|
|
||
|
|
</a>
|
||
|
|
|
||
|
|
|
||
|
|
|
||
|
|
</li>
|
||
|
|
|
||
|
|
<li class="chapter " data-level="1.1.2.4" data-path="../structural/facade.md">
|
||
|
|
|
||
|
|
<span>
|
||
|
|
|
||
|
|
|
||
|
|
Facade
|
||
|
|
|
||
|
|
</a>
|
||
|
|
|
||
|
|
|
||
|
|
|
||
|
|
</li>
|
||
|
|
|
||
|
|
<li class="chapter " data-level="1.1.2.5" data-path="../structural/flyweight.md">
|
||
|
|
|
||
|
|
<span>
|
||
|
|
|
||
|
|
|
||
|
|
Flyweight
|
||
|
|
|
||
|
|
</a>
|
||
|
|
|
||
|
|
|
||
|
|
|
||
|
|
</li>
|
||
|
|
|
||
|
|
<li class="chapter " data-level="1.1.2.6" data-path="../structural/proxy.md">
|
||
|
|
|
||
|
|
<span>
|
||
|
|
|
||
|
|
|
||
|
|
Proxy
|
||
|
|
|
||
|
|
</a>
|
||
|
|
|
||
|
|
|
||
|
|
|
||
|
|
</li>
|
||
|
|
|
||
|
|
|
||
|
|
</ul>
|
||
|
|
|
||
|
|
</li>
|
||
|
|
|
||
|
|
<li class="chapter " data-level="1.1.3" data-path="../">
|
||
|
|
|
||
|
|
<a href="../#behavioral-patterns">
|
||
|
|
|
||
|
|
|
||
|
|
Behavioral Patterns
|
||
|
|
|
||
|
|
</a>
|
||
|
|
|
||
|
|
|
||
|
|
|
||
|
|
<ul class="articles">
|
||
|
|
|
||
|
|
|
||
|
|
<li class="chapter " data-level="1.1.3.1" data-path="../behavioral/chain_of_responsibility.md">
|
||
|
|
|
||
|
|
<span>
|
||
|
|
|
||
|
|
|
||
|
|
Chain of Responsibility
|
||
|
|
|
||
|
|
</a>
|
||
|
|
|
||
|
|
|
||
|
|
|
||
|
|
</li>
|
||
|
|
|
||
|
|
<li class="chapter " data-level="1.1.3.2" data-path="../behavioral/command.md">
|
||
|
|
|
||
|
|
<span>
|
||
|
|
|
||
|
|
|
||
|
|
Command
|
||
|
|
|
||
|
|
</a>
|
||
|
|
|
||
|
|
|
||
|
|
|
||
|
|
</li>
|
||
|
|
|
||
|
|
<li class="chapter " data-level="1.1.3.3" data-path="../behavioral/mediator.md">
|
||
|
|
|
||
|
|
<span>
|
||
|
|
|
||
|
|
|
||
|
|
Mediator
|
||
|
|
|
||
|
|
</a>
|
||
|
|
|
||
|
|
|
||
|
|
|
||
|
|
</li>
|
||
|
|
|
||
|
|
<li class="chapter " data-level="1.1.3.4" data-path="../behavioral/memento.md">
|
||
|
|
|
||
|
|
<span>
|
||
|
|
|
||
|
|
|
||
|
|
Memento
|
||
|
|
|
||
|
|
</a>
|
||
|
|
|
||
|
|
|
||
|
|
|
||
|
|
</li>
|
||
|
|
|
||
|
|
<li class="chapter " data-level="1.1.3.5" data-path="../behavioral/observer.html">
|
||
|
|
|
||
|
|
<a href="../behavioral/observer.html">
|
||
|
|
|
||
|
|
|
||
|
|
Observer
|
||
|
|
|
||
|
|
</a>
|
||
|
|
|
||
|
|
|
||
|
|
|
||
|
|
</li>
|
||
|
|
|
||
|
|
<li class="chapter " data-level="1.1.3.6" data-path="../behavioral/registry.md">
|
||
|
|
|
||
|
|
<span>
|
||
|
|
|
||
|
|
|
||
|
|
Registry
|
||
|
|
|
||
|
|
</a>
|
||
|
|
|
||
|
|
|
||
|
|
|
||
|
|
</li>
|
||
|
|
|
||
|
|
<li class="chapter " data-level="1.1.3.7" data-path="../behavioral/state.md">
|
||
|
|
|
||
|
|
<span>
|
||
|
|
|
||
|
|
|
||
|
|
State
|
||
|
|
|
||
|
|
</a>
|
||
|
|
|
||
|
|
|
||
|
|
|
||
|
|
</li>
|
||
|
|
|
||
|
|
<li class="chapter " data-level="1.1.3.8" data-path="../behavioral/strategy.html">
|
||
|
|
|
||
|
|
<a href="../behavioral/strategy.html">
|
||
|
|
|
||
|
|
|
||
|
|
Strategy
|
||
|
|
|
||
|
|
</a>
|
||
|
|
|
||
|
|
|
||
|
|
|
||
|
|
</li>
|
||
|
|
|
||
|
|
<li class="chapter " data-level="1.1.3.9" data-path="../behavioral/template.md">
|
||
|
|
|
||
|
|
<span>
|
||
|
|
|
||
|
|
|
||
|
|
Template
|
||
|
|
|
||
|
|
</a>
|
||
|
|
|
||
|
|
|
||
|
|
|
||
|
|
</li>
|
||
|
|
|
||
|
|
<li class="chapter " data-level="1.1.3.10" data-path="../behavioral/visitor.md">
|
||
|
|
|
||
|
|
<span>
|
||
|
|
|
||
|
|
|
||
|
|
Visitor
|
||
|
|
|
||
|
|
</a>
|
||
|
|
|
||
|
|
|
||
|
|
|
||
|
|
</li>
|
||
|
|
|
||
|
|
|
||
|
|
</ul>
|
||
|
|
|
||
|
|
</li>
|
||
|
|
|
||
|
|
<li class="chapter " data-level="1.1.4" data-path="../">
|
||
|
|
|
||
|
|
<a href="../#synchronization-patterns">
|
||
|
|
|
||
|
|
|
||
|
|
Synchronization Patterns
|
||
|
|
|
||
|
|
</a>
|
||
|
|
|
||
|
|
|
||
|
|
|
||
|
|
<ul class="articles">
|
||
|
|
|
||
|
|
|
||
|
|
<li class="chapter " data-level="1.1.4.1" data-path="../synchronization/condition_variable.md">
|
||
|
|
|
||
|
|
<span>
|
||
|
|
|
||
|
|
|
||
|
|
Condition Variable
|
||
|
|
|
||
|
|
</a>
|
||
|
|
|
||
|
|
|
||
|
|
|
||
|
|
</li>
|
||
|
|
|
||
|
|
<li class="chapter " data-level="1.1.4.2" data-path="../synchronization/mutex.md">
|
||
|
|
|
||
|
|
<span>
|
||
|
|
|
||
|
|
|
||
|
|
Lock/Mutex
|
||
|
|
|
||
|
|
</a>
|
||
|
|
|
||
|
|
|
||
|
|
|
||
|
|
</li>
|
||
|
|
|
||
|
|
<li class="chapter " data-level="1.1.4.3" data-path="../synchronization/monitor.md">
|
||
|
|
|
||
|
|
<span>
|
||
|
|
|
||
|
|
|
||
|
|
Monitor
|
||
|
|
|
||
|
|
</a>
|
||
|
|
|
||
|
|
|
||
|
|
|
||
|
|
</li>
|
||
|
|
|
||
|
|
<li class="chapter " data-level="1.1.4.4" data-path="../synchronization/read_write_lock.md">
|
||
|
|
|
||
|
|
<span>
|
||
|
|
|
||
|
|
|
||
|
|
Read-Write Lock
|
||
|
|
|
||
|
|
</a>
|
||
|
|
|
||
|
|
|
||
|
|
|
||
|
|
</li>
|
||
|
|
|
||
|
|
<li class="chapter " data-level="1.1.4.5" data-path="../synchronization/semaphore.html">
|
||
|
|
|
||
|
|
<a href="../synchronization/semaphore.html">
|
||
|
|
|
||
|
|
|
||
|
|
Semaphore
|
||
|
|
|
||
|
|
</a>
|
||
|
|
|
||
|
|
|
||
|
|
|
||
|
|
</li>
|
||
|
|
|
||
|
|
|
||
|
|
</ul>
|
||
|
|
|
||
|
|
</li>
|
||
|
|
|
||
|
|
<li class="chapter " data-level="1.1.5" data-path="../">
|
||
|
|
|
||
|
|
<a href="../#concurrency-patterns">
|
||
|
|
|
||
|
|
|
||
|
|
Concurrency Patterns
|
||
|
|
|
||
|
|
</a>
|
||
|
|
|
||
|
|
|
||
|
|
|
||
|
|
<ul class="articles">
|
||
|
|
|
||
|
|
|
||
|
|
<li class="chapter " data-level="1.1.5.1" data-path="../concurrency/barrier.md">
|
||
|
|
|
||
|
|
<span>
|
||
|
|
|
||
|
|
|
||
|
|
N-Barrier
|
||
|
|
|
||
|
|
</a>
|
||
|
|
|
||
|
|
|
||
|
|
|
||
|
|
</li>
|
||
|
|
|
||
|
|
<li class="chapter " data-level="1.1.5.2" data-path="../concurrency/bounded_parallelism.html">
|
||
|
|
|
||
|
|
<a href="../concurrency/bounded_parallelism.html">
|
||
|
|
|
||
|
|
|
||
|
|
Bounded Parallelism
|
||
|
|
|
||
|
|
</a>
|
||
|
|
|
||
|
|
|
||
|
|
|
||
|
|
</li>
|
||
|
|
|
||
|
|
<li class="chapter " data-level="1.1.5.3" data-path="../concurrency/broadcast.md">
|
||
|
|
|
||
|
|
<span>
|
||
|
|
|
||
|
|
|
||
|
|
Broadcast
|
||
|
|
|
||
|
|
</a>
|
||
|
|
|
||
|
|
|
||
|
|
|
||
|
|
</li>
|
||
|
|
|
||
|
|
<li class="chapter " data-level="1.1.5.4" data-path="../concurrency/coroutine.md">
|
||
|
|
|
||
|
|
<span>
|
||
|
|
|
||
|
|
|
||
|
|
Coroutines
|
||
|
|
|
||
|
|
</a>
|
||
|
|
|
||
|
|
|
||
|
|
|
||
|
|
</li>
|
||
|
|
|
||
|
|
<li class="chapter " data-level="1.1.5.5" data-path="../concurrency/generator.html">
|
||
|
|
|
||
|
|
<a href="../concurrency/generator.html">
|
||
|
|
|
||
|
|
|
||
|
|
Generators
|
||
|
|
|
||
|
|
</a>
|
||
|
|
|
||
|
|
|
||
|
|
|
||
|
|
</li>
|
||
|
|
|
||
|
|
<li class="chapter " data-level="1.1.5.6" data-path="../concurrency/reactor.md">
|
||
|
|
|
||
|
|
<span>
|
||
|
|
|
||
|
|
|
||
|
|
Reactor
|
||
|
|
|
||
|
|
</a>
|
||
|
|
|
||
|
|
|
||
|
|
|
||
|
|
</li>
|
||
|
|
|
||
|
|
<li class="chapter " data-level="1.1.5.7" data-path="../concurrency/parallelism.html">
|
||
|
|
|
||
|
|
<a href="../concurrency/parallelism.html">
|
||
|
|
|
||
|
|
|
||
|
|
Parallelism
|
||
|
|
|
||
|
|
</a>
|
||
|
|
|
||
|
|
|
||
|
|
|
||
|
|
</li>
|
||
|
|
|
||
|
|
<li class="chapter " data-level="1.1.5.8" data-path="../concurrency/producer_consumer.md">
|
||
|
|
|
||
|
|
<span>
|
||
|
|
|
||
|
|
|
||
|
|
Producer Consumer
|
||
|
|
|
||
|
|
</a>
|
||
|
|
|
||
|
|
|
||
|
|
|
||
|
|
</li>
|
||
|
|
|
||
|
|
|
||
|
|
</ul>
|
||
|
|
|
||
|
|
</li>
|
||
|
|
|
||
|
|
<li class="chapter " data-level="1.1.6" data-path="../">
|
||
|
|
|
||
|
|
<a href="../#messaging-patterns">
|
||
|
|
|
||
|
|
|
||
|
|
Messaging Patterns
|
||
|
|
|
||
|
|
</a>
|
||
|
|
|
||
|
|
|
||
|
|
|
||
|
|
<ul class="articles">
|
||
|
|
|
||
|
|
|
||
|
|
<li class="chapter active" data-level="1.1.6.1" data-path="fan_in.html">
|
||
|
|
|
||
|
|
<a href="fan_in.html">
|
||
|
|
|
||
|
|
|
||
|
|
Fan-In
|
||
|
|
|
||
|
|
</a>
|
||
|
|
|
||
|
|
|
||
|
|
|
||
|
|
</li>
|
||
|
|
|
||
|
|
<li class="chapter " data-level="1.1.6.2" data-path="fan_out.html">
|
||
|
|
|
||
|
|
<a href="fan_out.html">
|
||
|
|
|
||
|
|
|
||
|
|
Fan-Out
|
||
|
|
|
||
|
|
</a>
|
||
|
|
|
||
|
|
|
||
|
|
|
||
|
|
</li>
|
||
|
|
|
||
|
|
<li class="chapter " data-level="1.1.6.3" data-path="futures_promises.md">
|
||
|
|
|
||
|
|
<span>
|
||
|
|
|
||
|
|
|
||
|
|
Futures & Promises
|
||
|
|
|
||
|
|
</a>
|
||
|
|
|
||
|
|
|
||
|
|
|
||
|
|
</li>
|
||
|
|
|
||
|
|
<li class="chapter " data-level="1.1.6.4" data-path="publish_subscribe.html">
|
||
|
|
|
||
|
|
<a href="publish_subscribe.html">
|
||
|
|
|
||
|
|
|
||
|
|
Publish/Subscribe
|
||
|
|
|
||
|
|
</a>
|
||
|
|
|
||
|
|
|
||
|
|
|
||
|
|
</li>
|
||
|
|
|
||
|
|
<li class="chapter " data-level="1.1.6.5" data-path="push_pull.md">
|
||
|
|
|
||
|
|
<span>
|
||
|
|
|
||
|
|
|
||
|
|
Push & Pull
|
||
|
|
|
||
|
|
</a>
|
||
|
|
|
||
|
|
|
||
|
|
|
||
|
|
</li>
|
||
|
|
|
||
|
|
|
||
|
|
</ul>
|
||
|
|
|
||
|
|
</li>
|
||
|
|
|
||
|
|
<li class="chapter " data-level="1.1.7" data-path="../">
|
||
|
|
|
||
|
|
<a href="../#stability-patterns">
|
||
|
|
|
||
|
|
|
||
|
|
Stability Patterns
|
||
|
|
|
||
|
|
</a>
|
||
|
|
|
||
|
|
|
||
|
|
|
||
|
|
<ul class="articles">
|
||
|
|
|
||
|
|
|
||
|
|
<li class="chapter " data-level="1.1.7.1" data-path="../stability/bulkhead.md">
|
||
|
|
|
||
|
|
<span>
|
||
|
|
|
||
|
|
|
||
|
|
Bulkheads
|
||
|
|
|
||
|
|
</a>
|
||
|
|
|
||
|
|
|
||
|
|
|
||
|
|
</li>
|
||
|
|
|
||
|
|
<li class="chapter " data-level="1.1.7.2" data-path="../stability/circuit-breaker.html">
|
||
|
|
|
||
|
|
<a href="../stability/circuit-breaker.html">
|
||
|
|
|
||
|
|
|
||
|
|
Circuit-Breaker
|
||
|
|
|
||
|
|
</a>
|
||
|
|
|
||
|
|
|
||
|
|
|
||
|
|
</li>
|
||
|
|
|
||
|
|
<li class="chapter " data-level="1.1.7.3" data-path="../stability/deadline.md">
|
||
|
|
|
||
|
|
<span>
|
||
|
|
|
||
|
|
|
||
|
|
Deadline
|
||
|
|
|
||
|
|
</a>
|
||
|
|
|
||
|
|
|
||
|
|
|
||
|
|
</li>
|
||
|
|
|
||
|
|
<li class="chapter " data-level="1.1.7.4" data-path="../stability/fail_fast.md">
|
||
|
|
|
||
|
|
<span>
|
||
|
|
|
||
|
|
|
||
|
|
Fail-Fast
|
||
|
|
|
||
|
|
</a>
|
||
|
|
|
||
|
|
|
||
|
|
|
||
|
|
</li>
|
||
|
|
|
||
|
|
<li class="chapter " data-level="1.1.7.5" data-path="../stability/handshaking.md">
|
||
|
|
|
||
|
|
<span>
|
||
|
|
|
||
|
|
|
||
|
|
Handshaking
|
||
|
|
|
||
|
|
</a>
|
||
|
|
|
||
|
|
|
||
|
|
|
||
|
|
</li>
|
||
|
|
|
||
|
|
<li class="chapter " data-level="1.1.7.6" data-path="../stability/steady_state.md">
|
||
|
|
|
||
|
|
<span>
|
||
|
|
|
||
|
|
|
||
|
|
Steady-State
|
||
|
|
|
||
|
|
</a>
|
||
|
|
|
||
|
|
|
||
|
|
|
||
|
|
</li>
|
||
|
|
|
||
|
|
|
||
|
|
</ul>
|
||
|
|
|
||
|
|
</li>
|
||
|
|
|
||
|
|
<li class="chapter " data-level="1.1.8" data-path="../">
|
||
|
|
|
||
|
|
<a href="../#profiling-patterns">
|
||
|
|
|
||
|
|
|
||
|
|
Profiling Patterns
|
||
|
|
|
||
|
|
</a>
|
||
|
|
|
||
|
|
|
||
|
|
|
||
|
|
<ul class="articles">
|
||
|
|
|
||
|
|
|
||
|
|
<li class="chapter " data-level="1.1.8.1" data-path="../profiling/timing.html">
|
||
|
|
|
||
|
|
<a href="../profiling/timing.html">
|
||
|
|
|
||
|
|
|
||
|
|
Timing Functions
|
||
|
|
|
||
|
|
</a>
|
||
|
|
|
||
|
|
|
||
|
|
|
||
|
|
</li>
|
||
|
|
|
||
|
|
|
||
|
|
</ul>
|
||
|
|
|
||
|
|
</li>
|
||
|
|
|
||
|
|
<li class="chapter " data-level="1.1.9" data-path="../">
|
||
|
|
|
||
|
|
<a href="../#idioms">
|
||
|
|
|
||
|
|
|
||
|
|
Idioms
|
||
|
|
|
||
|
|
</a>
|
||
|
|
|
||
|
|
|
||
|
|
|
||
|
|
<ul class="articles">
|
||
|
|
|
||
|
|
|
||
|
|
<li class="chapter " data-level="1.1.9.1" data-path="../idiom/functional-options.html">
|
||
|
|
|
||
|
|
<a href="../idiom/functional-options.html">
|
||
|
|
|
||
|
|
|
||
|
|
Functional Options
|
||
|
|
|
||
|
|
</a>
|
||
|
|
|
||
|
|
|
||
|
|
|
||
|
|
</li>
|
||
|
|
|
||
|
|
|
||
|
|
</ul>
|
||
|
|
|
||
|
|
</li>
|
||
|
|
|
||
|
|
<li class="chapter " data-level="1.1.10" data-path="../">
|
||
|
|
|
||
|
|
<a href="../#anti-patterns">
|
||
|
|
|
||
|
|
|
||
|
|
Anti-Patterns
|
||
|
|
|
||
|
|
</a>
|
||
|
|
|
||
|
|
|
||
|
|
|
||
|
|
<ul class="articles">
|
||
|
|
|
||
|
|
|
||
|
|
<li class="chapter " data-level="1.1.10.1" data-path="../anti-patterns/cascading_failures.md">
|
||
|
|
|
||
|
|
<span>
|
||
|
|
|
||
|
|
|
||
|
|
Cascading Failures
|
||
|
|
|
||
|
|
</a>
|
||
|
|
|
||
|
|
|
||
|
|
|
||
|
|
</li>
|
||
|
|
|
||
|
|
|
||
|
|
</ul>
|
||
|
|
|
||
|
|
</li>
|
||
|
|
|
||
|
|
|
||
|
|
</ul>
|
||
|
|
|
||
|
|
</li>
|
||
|
|
|
||
|
|
<li class="chapter " data-level="1.2" data-path="../CONTRIBUTING.html">
|
||
|
|
|
||
|
|
<a href="../CONTRIBUTING.html">
|
||
|
|
|
||
|
|
|
||
|
|
Contributing
|
||
|
|
|
||
|
|
</a>
|
||
|
|
|
||
|
|
|
||
|
|
|
||
|
|
</li>
|
||
|
|
|
||
|
|
|
||
|
|
|
||
|
|
|
||
|
|
<li class="divider"></li>
|
||
|
|
|
||
|
|
<li>
|
||
|
|
<a href="https://www.gitbook.com" target="blank" class="gitbook-link">
|
||
|
|
Published with GitBook
|
||
|
|
</a>
|
||
|
|
</li>
|
||
|
|
</ul>
|
||
|
|
|
||
|
|
|
||
|
|
</nav>
|
||
|
|
|
||
|
|
|
||
|
|
</div>
|
||
|
|
|
||
|
|
<div class="book-body">
|
||
|
|
|
||
|
|
<div class="body-inner">
|
||
|
|
|
||
|
|
|
||
|
|
|
||
|
|
<div class="book-header" role="navigation">
|
||
|
|
|
||
|
|
|
||
|
|
<!-- Title -->
|
||
|
|
<h1>
|
||
|
|
<i class="fa fa-circle-o-notch fa-spin"></i>
|
||
|
|
<a href=".." >Fan-In</a>
|
||
|
|
</h1>
|
||
|
|
</div>
|
||
|
|
|
||
|
|
|
||
|
|
|
||
|
|
|
||
|
|
<div class="page-wrapper" tabindex="-1" role="main">
|
||
|
|
<div class="page-inner">
|
||
|
|
|
||
|
|
<section class="normal markdown-section">
|
||
|
|
|
||
|
|
<h1 id="fan-in-messaging-patterns">Fan-In Messaging Patterns</h1>
|
||
|
|
<p>Fan-In is a messaging pattern used to create a funnel for work amongst workers (clients: source, server: destination).</p>
|
||
|
|
<p>We can model fan-in using the Go channels.</p>
|
||
|
|
<pre><code class="lang-go"><span class="hljs-comment">// Merge different channels in one channel</span>
|
||
|
|
<span class="hljs-keyword">func</span> Merge(cs ...<-<span class="hljs-keyword">chan</span> <span class="hljs-keyword">int</span>) <-<span class="hljs-keyword">chan</span> <span class="hljs-keyword">int</span> {
|
||
|
|
<span class="hljs-keyword">var</span> wg sync.WaitGroup
|
||
|
|
|
||
|
|
out := <span class="hljs-built_in">make</span>(<span class="hljs-keyword">chan</span> <span class="hljs-keyword">int</span>)
|
||
|
|
|
||
|
|
<span class="hljs-comment">// Start an send goroutine for each input channel in cs. send</span>
|
||
|
|
<span class="hljs-comment">// copies values from c to out until c is closed, then calls wg.Done.</span>
|
||
|
|
send := <span class="hljs-keyword">func</span>(c <-<span class="hljs-keyword">chan</span> <span class="hljs-keyword">int</span>) {
|
||
|
|
<span class="hljs-keyword">for</span> n := <span class="hljs-keyword">range</span> c {
|
||
|
|
out <- n
|
||
|
|
}
|
||
|
|
wg.Done()
|
||
|
|
}
|
||
|
|
|
||
|
|
wg.Add(<span class="hljs-built_in">len</span>(cs))
|
||
|
|
<span class="hljs-keyword">for</span> _, c := <span class="hljs-keyword">range</span> cs {
|
||
|
|
<span class="hljs-keyword">go</span> send(c)
|
||
|
|
}
|
||
|
|
|
||
|
|
<span class="hljs-comment">// Start a goroutine to close out once all the send goroutines are</span>
|
||
|
|
<span class="hljs-comment">// done. This must start after the wg.Add call.</span>
|
||
|
|
<span class="hljs-keyword">go</span> <span class="hljs-keyword">func</span>() {
|
||
|
|
wg.Wait()
|
||
|
|
<span class="hljs-built_in">close</span>(out)
|
||
|
|
}()
|
||
|
|
<span class="hljs-keyword">return</span> out
|
||
|
|
}
|
||
|
|
</code></pre>
|
||
|
|
<p>The <code>Merge</code> function converts a list of channels to a single channel by starting a goroutine for each inbound channel that copies the values to the sole outbound channel.</p>
|
||
|
|
<p>Once all the output goroutines have been started, <code>Merge</code> a goroutine is started to close the main channel.</p>
|
||
|
|
|
||
|
|
|
||
|
|
</section>
|
||
|
|
|
||
|
|
</div>
|
||
|
|
</div>
|
||
|
|
|
||
|
|
</div>
|
||
|
|
|
||
|
|
|
||
|
|
|
||
|
|
<a href="../#messaging-patterns" class="navigation navigation-prev " aria-label="Previous page: Messaging Patterns">
|
||
|
|
<i class="fa fa-angle-left"></i>
|
||
|
|
</a>
|
||
|
|
|
||
|
|
|
||
|
|
<a href="fan_out.html" class="navigation navigation-next " aria-label="Next page: Fan-Out">
|
||
|
|
<i class="fa fa-angle-right"></i>
|
||
|
|
</a>
|
||
|
|
|
||
|
|
|
||
|
|
|
||
|
|
</div>
|
||
|
|
|
||
|
|
<script>
|
||
|
|
var gitbook = gitbook || [];
|
||
|
|
gitbook.push(function() {
|
||
|
|
gitbook.page.hasChanged({"page":{"title":"Fan-In","level":"1.1.6.1","depth":3,"next":{"title":"Fan-Out","level":"1.1.6.2","depth":3,"path":"messaging/fan_out.md","ref":"messaging/fan_out.md","articles":[]},"previous":{"title":"Messaging Patterns","level":"1.1.6","depth":2,"anchor":"#messaging-patterns","path":"README.md","ref":"README.md#messaging-patterns","articles":[{"title":"Fan-In","level":"1.1.6.1","depth":3,"path":"messaging/fan_in.md","ref":"messaging/fan_in.md","articles":[]},{"title":"Fan-Out","level":"1.1.6.2","depth":3,"path":"messaging/fan_out.md","ref":"messaging/fan_out.md","articles":[]},{"title":"Futures & Promises","level":"1.1.6.3","depth":3,"path":"messaging/futures_promises.md","ref":"messaging/futures_promises.md","articles":[]},{"title":"Publish/Subscribe","level":"1.1.6.4","depth":3,"path":"messaging/publish_subscribe.md","ref":"messaging/publish_subscribe.md","articles":[]},{"title":"Push & Pull","level":"1.1.6.5","depth":3,"path":"messaging/push_pull.md","ref":"messaging/push_pull.md","articles":[]}]},"dir":"ltr"},"config":{"gitbook":"*","theme":"default","variables":{},"plugins":["-search","-lunr","github","edit-link"],"pluginsConfig":{"github":{"url":"https://github.com/tmrts/go-patterns"},"edit-link":{"label":"","base":"https://github.com/tmrts/go-patterns/edit/master/"},"highlight":{},"sharing":{"facebook":true,"twitter":true,"google":false,"weibo":false,"instapaper":false,"vk":false,"all":["facebook","google","twitter","weibo","instapaper"]},"fontsettings":{"theme":"white","family":"sans","size":2},"theme-default":{"styles":{"website":"styles/website.css","pdf":"styles/pdf.css","epub":"styles/epub.css","mobi":"styles/mobi.css","ebook":"styles/ebook.css","print":"styles/print.css"},"showLevel":false}},"structure":{"langs":"LANGS.md","readme":"README.md","glossary":"GLOSSARY.md","summary":"SUMMARY.md"},"pdf":{"pageNumbers":true,"fontSize":12,"fontFamily":"Arial","paperSize":"a4","chapterMark":"pagebreak","pageBreaksBefore":"/","margin":{"right":62,"left":62,"top":56,"bottom":56}},"styles":{"website":"styles/website.css","pdf":"styles/pdf.css","epub":"styles/epub.css","mobi":"styles/mobi.css","ebook":"styles/ebook.css","print":"styles/print.css"}},"file":{"path":"messaging/fan_in.md","mtime":"2017-05-01T12:22:21.000Z","type":"markdown"},"gitbook":{"version":"3.2.2","time":"2017-05-01T12:23:41.783Z"},"basePath":"..","book":{"language":""}});
|
||
|
|
});
|
||
|
|
</script>
|
||
|
|
</div>
|
||
|
|
|
||
|
|
|
||
|
|
<script src="../gitbook/gitbook.js"></script>
|
||
|
|
<script src="../gitbook/theme.js"></script>
|
||
|
|
|
||
|
|
|
||
|
|
<script src="../gitbook/gitbook-plugin-github/plugin.js"></script>
|
||
|
|
|
||
|
|
|
||
|
|
|
||
|
|
<script src="../gitbook/gitbook-plugin-edit-link/plugin.js"></script>
|
||
|
|
|
||
|
|
|
||
|
|
|
||
|
|
<script src="../gitbook/gitbook-plugin-sharing/buttons.js"></script>
|
||
|
|
|
||
|
|
|
||
|
|
|
||
|
|
<script src="../gitbook/gitbook-plugin-fontsettings/fontsettings.js"></script>
|
||
|
|
|
||
|
|
|
||
|
|
|
||
|
|
</body>
|
||
|
|
</html>
|
||
|
|
|