parallelise requests

cottand · Dec 18, 2024 · dcf90f4 · dcf90f4
1 parent 1c9c5cc
commit dcf90f4
Showing 1 changed file with 8 additions and 1 deletion.
diff --git a/handler.go b/handler.go
@@ -4,6 +4,7 @@ import (
 	"github.com/cottand/leng/internal/metric"
 	"github.com/cottand/leng/lcache"
 	"github.com/miekg/dns"
+	"golang.org/x/sync/errgroup"
 	"net"
 	"slices"
 	"sync"
@@ -77,12 +78,18 @@ func NewEventLoop(config *Config, blockCache *MemoryBlockCache) *EventLoop {
 }
 
 func (h *EventLoop) do() {
+	errGroup := errgroup.Group{}
+	// arbitrary cap to limit allocation spikes
+	errGroup.SetLimit(100)
 	for {
 		data, ok := <-h.requestChannel
 		if !ok {
 			break
 		}
-		h.doRequest(data.Net, data.w, data.req)
+		errGroup.Go(func() error {
+			h.doRequest(data.Net, data.w, data.req)
+			return nil
+		})
 	}
 }