fix data race

gunli · gunli · commit 139514f86820 · 2025-03-07T15:04:05.000+08:00
diff --git a/pulsar/producer_partition.go b/pulsar/producer_partition.go
@@ -1738,10 +1738,10 @@ func (i *pendingItem) done(err error) {
 		return
 	}
 	i.isDone = true
-	buffersPool.Put(i.buffer)
 	if i.flushCallback != nil {
 		i.flushCallback(err)
 	}
+	buffersPool.Put(i.buffer)
 }
 
 // _setConn sets the internal connection field of this partition producer atomically.

Original file line number	Diff line number	Diff line change
`@@ -1738,10 +1738,10 @@ func (i *pendingItem) done(err error) {`
`1738`	`1738`	`return`
`1739`	`1739`	`}`
`1740`	`1740`	`i.isDone = true`
`1741`		`- buffersPool.Put(i.buffer)`
`1742`	`1741`	`if i.flushCallback != nil {`
`1743`	`1742`	`i.flushCallback(err)`
`1744`	`1743`	`}`
	`1744`	`+ buffersPool.Put(i.buffer)`
`1745`	`1745`	`}`
`1746`	`1746`
`1747`	`1747`	`// _setConn sets the internal connection field of this partition producer atomically.`