1 /* 2 * Copyright 2015 Google Inc. 3 * 4 * Use of this source code is governed by a BSD-style license that can be 5 * found in the LICENSE file. 6 */ 7 8 #include "src/core/SkSharedMutex.h" 9 #include "src/core/SkTaskGroup.h" 10 11 #include "tests/Test.h" 12 DEF_TEST(SkSharedMutexBasic,r)13DEF_TEST(SkSharedMutexBasic, r) { 14 SkSharedMutex sm; 15 sm.acquire(); 16 sm.assertHeld(); 17 sm.release(); 18 sm.acquireShared(); 19 sm.assertHeldShared(); 20 sm.releaseShared(); 21 } 22 DEF_TEST(SkSharedMutexMultiThreaded,r)23DEF_TEST(SkSharedMutexMultiThreaded, r) { 24 SkSharedMutex sm; 25 static const int kSharedSize = 10; 26 int shared[kSharedSize]; 27 int value = 0; 28 for (int i = 0; i < kSharedSize; ++i) { 29 shared[i] = 0; 30 } 31 SkTaskGroup().batch(8, [&](int threadIndex) { 32 if (threadIndex % 4 != 0) { 33 for (int c = 0; c < 100000; ++c) { 34 sm.acquireShared(); 35 sm.assertHeldShared(); 36 int v = shared[0]; 37 for (int i = 1; i < kSharedSize; ++i) { 38 REPORTER_ASSERT(r, v == shared[i]); 39 } 40 sm.releaseShared(); 41 } 42 } else { 43 for (int c = 0; c < 100000; ++c) { 44 sm.acquire(); 45 sm.assertHeld(); 46 value += 1; 47 for (int i = 0; i < kSharedSize; ++i) { 48 shared[i] = value; 49 } 50 sm.release(); 51 } 52 } 53 }); 54 } 55