You should loop on awaitTermination ExecutorService threads; // … // Tell threads to finish off. threads.shutdown(); // Wait for everything to finish. while (!threads.awaitTermination(10, TimeUnit.SECONDS)) { log.info(“Awaiting completion of threads.”); }
As the why, I don’t know either. But I can imagine. The amount of resources of a computer is limited. Not all resources can be handled concurrently either. If multiple processes concurrently load files, they will be loaded slower than if they were being loaded sequentially (at least on a harddisk). A processor also has … Read more
Note: if you are limiting this to “3” just so you don’t overwhelm the machine running your app, I’d make sure this is a problem first. The threadpool is supposed to manage this for you. On the other hand, if you don’t want to overwhelm some other resource, then read on! You can’t manage the … Read more
I believe that threading priority is not controllable in python due to how they are implemented using a global interpreter lock (GIL). Having said that, even if you could give one thread more CPU processing priority, the python implementation that hands around the GIL would not be aware of this as it handed around the … Read more
You can pass your own ThreadFactory to ScheduledThreadPoolExecutor. Your ThreadFactory will create thread and can give it any name you want. Your ThreadFactory can also reuse Executors.defaultThreadFactory(), and only change the name before returning the thread.
We had to build our own job queue system to meet requirements similar to yours ( UI thread must always respond within 33ms, jobs can run from 15-15000ms ), because there really was nothing out there that quite met our needs, let alone was performant. Unfortunately our code is about as proprietary as proprietary gets, … Read more
What you want to do is new your own ExecutorService, probably using ThreadPoolExecutor. ThreadPoolExecutor has a constructor which takes a BlockingQueue and to get a bounded queue you use for example ArrayBlockingQueue properly constructed for bounding. You can also include a RejectedExecutionHandler in order to determine what to do when your queue is full, or … Read more
In your ReentrantReadWriteLock class, try changing self._condition = Condition()
I worked on making something I’d be able to use and I’ve published it on github: it’s unimaginably called threadpool.
The default minimum number of threads is the number of cores your machine has. That’s a good number, it doesn’t generally make sense to run more threads than you have cores. The default maximum number of threads is 250 times the number of cores you have on .NET 2.0 SP1 and up. There is an … Read more