add concurrent_http.go

config/config.go

@@ -21,9 +21,6 @@ import (
 	"strings"
 	"time"
 
-	"github.com/opentracing/opentracing-go"
-
-	"github.com/uber/jaeger-client-go"
 	"github.com/uber/jaeger-client-go/internal/baggage/remote"
 	throttler "github.com/uber/jaeger-client-go/internal/throttler/remote"
 	"github.com/uber/jaeger-client-go/rpcmetrics"
@@ -406,7 +403,7 @@ func (rc *ReporterConfig) newTransport() (jaeger.Transport, error) {
 		if rc.User != "" && rc.Password != "" {
 			httpOptions = append(httpOptions, transport.HTTPBasicAuth(rc.User, rc.Password))
 		}
-		return transport.NewHTTPTransport(rc.CollectorEndpoint, httpOptions...), nil
+		return transport.NewConcurrentHttpTransport(transport.NewHTTPTransport(rc.CollectorEndpoint, httpOptions...)), nil
 	default:
 		return jaeger.NewUDPTransport(rc.LocalAgentHostPort, 0)
 	}

transport/concurrent_http.go

@@ -0,0 +1,29 @@
+package transport
+
+import (
+	j "github.com/uber/jaeger-client-go/thrift-gen/jaeger"
+)
+
+type ConcurrentHttpTransport struct {
+	*HTTPTransport
+	pool chan int
+}
+
+func NewConcurrentHttpTransport(httpTransport *HTTPTransport) *ConcurrentHttpTransport {
+	ctp := &ConcurrentHttpTransport{
+		HTTPTransport: httpTransport,
+	}
+	ctp.pool = make(chan int, 100)
+	for i := 0; i < 100; i++ {
+		ctp.pool <- 0
+	}
+	return ctp
+}
+
+func (c *ConcurrentHttpTransport) send(spans []*j.Span) error {
+	<-c.pool
+	defer func() {
+		c.pool <- 0
+	}()
+	return c.HTTPTransport.send(spans)
+}