Add a test for cancelling a consumer from another thread