gistfile1.txt

package main

import (
	"bufio"
	"encoding/json"
	"log"
	"os"
	"sync"
)

var input chan []byte

func readJSON(path string) {
	input = make(chan []byte, 2)
	go Start()
	handler, err := os.Open(path)
	if err != nil {
		log.Fatal(err)
	}
	defer handler.Close()

	scanner := bufio.NewScanner(handler)
	for scanner.Scan() {
		input <- scanner.Bytes()
	}
	close(input)
}

func Start() {
	var wg sync.WaitGroup
	for i := 0; i < 2; i++ {
		wg.Add(1)
		go func() {
			defer wg.Done()
			run()
		}()
	}
	wg.Wait()
}

func run() {
	for {
		bytes, ok := <-input
		if !ok {
			return
		}
		var data map[string]interface{}
		json.Unmarshal(bytes, &data)
	}
}