gagliardetto

Golang Workers / Job Queue

A running example of the code from:

This gist creates a working example from blog post, and a alternate example using simple worker pool.

TLDR: if you want simple and controlled concurrency use a worker pool.

... or Why Pipelining Is Not That Easy

Golang Concurrency Patterns for brave and smart.

	Latency Comparison Numbers (~2012)
	----------------------------------
	L1 cache reference 0.5 ns
	Branch mispredict 5 ns
	L2 cache reference 7 ns 14x L1 cache
	Mutex lock/unlock 25 ns
	Main memory reference 100 ns 20x L2 cache, 200x L1 cache
	Compress 1K bytes with Zippy 3,000 ns 3 us
	Send 1K bytes over 1 Gbps network 10,000 ns 10 us
	Read 4K randomly from SSD* 150,000 ns 150 us ~1GB/sec SSD

	// ==UserScript==
	// @name LGTM stars
	// @namespace http://tampermonkey.net/
	// @version 0.1
	// @description Show star counts
	// @author Alvaro Muñoz (@pwntester)
	// @match https://lgtm.com/query/*
	// @grant none
	// @run-at document-idle
	// ==/UserScript==

	/*

	Go-Language implementation of an SSH Reverse Tunnel, the equivalent of below SSH command:

	ssh -R 8080:127.0.0.1:8080 operatore@146.148.22.123

	which opens a tunnel between the two endpoints and permit to exchange information on this direction:

	server:8080 -----> client:8080

	// junkterm is a quick and dirty serial terminal.
	package main

	import (
	"io"
	"log"
	"os"

	"github.com/pkg/term"
	"github.com/spf13/cobra"

	package main

	import (
	"log"
	"time"

	"golang.org/x/net/context"
	"google.golang.org/grpc"

	pb "github.com/jzelinskie/grpc/simple"

	96: FBProfileSetEventsCalendarSubscriptionStatusMutationOptimisticPayloadFactoryProtocol-Protocol.h
	95: FBGroupUpdateRequestToJoinSubscriptionLevelMutationOptimisticPayloadFactoryProtocol-Protocol.h
	94: FBEventUpdateNotificationSubscriptionLevelMutationOptimisticPayloadFactoryProtocol-Protocol.h
	93: FBReactionUnitUserSettingsDisableUnitTypeMutationOptimisticPayloadFactoryProtocol-Protocol.h
	93: FBMemReactionAcornSportsContentSettingsSetShouldNotPushNotificationsResponsePayloadBuilder.h
	92: FBReactionUnitUserSettingsEnableUnitTypeMutationOptimisticPayloadFactoryProtocol-Protocol.h
	91: FBProfileUpdateSecondarySubscribeStatusMutationOptimisticPayloadFactoryProtocol-Protocol.h
	91: FBViewerNotificationsUpdateAllSeenStateMutationOptimisticPayloadFactoryProtocol-Protocol.h
	90: FBMemReactionAcornSportsContentSettingsSetShouldPushNotificationsResponsePayloadBuilder.h
	89: FBMemReactionAcornTvContentSettingsSetShouldNotPushNotificationsResponsePayloadBuilder.h