This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
import glob | |
import os | |
import rosbag | |
import concurrent.futures | |
import multiprocessing | |
import time | |
USE_MULTIPROCESSING = True # Flag to switch between concurrent/multiprocessing libraries | |
NUM_WORKERS = 8 # Number of worker threads/processes |