0

我在这里从 Apache 获取示例代码:https ://activemq.apache.org/components/cms/example

(特别是生产者部分)并尝试重写它,因此它不会创建任何用于生产的线程。相反,在我的程序的主线程中,创建一个生产者对象并设置连接、会话、目的地等。然后它使用消息生产者发送消息。这一切都是在一个单例中完成的,因此我的程序只有一个 Producer 对象,并且只要它需要将任何消息转储到我的队列之一就可以访问它。这个示例代码似乎为每个线程创建了一个生产者,每次都设置它,只是为了发送一条消息,然后删除所有内容。每次你想从你的程序中产生一些东西时,它都会这样做。

当我尝试使用任何给定消息对消息生产者调用 send 时,我正在崩溃。经过一番挖掘后,我发现在发送调用之后它会尝试锁定互斥锁并进入临界区。我想这是为了线程?我的代码中根本不使用线程,所以我猜它会因此而崩溃......有谁知道绕过这个的方法?我不想使用多个线程,我不需要担心两个线程试图同时调用 send 或者使用互斥锁试图解决的任何问题。

4

1 回答 1

1

您不需要创建线程来运行生产者,但在内部库将使用几个线程,因为这是满足 API 要求所必需的,并且仅仅因为您不使用多个线程并不意味着其他人不会,所以互斥锁是内部要求。

您可以随意修改该示例以仅在应用程序的主线程内创建一个生产者,该示例使用两个线程,因为它既充当生产者又充当消费者。

您收到错误的一个可能原因是您没有初始化 ActiveMQ-CPP 库:

activemq::library::ActiveMQCPP::initializeLibrary();
于 2021-06-08T17:07:02.487 回答