mirror of
https://github.com/status-im/react-native.git
synced 2025-01-15 03:56:03 +00:00
b774820dc2
Reviewed By: javache Differential Revision: D4434052 fbshipit-source-id: ff2743eb7fe5d9cabb860752ca3d92d631a2f02b
48 lines
966 B
Plaintext
48 lines
966 B
Plaintext
/**
|
|
* Copyright (c) 2015-present, Facebook, Inc.
|
|
* All rights reserved.
|
|
*
|
|
* This source code is licensed under the BSD-style license found in the
|
|
* LICENSE file in the root directory of this source tree. An additional grant
|
|
* of patent rights can be found in the PATENTS file in the same directory.
|
|
*/
|
|
|
|
#include "RCTMessageQueue.h"
|
|
|
|
namespace facebook {
|
|
namespace react {
|
|
|
|
RCTMessageQueue::RCTMessageQueue(const std::string &name) {
|
|
m_queue = dispatch_queue_create(name.c_str(), NULL);
|
|
}
|
|
|
|
void RCTMessageQueue::runOnQueue(std::function<void()>&& func) {
|
|
if (m_shutdown) {
|
|
return;
|
|
}
|
|
dispatch_async(m_queue, ^{
|
|
if (!m_shutdown) {
|
|
func();
|
|
}
|
|
});
|
|
}
|
|
|
|
void RCTMessageQueue::runOnQueueSync(std::function<void()>&& func) {
|
|
if (m_shutdown) {
|
|
return;
|
|
}
|
|
dispatch_sync(m_queue, ^{
|
|
if (!m_shutdown) {
|
|
func();
|
|
}
|
|
});
|
|
}
|
|
|
|
void RCTMessageQueue::quitSynchronous() {
|
|
m_shutdown = true;
|
|
dispatch_sync(m_queue, ^{});
|
|
}
|
|
|
|
}
|
|
}
|