in src/producer.cc [32:39]
void Producer_sendAsync(Producer& producer, const Message& msg, SendCallback callback) {
Py_BEGIN_ALLOW_THREADS producer.sendAsync(msg, callback);
Py_END_ALLOW_THREADS
if (PyErr_CheckSignals() == -1) {
PyErr_SetInterrupt();
}
}