@@ -42,37 +42,6 @@ using std::vector;
4242using tbb::concurrent_vector;
4343using tbb::queuing_rw_mutex;
4444using tbb::task_group;
45- using tbb::task;
46- using tbb::task_group_context;
47- using tbb::empty_task;
48-
49- using AffinityT = task::affinity_id;
50-
51- template <typename TNode, typename TTurn>
52- class UpdateTask : public task
53- {
54- public:
55- UpdateTask (TNode* node, TTurn* turn) :
56- node_{ node },
57- turn_{ turn }
58- {
59- }
60-
61- virtual task* execute () override
62- {
63- node_->Tick (turn_);
64- return nullptr ;
65- }
66-
67- virtual void note_affinity (AffinityT id)
68- {
69- node_->Affinity = id;
70- }
71-
72- private:
73- TNode* node_;
74- TTurn* turn_;
75- };
7645
7746// /////////////////////////////////////////////////////////////////////////////////////////////////
7847// / SeqNode
@@ -96,8 +65,6 @@ class ParNode : public IReactiveNode
9665 int Level = 0 ;
9766 int NewLevel = 0 ;
9867 atomic<bool > Collected = false ;
99- task* CurrentTask = nullptr ;
100- AffinityT Affinity = 0 ;
10168
10269 NodeVector<ParNode> Successors;
10370};
@@ -170,13 +137,6 @@ class ParEngineBase : public EngineBase<ParNode,TTurn>
170137public:
171138 using DynRequestVectT = concurrent_vector<DynRequestData>;
172139
173- ParEngineBase () :
174- context_{task_group_context::bound, task_group_context::default_traits | task_group_context::concurrent_wait}
175- {
176- rootTask_ = new ( task::allocate_root (context_) ) empty_task;
177- rootTask_->set_ref_count (1 );
178- }
179-
180140 void OnTurnPropagate (TTurn& turn);
181141
182142 void OnDynamicNodeAttach (ParNode& node, ParNode& parent, TTurn& turn);
@@ -188,7 +148,6 @@ class ParEngineBase : public EngineBase<ParNode,TTurn>
188148
189149 virtual void processChildren (ParNode& node, TTurn& turn) override ;
190150
191-
192151 ConcurrentTopoQueue<ParNode> topoQueue_;
193152
194153 DynRequestVectT dynRequests_;
0 commit comments