Concurrent version of the DMR XML parser in Go.

concurrent-xml-parser.go

// Same data structures as before.

// ParseExcerpt parses XML file using XML decoding.
func (p *XMLParser) ParseExcerpt(id int, lines <-chan []string, parsed chan<- string, done chan<- int) {
	proc := 0 // How many excerpts did we process?
	var stat vehicleStat
	for excerpt := range lines {
		if err := xml.Unmarshal([]byte(strings.Join(excerpt, "\n")), &stat); err != nil {
			panic(err) // We _could_ skip it, but it's better to halt execution here.
		}
		if stat.Type == 1 {
			csv := fmt.Sprintf("%v;%v", stat.Info.Designation.BrandTypeName, stat.Info.Designation.Model.Name)
			parsed <- csv
			proc++
		}
	}
	fmt.Printf("XML-worker %d finished after processing %d excerpts\n", id, proc)
	done <- id
}