Page MenuHome
Differential D7475 Diff 23935 tests/gtests/blenlib/BLI_linklist_lockfree_test.cc

Changeset View

Standalone View

View Options

tests/gtests/blenlib/BLI_linklist_lockfree_test.cc

Show First 20 Lines • Show All 57 Lines • ▼ Show 20 Lines
namespace { namespace {
struct IndexedNode { struct IndexedNode {
IndexedNode *next; IndexedNode *next;
int index; int index;
}; };
void concurrent_insert(TaskPool *__restrict pool, void *taskdata, int /*threadid*/) void concurrent_insert(TaskPool *__restrict pool, void *taskdata)
{ {
LockfreeLinkList *list = (LockfreeLinkList *)BLI_task_pool_user_data(pool); LockfreeLinkList *list = (LockfreeLinkList *)BLI_task_pool_user_data(pool);
CHECK_NOTNULL(list); CHECK_NOTNULL(list);
IndexedNode *node = (IndexedNode *)MEM_mallocN(sizeof(IndexedNode), "test node"); IndexedNode *node = (IndexedNode *)MEM_mallocN(sizeof(IndexedNode), "test node");
node->index = POINTER_AS_INT(taskdata); node->index = POINTER_AS_INT(taskdata);
BLI_linklist_lockfree_insert(list, (LockfreeLinkNode *)node); BLI_linklist_lockfree_insert(list, (LockfreeLinkNode *)node);
} }
} // namespace } // namespace
TEST(LockfreeLinkList, InsertMultipleConcurrent) TEST(LockfreeLinkList, InsertMultipleConcurrent)
{ {
static const int num_threads = 512;
static const int num_nodes = 655360; static const int num_nodes = 655360;
/* Initialize list. */ /* Initialize list. */
LockfreeLinkList list; LockfreeLinkList list;
BLI_linklist_lockfree_init(&list); BLI_linklist_lockfree_init(&list);
/* Initialize task scheduler and pool. */ /* Initialize task scheduler and pool. */
TaskScheduler *scheduler = BLI_task_scheduler_create(num_threads); TaskPool *pool = BLI_task_pool_create_suspended(&list, TASK_PRIORITY_HIGH);
TaskPool *pool = BLI_task_pool_create_suspended(scheduler, &list, TASK_PRIORITY_HIGH);
/* Push tasks to the pool. */ /* Push tasks to the pool. */
for (int i = 0; i < num_nodes; ++i) { for (int i = 0; i < num_nodes; ++i) {
BLI_task_pool_push(pool, concurrent_insert, POINTER_FROM_INT(i), false, NULL); BLI_task_pool_push(pool, concurrent_insert, POINTER_FROM_INT(i), false, NULL);
} }
/* Run all the tasks. */ /* Run all the tasks. */
BLI_threaded_malloc_begin(); BLI_threaded_malloc_begin();
BLI_task_pool_work_and_wait(pool); BLI_task_pool_work_and_wait(pool);
BLI_threaded_malloc_end(); BLI_threaded_malloc_end();
Show All 12 LinesTEST(LockfreeLinkList, InsertMultipleConcurrent)
/* Then we make sure node was added. */ /* Then we make sure node was added. */
for (int node_index = 0; node_index < num_nodes; ++node_index) { for (int node_index = 0; node_index < num_nodes; ++node_index) {
EXPECT_TRUE(visited_nodes[node_index]); EXPECT_TRUE(visited_nodes[node_index]);
} }
MEM_freeN(visited_nodes); MEM_freeN(visited_nodes);
/* Cleanup data. */ /* Cleanup data. */
BLI_linklist_lockfree_free(&list, MEM_freeN); BLI_linklist_lockfree_free(&list, MEM_freeN);
BLI_task_pool_free(pool); BLI_task_pool_free(pool);
BLI_task_scheduler_free(scheduler);
} }