multithreaded rendering

mapblockrenderer/renderer_test.go

@@ -15,6 +15,27 @@ import (
   "time"
 )
 
+type JobData struct {
+  pos1, pos2 coords.MapBlockCoords
+  x,z int
+}
+
+func worker(r *MapBlockRenderer, jobs <-chan JobData) {
+  for d := range jobs {
+    img, _ := r.Render(d.pos1, d.pos2)
+
+    if img != nil {
+      f, _ := os.Create(fmt.Sprintf("../output/image_%d_%d.png", d.x, d.z))
+      start := time.Now()
+      png.Encode(f, img)
+      f.Close()
+      t := time.Now()
+      elapsed := t.Sub(start)
+      log.WithFields(logrus.Fields{"elapsed":elapsed}).Debug("Encoding completed")
+    }
+  }
+}
+
 func TestSimpleRender(t *testing.T) {
   logrus.SetLevel(logrus.InfoLevel)
 
@@ -45,21 +66,24 @@ func TestSimpleRender(t *testing.T) {
   r := NewMapBlockRenderer(cache, c)
   os.Mkdir("../output", 0755)
 
-  for x := -3; x < 3; x++ {
+  jobs := make(chan JobData, 100)
-    for z := -3; z < 3; z++ {
+  go worker(&r, jobs)
-      img, _ := r.Render(coords.NewMapBlockCoords(x, 10, z), coords.NewMapBlockCoords(x, -1, z))
+  go worker(&r, jobs)
+  go worker(&r, jobs)
 
-      if img != nil {
+  from := -1
-        f, _ := os.Create(fmt.Sprintf("../output/image_%d_%d.png", x, z))
+  to := 1
-        start := time.Now()
-        png.Encode(f, img)
-        f.Close()
-        t := time.Now()
-        elapsed := t.Sub(start)
-        log.WithFields(logrus.Fields{"elapsed":elapsed}).Debug("Encoding completed")
 
-      }
+  for x := from; x < to; x++ {
+    for z := from; z < to; z++ {
+      pos1 := coords.NewMapBlockCoords(x, 10, z)
+      pos2 := coords.NewMapBlockCoords(x, -1, z)
+
+      jobs <- JobData{pos1:pos1, pos2:pos2, x:x, z:z}
     }
   }
 
+  close(jobs)
+
+
 }