mirror of
https://github.com/OpenSpace/OpenSpace.git
synced 2026-02-16 09:19:21 -06:00
5575f17b46
Saving GDAL dataset values upon initialization of dataset to avoid calling GDAL functions afterwards since it can be done concurrently. Not done for the data reading since some (not all) GDAL dataset drivers support concurrent reading. The WMS driver does not support concurrent reading, which is why we only use one worker thread per AsyncTileDataReader. Perhaps something for the future if GDAL will ensure thread saefty. Protecting GdalRawTileDataReader with mutex lock when initializing. Make sure read only functions in RawTileDataReader are const. Protecting ConcurrentJobManager with mutex lock when pushing and popping to finished jobs.
76 lines
3.3 KiB
C++
76 lines
3.3 KiB
C++
/*****************************************************************************************
|
|
* *
|
|
* OpenSpace *
|
|
* *
|
|
* Copyright (c) 2014-2017 *
|
|
* *
|
|
* Permission is hereby granted, free of charge, to any person obtaining a copy of this *
|
|
* software and associated documentation files (the "Software"), to deal in the Software *
|
|
* without restriction, including without limitation the rights to use, copy, modify, *
|
|
* merge, publish, distribute, sublicense, and/or sell copies of the Software, and to *
|
|
* permit persons to whom the Software is furnished to do so, subject to the following *
|
|
* conditions: *
|
|
* *
|
|
* The above copyright notice and this permission notice shall be included in all copies *
|
|
* or substantial portions of the Software. *
|
|
* *
|
|
* THE SOFTWARE IS PROVIDED "AS IS", WITHOUT WARRANTY OF ANY KIND, EXPRESS OR IMPLIED, *
|
|
* INCLUDING BUT NOT LIMITED TO THE WARRANTIES OF MERCHANTABILITY, FITNESS FOR A *
|
|
* PARTICULAR PURPOSE AND NONINFRINGEMENT. IN NO EVENT SHALL THE AUTHORS OR COPYRIGHT *
|
|
* HOLDERS BE LIABLE FOR ANY CLAIM, DAMAGES OR OTHER LIABILITY, WHETHER IN AN ACTION OF *
|
|
* CONTRACT, TORT OR OTHERWISE, ARISING FROM, OUT OF OR IN CONNECTION WITH THE SOFTWARE *
|
|
* OR THE USE OR OTHER DEALINGS IN THE SOFTWARE. *
|
|
****************************************************************************************/
|
|
|
|
#ifndef __OPENSPACE_MODULE_GLOBEBROWSING___CONCURRENT_JOB_MANAGER___H__
|
|
#define __OPENSPACE_MODULE_GLOBEBROWSING___CONCURRENT_JOB_MANAGER___H__
|
|
|
|
#include <modules/globebrowsing/other/concurrentqueue.h>
|
|
#include <modules/globebrowsing/other/threadpool.h>
|
|
|
|
#include <mutex>
|
|
|
|
namespace openspace {
|
|
namespace globebrowsing {
|
|
|
|
// Templated abstract base class representing a job to be done.
|
|
// Client code derive from this class and implement the virtual execute() method
|
|
template<typename P>
|
|
struct Job {
|
|
Job();
|
|
virtual ~Job();
|
|
|
|
virtual void execute() = 0;
|
|
virtual std::shared_ptr<P> product() = 0;
|
|
};
|
|
|
|
/*
|
|
* Templated Concurrent Job Manager
|
|
* This class is used execute specific jobs on one (1) parallell thread
|
|
*/
|
|
template<typename P>
|
|
class ConcurrentJobManager {
|
|
public:
|
|
ConcurrentJobManager(std::shared_ptr<ThreadPool> pool);
|
|
|
|
void enqueueJob(std::shared_ptr<Job<P>> job);
|
|
|
|
void clearEnqueuedJobs();
|
|
|
|
std::shared_ptr<Job<P>> popFinishedJob();
|
|
|
|
size_t numFinishedJobs() const;
|
|
|
|
private:
|
|
ConcurrentQueue<std::shared_ptr<Job<P>>> _finishedJobs;
|
|
std::shared_ptr<ThreadPool> threadPool;
|
|
std::mutex _finishedJobsMutex;
|
|
};
|
|
|
|
} // namespace globebrowsing
|
|
} // namespace openspace
|
|
|
|
#include "concurrentjobmanager.inl"
|
|
|
|
#endif // __OPENSPACE_MODULE_GLOBEBROWSING___CONCURRENT_JOB_MANAGER___H__
|