Left: | ||
Right: |
OLD | NEW |
---|---|
1 /* | 1 /* |
2 * This file is part of Adblock Plus <https://adblockplus.org/>, | 2 * This file is part of Adblock Plus <https://adblockplus.org/>, |
3 * Copyright (C) 2006-present eyeo GmbH | 3 * Copyright (C) 2006-present eyeo GmbH |
4 * | 4 * |
5 * Adblock Plus is free software: you can redistribute it and/or modify | 5 * Adblock Plus is free software: you can redistribute it and/or modify |
6 * it under the terms of the GNU General Public License version 3 as | 6 * it under the terms of the GNU General Public License version 3 as |
7 * published by the Free Software Foundation. | 7 * published by the Free Software Foundation. |
8 * | 8 * |
9 * Adblock Plus is distributed in the hope that it will be useful, | 9 * Adblock Plus is distributed in the hope that it will be useful, |
10 * but WITHOUT ANY WARRANTY; without even the implied warranty of | 10 * but WITHOUT ANY WARRANTY; without even the implied warranty of |
(...skipping 44 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... | |
55 * Creates a new thread in which the `call` will be executed. | 55 * Creates a new thread in which the `call` will be executed. |
56 * @param call is a function object which is called within a worker thread, | 56 * @param call is a function object which is called within a worker thread, |
57 * different from the caller thread. There is no effect if `call` is | 57 * different from the caller thread. There is no effect if `call` is |
58 * empty. | 58 * empty. |
59 */ | 59 */ |
60 void Dispatch(const std::function<void()>& call); | 60 void Dispatch(const std::function<void()>& call); |
61 private: | 61 private: |
62 SyncThreads threads; | 62 SyncThreads threads; |
63 ActiveObject threadCollector; | 63 ActiveObject threadCollector; |
64 }; | 64 }; |
65 | |
66 /** | |
67 * This class provides the same interface as `AsyncExecutor` but allows in | |
68 * a thread-safe manner invalidate internally held implementation of | |
69 * `AsyncExecutor`. Any subsequent calls of `Dispatch` have no effect, | |
70 * what allows to safely share `AsyncExecutor` but control it's operability. | |
71 */ | |
72 class OptionalAsyncExecutor | |
73 { | |
74 public: | |
75 /** | |
76 * Contructor. | |
77 * | |
78 * Initially constructed the class behaves as `AsyncExecutor`. | |
79 */ | |
80 OptionalAsyncExecutor() | |
81 : executor(new AsyncExecutor()) | |
82 { | |
83 } | |
84 | |
85 /** | |
86 * Creates a new thread in which the `call` will be executed. | |
87 * @param call is a function object which is called within a worker thread, | |
88 * different from the caller thread. There is no effect if `call` is | |
89 * empty or if `Invalidate` had been already called. | |
90 */ | |
91 void Dispatch(const std::function<void()>& call) | |
92 { | |
93 std::lock_guard<std::mutex> lock(asyncExecutorMutex); | |
94 if (!executor) | |
95 return; | |
96 executor->Dispatch(call); | |
97 } | |
98 | |
99 /** | |
100 * Destroyes internally held `AsyncExecutor`, any subsequent calls of | |
hub
2018/03/19 11:48:43
nit: "Destroys"
sergei
2018/03/19 12:34:26
Done.
| |
101 * `Dispatch` have no effect. | |
102 */ | |
103 void Invalidate() | |
104 { | |
105 std::unique_ptr<AsyncExecutor> tmp; | |
106 { | |
107 std::lock_guard<std::mutex> lock(asyncExecutorMutex); | |
108 tmp = move(executor); | |
109 } | |
110 } | |
111 private: | |
112 std::mutex asyncExecutorMutex; | |
113 std::unique_ptr<AsyncExecutor> executor; | |
114 }; | |
65 } | 115 } |
OLD | NEW |