本文整理汇总了C++中TaskPool类的典型用法代码示例。如果您正苦于以下问题：C++ TaskPool类的具体用法？C++ TaskPool怎么用？C++ TaskPool使用的例子？那么恭喜您, 这里精选的类代码示例或许可以为您提供帮助。
在下文中一共展示了TaskPool类的20个代码示例，这些例子默认根据受欢迎程度排序。您可以为喜欢或者感觉有用的代码点赞，您的评价将有助于我们的系统推荐出更棒的C++代码示例。
示例1: device_update
void ImageManager::device_update(Device *device,
Scene *scene,
Progress& progress)
{
if(!need_update) {
return;
}
TaskPool pool;
for(int type = 0; type < IMAGE_DATA_NUM_TYPES; type++) {
for(size_t slot = 0; slot < images[type].size(); slot++) {
if(!images[type][slot])
continue;
if(images[type][slot]->users == 0) {
device_free_image(device, (ImageDataType)type, slot);
}
else if(images[type][slot]->need_load) {
if(!osl_texture_system || images[type][slot]->builtin_data)
pool.push(function_bind(&ImageManager::device_load_image,
this,
device,
scene,
(ImageDataType)type,
slot,
&progress));
}
}
}
pool.wait_work();
need_update = false;
}
开发者ID:mgschwan，项目名称:blensor，代码行数:34，代码来源:image.cpp
示例2: TEST
TEST(util_task, basic)
{
TaskScheduler::init(0);
TaskPool pool;
for (int i = 0; i < 100; ++i) {
pool.push(function_bind(task_run));
}
TaskPool::Summary summary;
pool.wait_work(&summary);
TaskScheduler::exit();
EXPECT_EQ(summary.num_tasks_handled, 100);
}
开发者ID:dfelinto，项目名称:blender，代码行数:12，代码来源:util_task_test.cpp
示例3: CreateTask
TaskHandle CreateTask(TaskPool& pool,
TaskHandle* parentTask,
const DELEGATE_CBK<void, const Task&>& threadedFunction)
{
Task* freeTask = pool.createTask(parentTask ? parentTask->_task : nullptr,
threadedFunction);
return TaskHandle(freeTask, &pool);
}
开发者ID:IonutCava，项目名称:trunk，代码行数:8，代码来源:TaskPool.cpp
示例4: parallel_for
void parallel_for(TaskPool& pool,
const DELEGATE_CBK<void, const Task&, U32, U32>& cbk,
U32 count,
U32 partitionSize,
TaskPriority priority,
bool noWait,
bool useCurrentThread)
{
if (count > 0) {
const U32 crtPartitionSize = std::min(partitionSize, count);
const U32 partitionCount = count / crtPartitionSize;
const U32 remainder = count % crtPartitionSize;
U32 adjustedCount = partitionCount;
if (useCurrentThread) {
adjustedCount -= 1;
}
std::atomic_uint jobCount = adjustedCount + (remainder > 0 ? 1 : 0);
for (U32 i = 0; i < adjustedCount; ++i) {
const U32 start = i * crtPartitionSize;
const U32 end = start + crtPartitionSize;
CreateTask(pool,
nullptr,
[&cbk, &jobCount, start, end](const Task& parentTask) {
cbk(parentTask, start, end);
jobCount.fetch_sub(1);
}).startTask(priority);
}
if (remainder > 0) {
CreateTask(pool,
nullptr,
[&cbk, &jobCount, count, remainder](const Task& parentTask) {
cbk(parentTask, count - remainder, count);
jobCount.fetch_sub(1);
}).startTask(priority);
}
if (useCurrentThread) {
TaskHandle threadTask = CreateTask(pool, [](const Task& parentTask) {ACKNOWLEDGE_UNUSED(parentTask); });
const U32 start = adjustedCount * crtPartitionSize;
const U32 end = start + crtPartitionSize;
cbk(*threadTask._task, start, end);
}
if (!noWait) {
while (jobCount.load() > 0) {
pool.threadWaiting();
}
}
}
}
开发者ID:IonutCava，项目名称:trunk，代码行数:53，代码来源:TaskPool.cpp
示例5: device_update
void ImageManager::device_update(Device *device, DeviceScene *dscene, Progress& progress)
{
if(!need_update)
return;
TaskPool pool;
for(size_t slot = 0; slot < images.size(); slot++) {
if(!images[slot])
continue;
if(images[slot]->users == 0) {
device_free_image(device, dscene, slot);
}
else if(images[slot]->need_load) {
if(!osl_texture_system)
pool.push(function_bind(&ImageManager::device_load_image, this, device, dscene, slot, &progress));
}
}
for(size_t slot = 0; slot < float_images.size(); slot++) {
if(!float_images[slot])
continue;
if(float_images[slot]->users == 0) {
device_free_image(device, dscene, slot + TEX_IMAGE_FLOAT_START);
}
else if(float_images[slot]->need_load) {
if(!osl_texture_system)
pool.push(function_bind(&ImageManager::device_load_image, this, device, dscene, slot + TEX_IMAGE_FLOAT_START, &progress));
}
}
pool.wait_work();
if(pack_images)
device_pack_images(device, dscene, progress);
need_update = false;
}
开发者ID:vanangamudi，项目名称:blender-main，代码行数:40，代码来源:image.cpp
示例6: WaitForAllTasks
void WaitForAllTasks(TaskPool& pool, bool yield, bool flushCallbacks, bool foceClear) {
pool.waitForAllTasks(yield, flushCallbacks, foceClear);
}
开发者ID:IonutCava，项目名称:trunk，代码行数:3，代码来源:TaskPool.cpp
示例7: thread_shader
void thread_shader(DeviceTask& task)
{
KernelGlobals kg = kernel_globals;
#ifdef WITH_OSL
OSLShader::thread_init(&kg, &kernel_globals, &osl_globals);
#endif
#ifdef WITH_OPTIMIZED_KERNEL
if(system_cpu_support_optimized()) {
for(int x = task.shader_x; x < task.shader_x + task.shader_w; x++) {
kernel_cpu_optimized_shader(&kg, (uint4*)task.shader_input, (float4*)task.shader_output, task.shader_eval_type, x);
if(task_pool.cancelled())
break;
}
}
else
#endif
{
for(int x = task.shader_x; x < task.shader_x + task.shader_w; x++) {
kernel_cpu_shader(&kg, (uint4*)task.shader_input, (float4*)task.shader_output, task.shader_eval_type, x);
if(task_pool.cancelled())
break;
}
}
#ifdef WITH_OSL
OSLShader::thread_free(&kg);
#endif
}
开发者ID:danielmarg，项目名称:blender-main，代码行数:32，代码来源:device_cpu.cpp
示例8: thread_shader
void thread_shader(DeviceTask &task)
{
KernelGlobals kg = kernel_globals;
#ifdef WITH_OSL
OSLShader::thread_init(&kg, &kernel_globals, &osl_globals);
#endif
for (int sample = 0; sample < task.num_samples; sample++) {
for (int x = task.shader_x; x < task.shader_x + task.shader_w; x++)
shader_kernel()(&kg,
(uint4 *)task.shader_input,
(float4 *)task.shader_output,
task.shader_eval_type,
task.shader_filter,
x,
task.offset,
sample);
if (task.get_cancel() || task_pool.canceled())
break;
task.update_progress(NULL);
}
#ifdef WITH_OSL
OSLShader::thread_free(&kg);
#endif
}
开发者ID:sobotka，项目名称:blender，代码行数:28，代码来源:device_cpu.cpp
示例9: task_add
void task_add(DeviceTask& task)
{
/* split task into smaller ones */
list<DeviceTask> tasks;
task.split(tasks, TaskScheduler::num_threads());
foreach(DeviceTask& task, tasks)
task_pool.push(new CPUDeviceTask(this, task));
}
开发者ID:paleajed，项目名称:EWOCprojects-Blender，代码行数:9，代码来源:device_cpu.cpp
示例10: task_add
void task_add(DeviceTask& task)
{
/* split task into smaller ones, more than number of threads for uneven
* workloads where some parts of the image render slower than others */
list<DeviceTask> tasks;
task.split(tasks, TaskScheduler::num_threads());
foreach(DeviceTask& task, tasks)
task_pool.push(new CPUDeviceTask(this, task));
}
开发者ID:JasonWilkins，项目名称:blender-wayland，代码行数:10，代码来源:device_cpu.cpp
示例11: thread_shader
void thread_shader(DeviceTask& task)
{
KernelGlobals kg = kernel_globals;
#ifdef WITH_OSL
OSLShader::thread_init(&kg, &kernel_globals, &osl_globals);
#endif
void(*shader_kernel)(KernelGlobals*, uint4*, float4*, int, int, int, int);
#ifdef WITH_CYCLES_OPTIMIZED_KERNEL_AVX2
if(system_cpu_support_avx2())
shader_kernel = kernel_cpu_avx2_shader;
else
#endif
#ifdef WITH_CYCLES_OPTIMIZED_KERNEL_AVX
if(system_cpu_support_avx())
shader_kernel = kernel_cpu_avx_shader;
else
#endif
#ifdef WITH_CYCLES_OPTIMIZED_KERNEL_SSE41
if(system_cpu_support_sse41())
shader_kernel = kernel_cpu_sse41_shader;
else
#endif
#ifdef WITH_CYCLES_OPTIMIZED_KERNEL_SSE3
if(system_cpu_support_sse3())
shader_kernel = kernel_cpu_sse3_shader;
else
#endif
#ifdef WITH_CYCLES_OPTIMIZED_KERNEL_SSE2
if(system_cpu_support_sse2())
shader_kernel = kernel_cpu_sse2_shader;
else
#endif
shader_kernel = kernel_cpu_shader;
for(int sample = 0; sample < task.num_samples; sample++) {
for(int x = task.shader_x; x < task.shader_x + task.shader_w; x++)
shader_kernel(&kg, (uint4*)task.shader_input, (float4*)task.shader_output,
task.shader_eval_type, x, task.offset, sample);
if(task.get_cancel() || task_pool.canceled())
break;
task.update_progress(NULL);
}
#ifdef WITH_OSL
OSLShader::thread_free(&kg);
#endif
}
开发者ID:Andrewson3D，项目名称:blender-for-vray，代码行数:52，代码来源:device_cpu.cpp
示例12: task_add
void task_add(DeviceTask& task)
{
/* split task into smaller ones */
list<DeviceTask> tasks;
if(task.type == DeviceTask::SHADER)
task.split(tasks, TaskScheduler::num_threads(), 256);
else
task.split(tasks, TaskScheduler::num_threads());
foreach(DeviceTask& task, tasks)
task_pool.push(new CPUDeviceTask(this, task));
}
开发者ID:ChunHungLiu，项目名称:blender，代码行数:13，代码来源:device_cpu.cpp
示例13: rewrapCache
void rewrapCache()
{
if(cache.isEmpty()) return;
if(isRewrapping())
{
// Cancel an existing rewrap.
cancelRewrap++;
}
// Start a rewrapping task that goes through all the existing entries,
// starting from the latest entry.
rewrapPool.start(new RewrapTask(this, cache.size() - 1, contentWidth()));
}
开发者ID:roman313，项目名称:Doomsday-Engine，代码行数:14，代码来源:logwidget.cpp
示例14: task_add
void task_add(DeviceTask &task)
{
/* Load texture info. */
load_texture_info();
/* split task into smaller ones */
list<DeviceTask> tasks;
if (task.type == DeviceTask::SHADER)
task.split(tasks, info.cpu_threads, 256);
else
task.split(tasks, info.cpu_threads);
foreach (DeviceTask &task, tasks)
task_pool.push(new CPUDeviceTask(this, task));
}
开发者ID:sobotka，项目名称:blender，代码行数:16，代码来源:device_cpu.cpp
示例15: path_trace
void path_trace(DeviceTask &task, RenderTile &tile, KernelGlobals *kg)
{
const bool use_coverage = kernel_data.film.cryptomatte_passes & CRYPT_ACCURATE;
scoped_timer timer(&tile.buffers->render_time);
Coverage coverage(kg, tile);
if (use_coverage) {
coverage.init_path_trace();
}
float *render_buffer = (float *)tile.buffer;
int start_sample = tile.start_sample;
int end_sample = tile.start_sample + tile.num_samples;
/* Needed for Embree. */
SIMD_SET_FLUSH_TO_ZERO;
for (int sample = start_sample; sample < end_sample; sample++) {
if (task.get_cancel() || task_pool.canceled()) {
if (task.need_finish_queue == false)
break;
}
for (int y = tile.y; y < tile.y + tile.h; y++) {
for (int x = tile.x; x < tile.x + tile.w; x++) {
if (use_coverage) {
coverage.init_pixel(x, y);
}
path_trace_kernel()(kg, render_buffer, sample, x, y, tile.offset, tile.stride);
}
}
tile.sample = sample + 1;
task.update_progress(&tile, tile.w * tile.h);
}
if (use_coverage) {
coverage.finalize();
}
}
开发者ID:sobotka，项目名称:blender，代码行数:41，代码来源:device_cpu.cpp
示例16:
~OpenCLDevice()
{
task_pool.stop();
if(null_mem)
clReleaseMemObject(CL_MEM_PTR(null_mem));
map<string, device_vector<uchar>*>::iterator mt;
for(mt = const_mem_map.begin(); mt != const_mem_map.end(); mt++) {
mem_free(*(mt->second));
delete mt->second;
}
if(ckPathTraceKernel)
clReleaseKernel(ckPathTraceKernel);
if(ckFilmConvertKernel)
clReleaseKernel(ckFilmConvertKernel);
if(cpProgram)
clReleaseProgram(cpProgram);
if(cqCommandQueue)
clReleaseCommandQueue(cqCommandQueue);
if(cxContext)
clReleaseContext(cxContext);
}
开发者ID:scorpion81，项目名称:blender-voro，代码行数:24，代码来源:device_opencl.cpp
示例17:
~CPUDevice()
{
task_pool.stop();
}
开发者ID:paleajed，项目名称:EWOCprojects-Blender，代码行数:4，代码来源:device_cpu.cpp
示例18: task_cancel
void task_cancel()
{
task_pool.cancel();
}
开发者ID:paleajed，项目名称:EWOCprojects-Blender，代码行数:4，代码来源:device_cpu.cpp
示例19: task_wait
void task_wait()
{
task_pool.wait_work();
}
开发者ID:paleajed，项目名称:EWOCprojects-Blender，代码行数:4，代码来源:device_cpu.cpp
示例20:
~CPUDevice()
{
task_pool.stop();
texture_info.free();
}
开发者ID:sobotka，项目名称:blender，代码行数:5，代码来源:device_cpu.cpp
注：本文中的TaskPool类示例由纯净天空整理自Github/MSDocs等源码及文档管理平台，相关代码片段筛选自各路编程大神贡献的开源项目，源码版权归原作者所有，传播和使用请参考对应项目的License；未经允许，请勿转载。 |
客服电话
APP下载
官方微信
请发表评论