buffer some channels

site/watch.go

@@ -27,8 +27,8 @@ func (e FilesEvent) String() string {
 func (s *Site) WatchFiles() (<-chan FilesEvent, error) {
 	var (
 		sourceDir = s.SourceDir()
-		events    = make(chan string)
-		debounced = debounce(time.Second, events)
+		filenames = make(chan string, 100)
+		debounced = debounce(time.Second, filenames)
 		results   = make(chan FilesEvent)
 	)
 	watcher, err := fsnotify.NewWatcher()
@@ -39,7 +39,7 @@ func (s *Site) WatchFiles() (<-chan FilesEvent, error) {
 		for {
 			select {
 			case event := <-watcher.Events:
-				events <- event.Name
+				filenames <- event.Name
 			case err := <-watcher.Errors:
 				fmt.Fprintln(os.Stderr, "error:", err)
 			}

site/write.go

@@ -6,6 +6,7 @@ import (
 	"io"
 	"os"
 	"path/filepath"
+	"runtime"
 	"strings"
 
 	"github.com/osteele/gojekyll/pages"
@@ -16,7 +17,7 @@ import (
 // WriteFiles writes output files.
 // It attends to options.dry_run.
 func (s *Site) WriteFiles() (count int, err error) {
-	errs := make(chan error)
+	errs := make(chan error, runtime.NumCPU())
 	for _, p := range s.OutputDocs() {
 		count++
 		go func(d pages.Document) {