queue-example.go

package main

import (
	"fmt"
	"net/http"
)

type storageData struct {
	data   string
}

var uploadQueue = make(chan storageData)

func uploader(uploadQueue chan storageData) {
	for {
		data := <-uploadQueue
		insertToBucket(data)
	}
}

func handler(w http.ResponseWriter, r *http.Request) {
	uploadQueue <- get_data(r)
	fmt.Fprintf(w, "Upload ok")
}

func initializeUploaders(uploadQueue chan storageData, n int) {
	for i := 0; i < n; i++ {
		fmt.Printf("Started uploader %d\n", i)
		go uploader(uploadQueue)
	}
}

func main() {
 	runtime.GOMAXPROCS(8)
	const nUploaders = 10
	initializeUploaders(uploadQueue, 10)
	http.HandleFunc("/upload", handler)
	http.ListenAndServe(":8080", nil)
}