-
Notifications
You must be signed in to change notification settings - Fork 6.8k
Conversation
@@ -52,7 +52,7 @@ class ConnectionWrapper(object): | |||
NDArray via shared memory.""" | |||
|
|||
def __init__(self, conn): | |||
self.conn = conn | |||
self._conn = conn |
There was a problem hiding this comment.
Choose a reason for hiding this comment
The reason will be displayed to describe this comment to others. Learn more.
?
There was a problem hiding this comment.
Choose a reason for hiding this comment
The reason will be displayed to describe this comment to others. Learn more.
getattr is dead cycle call. change the name same time.
@@ -91,11 +95,18 @@ class CPUSharedStorageManager final : public StorageManager { | |||
private: | |||
static constexpr size_t alignment_ = 16; | |||
|
|||
std::mutex mutex_; | |||
std::recursive_mutex mutex_; |
There was a problem hiding this comment.
Choose a reason for hiding this comment
The reason will be displayed to describe this comment to others. Learn more.
is this slower?
std::unordered_map<void*, Storage::Handle> pool_; | ||
#ifdef _WIN32 | ||
std::unordered_map<void*, Storage::Handle> is_free_; | ||
std::unordered_map<void*, HANDLE> map_handle_map_; |
There was a problem hiding this comment.
Choose a reason for hiding this comment
The reason will be displayed to describe this comment to others. Learn more.
why do you need two more maps?
There was a problem hiding this comment.
Choose a reason for hiding this comment
The reason will be displayed to describe this comment to others. Learn more.
only use pool_ has the problem of repeated release.
Could you rebase? |
* add shared storage in windows * fix * lint * fix * fix * fix * fix process.h
* add shared storage in windows * fix * lint * fix * fix * fix * fix process.h
Description
Checklist
Essentials
make lint
)