One Thread Per Subscriber

asked 2016-02-16 01:59:21 -0500

solb22
25 ●3 ●5 ●8

updated 2016-02-16 02:00:21 -0500

I'm using roscpp, and I am programmatically creating a bunch of subscriber callbacks (using ShapeShifter). Each callback is not computationally expensive, but I'm measuring the difference between the published time in the header, and the received time. As such, the first line of my callback defines the received time.

So having a single threaded model isn't great, because one subscriber callback will block another callback, and increase its lag time.

Ideally I'd like to create one thread per subscriber. I can't use a custom callback queue, because these are not called by ros::spin.

So what is the most idiomatic way to have each subscriber run on its own thread?

answered 2016-02-16 02:49:40 -0500

gvdhoorn
86574 ●283 ●1432 ●1054 http://cor.tudelft.nl/

updated 2016-02-16 02:52:17 -0500

Does ros::MultiThreadedSpinner not already do what you describe? See roscpp - Overview - Callbacks and Spinning.

Edit: you might also be interested in the topic statistics support added in Indigo. See Topics - Topic statistics and rosprofiler.

edit flag offensive delete link

Comments

Hm, I guess it does, is there a limit to the number of thread I can pass to that? The documentation made it look like I was limited to the number of cores on my machine. I was actually looking at ros::AsyncSpinner