mirror of
https://github.com/GLEGram/GLEGram-iOS.git
synced 2026-04-24 11:56:18 +02:00
Leeksov
4647310322
Based on Swiftgram 12.5 (Telegram iOS 12.5). All GLEGram features ported and organized in GLEGram/ folder. Features: Ghost Mode, Saved Deleted Messages, Content Protection Bypass, Font Replacement, Fake Profile, Chat Export, Plugin System, and more. See CHANGELOG_12.5.md for full details.
64 lines
2.0 KiB
Plaintext
64 lines
2.0 KiB
Plaintext
//
|
|
// ASDispatch.mm
|
|
// Texture
|
|
//
|
|
// Copyright (c) Pinterest, Inc. All rights reserved.
|
|
// Licensed under Apache 2.0: http://www.apache.org/licenses/LICENSE-2.0
|
|
//
|
|
|
|
#import "ASDispatch.h"
|
|
#import <AsyncDisplayKit/ASConfigurationInternal.h>
|
|
|
|
|
|
// Prefer C atomics in this file because ObjC blocks can't capture C++ atomics well.
|
|
#import <stdatomic.h>
|
|
|
|
/**
|
|
* Like dispatch_apply, but you can set the thread count. 0 means 2*active CPUs.
|
|
*
|
|
* Note: The actual number of threads may be lower than threadCount, if libdispatch
|
|
* decides the system can't handle it. In reality this rarely happens.
|
|
*/
|
|
void ASDispatchApply(size_t iterationCount, dispatch_queue_t queue, NSUInteger threadCount, NS_NOESCAPE void(^work)(size_t i)) {
|
|
if (threadCount == 0) {
|
|
if (ASActivateExperimentalFeature(ASExperimentalDispatchApply)) {
|
|
dispatch_apply(iterationCount, queue, work);
|
|
return;
|
|
}
|
|
threadCount = NSProcessInfo.processInfo.activeProcessorCount * 2;
|
|
}
|
|
dispatch_group_t group = dispatch_group_create();
|
|
__block atomic_size_t counter = ATOMIC_VAR_INIT(0);
|
|
for (NSUInteger t = 0; t < threadCount; t++) {
|
|
dispatch_group_async(group, queue, ^{
|
|
size_t i;
|
|
while ((i = atomic_fetch_add(&counter, 1)) < iterationCount) {
|
|
work(i);
|
|
}
|
|
});
|
|
}
|
|
dispatch_group_wait(group, DISPATCH_TIME_FOREVER);
|
|
};
|
|
|
|
/**
|
|
* Like dispatch_async, but you can set the thread count. 0 means 2*active CPUs.
|
|
*
|
|
* Note: The actual number of threads may be lower than threadCount, if libdispatch
|
|
* decides the system can't handle it. In reality this rarely happens.
|
|
*/
|
|
void ASDispatchAsync(size_t iterationCount, dispatch_queue_t queue, NSUInteger threadCount, NS_NOESCAPE void(^work)(size_t i)) {
|
|
if (threadCount == 0) {
|
|
threadCount = NSProcessInfo.processInfo.activeProcessorCount * 2;
|
|
}
|
|
__block atomic_size_t counter = ATOMIC_VAR_INIT(0);
|
|
for (NSUInteger t = 0; t < threadCount; t++) {
|
|
dispatch_async(queue, ^{
|
|
size_t i;
|
|
while ((i = atomic_fetch_add(&counter, 1)) < iterationCount) {
|
|
work(i);
|
|
}
|
|
});
|
|
}
|
|
};
|
|
|