httppool

A simple asynchronous worker pool and concurrent job queue for Golang's HTTP Server, inspired from Node.js asynchronous http server design.

Narasimha1997
8
2
Go

httppool

A simple asynchronous worker pool and concurrent job queue for Golang’s HTTP Server, inspired from Node.js asynchronous http server design.

Components

  1. A simple concurrent FIFO queue built mutexes/locking and doubly-linked-list - job queue
  2. A pool of goroutine workers that can grow to any specifed size.
  3. A function dispatcher that schedules handler functions to any of the free goroutine.
  4. A built-in routing-map that maps multiple routes (url paths) to handler functions.

Example :

package main

import (
	"fmt"
	"net/http"

	"github.com/Narasimha1997/httppool"
)

/*
	The handler will be passed with *http.ResponseWriter, *http.Request pointers,
	channel is a notifier which notifies the dispatcher about the routine completion,
	Pass channel<-true after completion
*/
func testRoute(w *http.ResponseWriter, r *http.Request, channel chan<- bool) {

	//use the r : http.Request

	fmt.Fprintf(*w, "<html></head>")
	fmt.Fprintf(*w, "<title>Sample test page</title>")
	fmt.Fprintf(*w, "</head>")
	fmt.Fprintf(*w, "<body>")
	fmt.Fprintf(*w, "<h4>Welcome to sample page</h4>")
	fmt.Fprintf(*w, "</body>")
	fmt.Fprintf(*w, "</html>")

	channel <- true
}

func main() {
	//Create a pool with 300 workers and 100 max queue size
	pool := httppool.NewRouteHandler(300, 100)

	//Register the route /test
	pool.RegisterRoute("/test", testRoute)

	//Register the route handler and redirect the root requests to our pool
	//This is how we glue http and pool modules
	http.HandleFunc("/", func(w http.ResponseWriter, r *http.Request) {
		//dispatch
		pool.Dispatch(w, r)
	})

	//Start the server on :9000 port
	http.ListenAndServe(":9000", nil)
}

To install:

To install as a pkg run:

go get github.com/Narasimha1997/httppool

To build from source:

#from project root

GOPATH=${GOPATH}:${PWD} 
go build github.com/Narasimha1997/httppool

Then you can run the example using the same GOPATH, as:

GOPATH=${GOPATH}:${PWD}
go build example/example.go

Then run the example binary as follows:

./example

TODO

  1. Built-in Logging
  2. Static file serving capability with built-in LRU cache for small files