65578e1c |
1 | // Created on: 2015-05-27 |
2 | // Created by: Denis BOGOLEPOV |
3 | // Copyright (c) 2015 OPEN CASCADE SAS |
4 | // |
5 | // This file is part of Open CASCADE Technology software library. |
6 | // |
7 | // This library is free software; you can redistribute it and/or modify it under |
8 | // the terms of the GNU Lesser General Public License version 2.1 as published |
9 | // by the Free Software Foundation, with special exception defined in the file |
10 | // OCCT_LGPL_EXCEPTION.txt. Consult the file LICENSE_LGPL_21.txt included in OCCT |
11 | // distribution for complete text of the license and disclaimer of any warranty. |
12 | // |
13 | // Alternatively, this file may be used under the terms of Open CASCADE |
14 | // commercial license or contractual agreement. |
15 | |
16 | #include <BVH_BuildQueue.hxx> |
17 | |
18 | // ======================================================================= |
19 | // function : Size |
20 | // purpose : Returns current size of BVH build queue |
21 | // ======================================================================= |
22 | Standard_Integer BVH_BuildQueue::Size() |
23 | { |
24 | Standard_Integer aSize; |
25 | |
26 | myMutex.Lock(); |
27 | { |
28 | aSize = myQueue.Size(); |
29 | } |
30 | myMutex.Unlock(); |
31 | |
32 | return aSize; |
33 | } |
34 | |
35 | // ======================================================================= |
36 | // function : Enqueue |
37 | // purpose : Enqueues new work-item onto BVH build queue |
38 | // ======================================================================= |
39 | void BVH_BuildQueue::Enqueue (const Standard_Integer& theWorkItem) |
40 | { |
41 | myMutex.Lock(); |
42 | { |
43 | myQueue.Append (theWorkItem); |
44 | } |
45 | myMutex.Unlock(); |
46 | } |
47 | |
48 | // ======================================================================= |
49 | // function : Fetch |
50 | // purpose : Fetches first work-item from BVH build queue |
51 | // ======================================================================= |
52 | Standard_Integer BVH_BuildQueue::Fetch (Standard_Boolean& wasBusy) |
53 | { |
54 | Standard_Integer aQuery = -1; |
55 | { |
56 | Standard_Mutex::Sentry aSentry (myMutex); |
57 | |
58 | if (!myQueue.IsEmpty()) |
59 | { |
60 | aQuery = myQueue.First(); |
61 | |
62 | myQueue.Remove (1); // remove item from queue |
63 | } |
64 | |
65 | if (aQuery != -1) |
66 | { |
67 | if (!wasBusy) |
68 | { |
69 | ++myNbThreads; |
70 | } |
71 | } |
72 | else if (wasBusy) |
73 | { |
74 | --myNbThreads; |
75 | } |
76 | |
77 | wasBusy = aQuery != -1; |
78 | } |
79 | |
80 | return aQuery; |
81 | } |