Rajesh Kumar Nallabanda rajesnal

rajesnal / dynamic_plotting.py

Created June 23, 2018 16:30 — forked from greydanus/dynamic_plotting.py

Dynamic plotting for matplotlib

	"Dynamic plotting in matplotlib. Copy and paste into a Jupyter notebook."
	# written October 2016 by Sam Greydanus
	%matplotlib notebook
	import matplotlib.pyplot as plt
	import numpy as np
	import time

	def plt_dynamic(x, y, ax, colors=['b']):
	for color in colors:
	ax.plot(x, y, color)

rajesnal / golang_job_queue.md

Created April 12, 2018 12:05 — forked from harlow/golang_job_queue.md

Job queues in Golang

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.

rajesnal / main.go

Created April 12, 2018 11:59 — forked from nesv/main.go

	package main

	import (
	"flag"
	"fmt"
	"net/http"
	)

	var (
	NWorkers = flag.Int("n", 4, "The number of workers to start")

rajesnal / worker.go

Created April 12, 2018 11:59 — forked from nesv/worker.go

	package main

	import (
	"fmt"
	"time"
	)

	// NewWorker creates, and returns a new Worker object. Its only argument
	// is a channel that the worker can add itself to whenever it is done its
	// work.

rajesnal / collector.go

Created April 12, 2018 11:58 — forked from nesv/collector.go

	package main

	import (
	"fmt"
	"net/http"
	"time"
	)

	// A buffered channel that we can send work requests on.
	var WorkQueue = make(chan WorkRequest, 100)

rajesnal / work.go

Created April 12, 2018 11:57 — forked from nesv/work.go

rajesnal / dispatcher.go

Created April 12, 2018 11:57 — forked from nesv/dispatcher.go

	package main

	import "fmt"

	var WorkerQueue chan chan WorkRequest

	func StartDispatcher(nworkers int) {
	// First, initialize the channel we are going to but the workers' work channels into.
	WorkerQueue = make(chan chan WorkRequest, nworkers)

rajesnal / fifo.go

Created January 7, 2018 07:28 — forked from edhemphill/fifo.go

Thread / goroutine safe, batching and blocking FIFO queue in golang