ActiveMQ CMS:有没有办法不用线程就可以使用它?
ActiveMQ CMS: Is there a way to use it without threading?
我在这里从 Apache 获取示例代码:https://activemq.apache.org/components/cms/example
(特别是生产者部分)并尝试重写它,这样它就不会为生产创建任何线程。相反,在我的程序的主线程中,创建一个生产者对象并设置连接、会话、目标等。然后它使用消息生产者发送消息。这一切都是在单例中完成的,因此我的程序只有一个 Producer 对象,只要它需要将任何消息转储到我的队列之一,就会转到它。这个示例代码似乎为每个线程创建一个生产者,每次都设置它,只是为了发送一条消息,然后删除所有内容。每当您想从您的程序中产生一些东西时,它都会这样做。
当我尝试使用任何给定消息调用消息生成器的发送时,我崩溃了。经过一番挖掘后,我发现在发送调用后,它会尝试锁定互斥锁并进入临界区。我想这是为了穿线?我的代码中根本不使用线程,所以我猜它会因此而崩溃……有谁知道绕过这个的方法吗?我不想使用多线程,我不需要担心两个线程试图同时调用发送或者使用互斥锁试图解决的任何问题。
您不需要为 运行 生产者创建一个线程,但在内部库将使用几个线程,因为这是满足 API 要求所必需的,而且仅仅因为你不使用多线程并不意味着其他人不会,所以互斥锁是一个内部要求。
您可以自由修改示例以仅在应用程序的主线程内创建一个生产者,该示例使用两个线程,因为它同时充当生产者和消费者。
您收到错误的一个可能原因是您没有初始化 ActiveMQ-CPP 库:
activemq::library::ActiveMQCPP::initializeLibrary();
我在这里从 Apache 获取示例代码:https://activemq.apache.org/components/cms/example
(特别是生产者部分)并尝试重写它,这样它就不会为生产创建任何线程。相反,在我的程序的主线程中,创建一个生产者对象并设置连接、会话、目标等。然后它使用消息生产者发送消息。这一切都是在单例中完成的,因此我的程序只有一个 Producer 对象,只要它需要将任何消息转储到我的队列之一,就会转到它。这个示例代码似乎为每个线程创建一个生产者,每次都设置它,只是为了发送一条消息,然后删除所有内容。每当您想从您的程序中产生一些东西时,它都会这样做。
当我尝试使用任何给定消息调用消息生成器的发送时,我崩溃了。经过一番挖掘后,我发现在发送调用后,它会尝试锁定互斥锁并进入临界区。我想这是为了穿线?我的代码中根本不使用线程,所以我猜它会因此而崩溃……有谁知道绕过这个的方法吗?我不想使用多线程,我不需要担心两个线程试图同时调用发送或者使用互斥锁试图解决的任何问题。
您不需要为 运行 生产者创建一个线程,但在内部库将使用几个线程,因为这是满足 API 要求所必需的,而且仅仅因为你不使用多线程并不意味着其他人不会,所以互斥锁是一个内部要求。
您可以自由修改示例以仅在应用程序的主线程内创建一个生产者,该示例使用两个线程,因为它同时充当生产者和消费者。
您收到错误的一个可能原因是您没有初始化 ActiveMQ-CPP 库:
activemq::library::ActiveMQCPP::initializeLibrary();