Does MQObject.Put() support goroutine concurrency?

[lavamini]

Hi, I want to use "github.com/panjf2000/ants/v2" goroutine pool. Should I share MQObject in ants pool or create a single MQObject in every goroutine? Does MQObject.Put() support goroutine concurrency? Thanks very much.

[ibmmqmet]

Have you tried it? What happened?

There should be no reason why you can't use the same MQObject in multiple goroutines. However, MQ restricts operations so that only one can actually be executing at a time.

If two MQPUTs for the same object (indeed even different objects on the same hConn) are attempted at the same time, then the second will either be blocked until the first ends or it will return an error. That is controlled by the MQCNO_HANDLE_SHARE_BLOCK or _NO_BLOCK flag at connection time, The default in this library is MQCNO_HANDLE_SHARE_NO_BLOCK so you'd see the error on simultaneous execution unless you set the flag explicitly.