19881f8b24
This still has the unwanted side effect off blocking the Map thread waiting for the workers to return (because they hold a reference to the Map thread main loop). Maybe the only way to solve this would be having a I/O thread for dispatching messages. The Request is not bound anymore to the invoker thread because the workers will request for glyphs, but the reply will arrive at the Map thread.
53 lines
1.0 KiB
C++
53 lines
1.0 KiB
C++
#ifndef MBGL_STORAGE_DEFAULT_REQUEST
|
|
#define MBGL_STORAGE_DEFAULT_REQUEST
|
|
|
|
#include <mbgl/storage/resource.hpp>
|
|
|
|
#include <mbgl/util/util.hpp>
|
|
#include <mbgl/util/noncopyable.hpp>
|
|
|
|
#include <mutex>
|
|
#include <thread>
|
|
#include <functional>
|
|
#include <memory>
|
|
|
|
typedef struct uv_async_s uv_async_t;
|
|
typedef struct uv_loop_s uv_loop_t;
|
|
|
|
namespace mbgl {
|
|
|
|
class Response;
|
|
|
|
class Request : private util::noncopyable {
|
|
public:
|
|
using Callback = std::function<void(const Response &)>;
|
|
Request(const Resource &resource, uv_loop_t *loop, Callback callback);
|
|
|
|
public:
|
|
// May be called from any thread.
|
|
void notify(const std::shared_ptr<const Response> &response);
|
|
void destruct();
|
|
|
|
// May be called only from the thread the Request was created in.
|
|
void cancel();
|
|
|
|
private:
|
|
~Request();
|
|
void invoke();
|
|
void notifyCallback();
|
|
|
|
private:
|
|
uv_async_t *async = nullptr;
|
|
struct Canceled;
|
|
std::unique_ptr<Canceled> canceled;
|
|
Callback callback;
|
|
std::shared_ptr<const Response> response;
|
|
|
|
public:
|
|
const Resource resource;
|
|
};
|
|
|
|
}
|
|
|
|
#endif
|