"...git@developer.sourcefind.cn:tianlh/lightgbm-dcu.git" did not exist on "05754b957921d37bc3a2be25f5afe979c7e2f647"
serial_tree_learner.cpp 22.7 KB
Newer Older
Guolin Ke's avatar
Guolin Ke committed
1
2
3
4
5
6
7
8
9
#include "serial_tree_learner.h"

#include <LightGBM/utils/array_args.h>

#include <algorithm>
#include <vector>

namespace LightGBM {

Guolin Ke's avatar
Guolin Ke committed
10
11
12
13
14
15
16
17
18
#ifdef TIMETAG
std::chrono::duration<double, std::milli> init_train_time;
std::chrono::duration<double, std::milli> init_split_time;
std::chrono::duration<double, std::milli> hist_time;
std::chrono::duration<double, std::milli> find_split_time;
std::chrono::duration<double, std::milli> split_time;
std::chrono::duration<double, std::milli> ordered_bin_time;
#endif // TIMETAG

Guolin Ke's avatar
Guolin Ke committed
19
SerialTreeLearner::SerialTreeLearner(const TreeConfig* tree_config)
Guolin Ke's avatar
Guolin Ke committed
20
  :tree_config_(tree_config) {
Guolin Ke's avatar
Guolin Ke committed
21
  random_ = Random(tree_config_->feature_fraction_seed);
22
23
  #pragma omp parallel
  #pragma omp master
Guolin Ke's avatar
Guolin Ke committed
24
25
26
  {
    num_threads_ = omp_get_num_threads();
  }
Guolin Ke's avatar
Guolin Ke committed
27
28
29
}

SerialTreeLearner::~SerialTreeLearner() {
30
  #ifdef TIMETAG
Guolin Ke's avatar
Guolin Ke committed
31
32
33
34
35
36
  Log::Info("SerialTreeLearner::init_train costs %f", init_train_time * 1e-3);
  Log::Info("SerialTreeLearner::init_split costs %f", init_split_time * 1e-3);
  Log::Info("SerialTreeLearner::hist_build costs %f", hist_time * 1e-3);
  Log::Info("SerialTreeLearner::find_split costs %f", find_split_time * 1e-3);
  Log::Info("SerialTreeLearner::split costs %f", split_time * 1e-3);
  Log::Info("SerialTreeLearner::ordered_bin costs %f", ordered_bin_time * 1e-3);
37
  #endif
Guolin Ke's avatar
Guolin Ke committed
38
39
}

40
void SerialTreeLearner::Init(const Dataset* train_data, bool is_constant_hessian) {
Guolin Ke's avatar
Guolin Ke committed
41
42
43
  train_data_ = train_data;
  num_data_ = train_data_->num_data();
  num_features_ = train_data_->num_features();
44
  is_constant_hessian_ = is_constant_hessian;
45
46
  int max_cache_size = 0;
  // Get the max size of pool
Guolin Ke's avatar
Guolin Ke committed
47
48
  if (tree_config_->histogram_pool_size <= 0) {
    max_cache_size = tree_config_->num_leaves;
49
50
51
  } else {
    size_t total_histogram_size = 0;
    for (int i = 0; i < train_data_->num_features(); ++i) {
Guolin Ke's avatar
Guolin Ke committed
52
      total_histogram_size += sizeof(HistogramBinEntry) * train_data_->FeatureNumBin(i);
53
    }
Guolin Ke's avatar
Guolin Ke committed
54
    max_cache_size = static_cast<int>(tree_config_->histogram_pool_size * 1024 * 1024 / total_histogram_size);
55
56
  }
  // at least need 2 leaves
Guolin Ke's avatar
Guolin Ke committed
57
  max_cache_size = std::max(2, max_cache_size);
Guolin Ke's avatar
Guolin Ke committed
58
  max_cache_size = std::min(max_cache_size, tree_config_->num_leaves);
Guolin Ke's avatar
Guolin Ke committed
59

Guolin Ke's avatar
Guolin Ke committed
60
  histogram_pool_.DynamicChangeSize(train_data_, tree_config_, max_cache_size, tree_config_->num_leaves);
Guolin Ke's avatar
Guolin Ke committed
61
  // push split information for all leaves
Guolin Ke's avatar
Guolin Ke committed
62
  best_split_per_leaf_.resize(tree_config_->num_leaves);
Guolin Ke's avatar
Guolin Ke committed
63

Guolin Ke's avatar
Guolin Ke committed
64
  // get ordered bin
Guolin Ke's avatar
Guolin Ke committed
65
  train_data_->CreateOrderedBins(&ordered_bins_);
Guolin Ke's avatar
Guolin Ke committed
66
67

  // check existing for ordered bin
Guolin Ke's avatar
Guolin Ke committed
68
  for (int i = 0; i < static_cast<int>(ordered_bins_.size()); ++i) {
Guolin Ke's avatar
Guolin Ke committed
69
70
71
72
73
    if (ordered_bins_[i] != nullptr) {
      has_ordered_bin_ = true;
      break;
    }
  }
wxchan's avatar
wxchan committed
74
  // initialize splits for leaf
Guolin Ke's avatar
Guolin Ke committed
75
76
  smaller_leaf_splits_.reset(new LeafSplits(train_data_->num_data()));
  larger_leaf_splits_.reset(new LeafSplits(train_data_->num_data()));
Guolin Ke's avatar
Guolin Ke committed
77
78

  // initialize data partition
Guolin Ke's avatar
Guolin Ke committed
79
  data_partition_.reset(new DataPartition(num_data_, tree_config_->num_leaves));
Guolin Ke's avatar
Guolin Ke committed
80
  is_feature_used_.resize(num_features_);
Guolin Ke's avatar
Guolin Ke committed
81
  // initialize ordered gradients and hessians
Guolin Ke's avatar
Guolin Ke committed
82
83
84
  ordered_gradients_.resize(num_data_);
  ordered_hessians_.resize(num_data_);
  // if has ordered bin, need to allocate a buffer to fast split
Guolin Ke's avatar
Guolin Ke committed
85
  if (has_ordered_bin_) {
Guolin Ke's avatar
Guolin Ke committed
86
    is_data_in_leaf_.resize(num_data_);
87
    std::fill(is_data_in_leaf_.begin(), is_data_in_leaf_.end(), static_cast<char>(0));
Guolin Ke's avatar
Guolin Ke committed
88
    ordered_bin_indices_.clear();
Guolin Ke's avatar
Guolin Ke committed
89
90
    for (int i = 0; i < static_cast<int>(ordered_bins_.size()); i++) {
      if (ordered_bins_[i] != nullptr) {
Guolin Ke's avatar
Guolin Ke committed
91
        ordered_bin_indices_.push_back(i);
Guolin Ke's avatar
Guolin Ke committed
92
93
      }
    }
Guolin Ke's avatar
Guolin Ke committed
94
  }
Guolin Ke's avatar
Guolin Ke committed
95
  Log::Info("Number of data: %d, number of used features: %d", num_data_, num_features_);
Guolin Ke's avatar
Guolin Ke committed
96
97
}

Guolin Ke's avatar
Guolin Ke committed
98
99
100
101
102
103
void SerialTreeLearner::ResetTrainingData(const Dataset* train_data) {
  train_data_ = train_data;
  num_data_ = train_data_->num_data();
  num_features_ = train_data_->num_features();

  // get ordered bin
Guolin Ke's avatar
Guolin Ke committed
104
105
  train_data_->CreateOrderedBins(&ordered_bins_);

Guolin Ke's avatar
Guolin Ke committed
106
107
  has_ordered_bin_ = false;
  // check existing for ordered bin
Guolin Ke's avatar
Guolin Ke committed
108
  for (int i = 0; i < static_cast<int>(ordered_bins_.size()); ++i) {
Guolin Ke's avatar
Guolin Ke committed
109
110
111
112
113
114
115
116
117
118
119
120
121
122
123
124
125
126
127
128
    if (ordered_bins_[i] != nullptr) {
      has_ordered_bin_ = true;
      break;
    }
  }
  // initialize splits for leaf
  smaller_leaf_splits_->ResetNumData(num_data_);
  larger_leaf_splits_->ResetNumData(num_data_);

  // initialize data partition
  data_partition_->ResetNumData(num_data_);

  is_feature_used_.resize(num_features_);

  // initialize ordered gradients and hessians
  ordered_gradients_.resize(num_data_);
  ordered_hessians_.resize(num_data_);
  // if has ordered bin, need to allocate a buffer to fast split
  if (has_ordered_bin_) {
    is_data_in_leaf_.resize(num_data_);
129
    std::fill(is_data_in_leaf_.begin(), is_data_in_leaf_.end(), static_cast<char>(0));
Guolin Ke's avatar
Guolin Ke committed
130
    ordered_bin_indices_.clear();
Guolin Ke's avatar
Guolin Ke committed
131
132
    for (int i = 0; i < static_cast<int>(ordered_bins_.size()); i++) {
      if (ordered_bins_[i] != nullptr) {
Guolin Ke's avatar
Guolin Ke committed
133
        ordered_bin_indices_.push_back(i);
Guolin Ke's avatar
Guolin Ke committed
134
135
      }
    }
Guolin Ke's avatar
Guolin Ke committed
136
137
  }
}
Guolin Ke's avatar
Guolin Ke committed
138

Guolin Ke's avatar
Guolin Ke committed
139
140
141
142
143
144
145
146
147
148
void SerialTreeLearner::ResetConfig(const TreeConfig* tree_config) {
  if (tree_config_->num_leaves != tree_config->num_leaves) {
    tree_config_ = tree_config;
    int max_cache_size = 0;
    // Get the max size of pool
    if (tree_config->histogram_pool_size <= 0) {
      max_cache_size = tree_config_->num_leaves;
    } else {
      size_t total_histogram_size = 0;
      for (int i = 0; i < train_data_->num_features(); ++i) {
Guolin Ke's avatar
Guolin Ke committed
149
        total_histogram_size += sizeof(HistogramBinEntry) * train_data_->FeatureNumBin(i);
Guolin Ke's avatar
Guolin Ke committed
150
151
152
153
154
155
      }
      max_cache_size = static_cast<int>(tree_config_->histogram_pool_size * 1024 * 1024 / total_histogram_size);
    }
    // at least need 2 leaves
    max_cache_size = std::max(2, max_cache_size);
    max_cache_size = std::min(max_cache_size, tree_config_->num_leaves);
Guolin Ke's avatar
Guolin Ke committed
156
    histogram_pool_.DynamicChangeSize(train_data_, tree_config_, max_cache_size, tree_config_->num_leaves);
Guolin Ke's avatar
Guolin Ke committed
157
158
159

    // push split information for all leaves
    best_split_per_leaf_.resize(tree_config_->num_leaves);
160
    data_partition_->ResetLeaves(tree_config_->num_leaves);
Guolin Ke's avatar
Guolin Ke committed
161
162
163
164
  } else {
    tree_config_ = tree_config;
  }

Guolin Ke's avatar
Guolin Ke committed
165
  histogram_pool_.ResetConfig(tree_config_);
Guolin Ke's avatar
Guolin Ke committed
166
167
}

168
Tree* SerialTreeLearner::Train(const score_t* gradients, const score_t *hessians, bool is_constant_hessian) {
Guolin Ke's avatar
Guolin Ke committed
169
170
  gradients_ = gradients;
  hessians_ = hessians;
171
  is_constant_hessian_ = is_constant_hessian;
172
  #ifdef TIMETAG
Guolin Ke's avatar
Guolin Ke committed
173
  auto start_time = std::chrono::steady_clock::now();
174
  #endif
Guolin Ke's avatar
Guolin Ke committed
175
176
  // some initial works before training
  BeforeTrain();
Guolin Ke's avatar
Guolin Ke committed
177

178
  #ifdef TIMETAG
Guolin Ke's avatar
Guolin Ke committed
179
  init_train_time += std::chrono::steady_clock::now() - start_time;
180
  #endif
Guolin Ke's avatar
Guolin Ke committed
181

Guolin Ke's avatar
Guolin Ke committed
182
  auto tree = std::unique_ptr<Tree>(new Tree(tree_config_->num_leaves));
Guolin Ke's avatar
Guolin Ke committed
183
184
  // root leaf
  int left_leaf = 0;
185
  int cur_depth = 1;
Guolin Ke's avatar
Guolin Ke committed
186
187
  // only root leaf can be splitted on first time
  int right_leaf = -1;
Guolin Ke's avatar
Guolin Ke committed
188
  for (int split = 0; split < tree_config_->num_leaves - 1; ++split) {
189
    #ifdef TIMETAG
Guolin Ke's avatar
Guolin Ke committed
190
    start_time = std::chrono::steady_clock::now();
191
    #endif
Guolin Ke's avatar
Guolin Ke committed
192
    // some initial works before finding best split
Guolin Ke's avatar
Guolin Ke committed
193
    if (BeforeFindBestSplit(tree.get(), left_leaf, right_leaf)) {
194
      #ifdef TIMETAG
Guolin Ke's avatar
Guolin Ke committed
195
      init_split_time += std::chrono::steady_clock::now() - start_time;
196
      #endif
Guolin Ke's avatar
Guolin Ke committed
197
198
199
200
201
202
203
204
205
206
207
      // find best threshold for every feature
      FindBestThresholds();
      // find best split from all features
      FindBestSplitsForLeaves();
    }
    // Get a leaf with max split gain
    int best_leaf = static_cast<int>(ArrayArgs<SplitInfo>::ArgMax(best_split_per_leaf_));
    // Get split information for best leaf
    const SplitInfo& best_leaf_SplitInfo = best_split_per_leaf_[best_leaf];
    // cannot split, quit
    if (best_leaf_SplitInfo.gain <= 0.0) {
208
      Log::Info("No further splits with positive gain, best gain: %f", best_leaf_SplitInfo.gain);
Guolin Ke's avatar
Guolin Ke committed
209
210
      break;
    }
211
    #ifdef TIMETAG
Guolin Ke's avatar
Guolin Ke committed
212
    start_time = std::chrono::steady_clock::now();
213
    #endif
Guolin Ke's avatar
Guolin Ke committed
214
    // split tree with best leaf
Guolin Ke's avatar
Guolin Ke committed
215
    Split(tree.get(), best_leaf, &left_leaf, &right_leaf);
216
    #ifdef TIMETAG
Guolin Ke's avatar
Guolin Ke committed
217
    split_time += std::chrono::steady_clock::now() - start_time;
218
    #endif
219
    cur_depth = std::max(cur_depth, tree->leaf_depth(left_leaf));
Guolin Ke's avatar
Guolin Ke committed
220
  }
221
  Log::Info("Trained a tree with leaves=%d and max_depth=%d", tree->num_leaves(), cur_depth);
Guolin Ke's avatar
Guolin Ke committed
222
  return tree.release();
Guolin Ke's avatar
Guolin Ke committed
223
224
}

Guolin Ke's avatar
Guolin Ke committed
225
226
227
Tree* SerialTreeLearner::FitByExistingTree(const Tree* old_tree, const score_t* gradients, const score_t *hessians) const {
  auto tree = std::unique_ptr<Tree>(new Tree(*old_tree));
  CHECK(data_partition_->num_leaves() >= tree->num_leaves());
228
  OMP_INIT_EX();
Guolin Ke's avatar
Guolin Ke committed
229
  #pragma omp parallel for schedule(static)
230
  for (int i = 0; i < tree->num_leaves(); ++i) {
231
    OMP_LOOP_EX_BEGIN();
Guolin Ke's avatar
Guolin Ke committed
232
233
234
235
236
237
238
239
240
241
242
243
244
245
    data_size_t cnt_leaf_data = 0;
    auto tmp_idx = data_partition_->GetIndexOnLeaf(i, &cnt_leaf_data);
    double sum_grad = 0.0f;
    double sum_hess = 0.0f;
    for (data_size_t j = 0; j < cnt_leaf_data; ++j) {
      auto idx = tmp_idx[j];
      sum_grad += gradients[idx];
      sum_hess += hessians[idx];
    }
    // avoid zero hessians.
    if (sum_hess <= 0) sum_hess = kEpsilon;
    double output = FeatureHistogram::CalculateSplittedLeafOutput(sum_grad, sum_hess,
                                                                  tree_config_->lambda_l1, tree_config_->lambda_l2);
    tree->SetLeafOutput(i, output);
246
    OMP_LOOP_EX_END();
Guolin Ke's avatar
Guolin Ke committed
247
  }
248
  OMP_THROW_EX();
Guolin Ke's avatar
Guolin Ke committed
249
250
251
  return tree.release();
}

Guolin Ke's avatar
Guolin Ke committed
252
void SerialTreeLearner::BeforeTrain() {
Guolin Ke's avatar
Guolin Ke committed
253

254
255
  // reset histogram pool
  histogram_pool_.ResetMap();
Guolin Ke's avatar
Guolin Ke committed
256

Guolin Ke's avatar
Guolin Ke committed
257
258
  if (tree_config_->feature_fraction < 1) {
    int used_feature_cnt = static_cast<int>(train_data_->num_total_features()*tree_config_->feature_fraction);
Guolin Ke's avatar
Guolin Ke committed
259
260
261
    // initialize used features
    std::memset(is_feature_used_.data(), 0, sizeof(int8_t) * num_features_);
    // Get used feature at current tree
Guolin Ke's avatar
Guolin Ke committed
262
    auto used_feature_indices = random_.Sample(train_data_->num_total_features(), used_feature_cnt);
Guolin Ke's avatar
Guolin Ke committed
263
264
265
    int omp_loop_size = static_cast<int>(used_feature_indices.size());
    #pragma omp parallel for schedule(static, 512) if (omp_loop_size >= 1024)
    for (int i = 0; i < omp_loop_size; ++i) {
Guolin Ke's avatar
Guolin Ke committed
266
      int inner_feature_index = train_data_->InnerFeatureIndex(used_feature_indices[i]);
267
      if (inner_feature_index < 0) { continue; }
Guolin Ke's avatar
Guolin Ke committed
268
      is_feature_used_[inner_feature_index] = 1;
Guolin Ke's avatar
Guolin Ke committed
269
270
    }
  } else {
Guolin Ke's avatar
Guolin Ke committed
271
    #pragma omp parallel for schedule(static, 512) if (num_features_ >= 1024)
Guolin Ke's avatar
Guolin Ke committed
272
273
274
    for (int i = 0; i < num_features_; ++i) {
      is_feature_used_[i] = 1;
    }
Guolin Ke's avatar
Guolin Ke committed
275
  }
276

Guolin Ke's avatar
Guolin Ke committed
277
278
279
280
  // initialize data partition
  data_partition_->Init();

  // reset the splits for leaves
Guolin Ke's avatar
Guolin Ke committed
281
  for (int i = 0; i < tree_config_->num_leaves; ++i) {
Guolin Ke's avatar
Guolin Ke committed
282
283
284
285
286
287
288
    best_split_per_leaf_[i].Reset();
  }

  // Sumup for root
  if (data_partition_->leaf_count(0) == num_data_) {
    // use all data
    smaller_leaf_splits_->Init(gradients_, hessians_);
Guolin Ke's avatar
Guolin Ke committed
289

Guolin Ke's avatar
Guolin Ke committed
290
291
  } else {
    // use bagging, only use part of data
Guolin Ke's avatar
Guolin Ke committed
292
    smaller_leaf_splits_->Init(0, data_partition_.get(), gradients_, hessians_);
Guolin Ke's avatar
Guolin Ke committed
293
294
295
296
297
298
  }

  larger_leaf_splits_->Init();

  // if has ordered bin, need to initialize the ordered bin
  if (has_ordered_bin_) {
299
    #ifdef TIMETAG
Guolin Ke's avatar
Guolin Ke committed
300
    auto start_time = std::chrono::steady_clock::now();
301
    #endif
Guolin Ke's avatar
Guolin Ke committed
302
303
    if (data_partition_->leaf_count(0) == num_data_) {
      // use all data, pass nullptr
304
305
      OMP_INIT_EX();
      #pragma omp parallel for schedule(static)
Guolin Ke's avatar
Guolin Ke committed
306
      for (int i = 0; i < static_cast<int>(ordered_bin_indices_.size()); ++i) {
307
        OMP_LOOP_EX_BEGIN();
Guolin Ke's avatar
Guolin Ke committed
308
        ordered_bins_[ordered_bin_indices_[i]]->Init(nullptr, tree_config_->num_leaves);
309
        OMP_LOOP_EX_END();
Guolin Ke's avatar
Guolin Ke committed
310
      }
311
      OMP_THROW_EX();
Guolin Ke's avatar
Guolin Ke committed
312
313
314
315
316
317
318
    } else {
      // bagging, only use part of data

      // mark used data
      const data_size_t* indices = data_partition_->indices();
      data_size_t begin = data_partition_->leaf_begin(0);
      data_size_t end = begin + data_partition_->leaf_count(0);
Guolin Ke's avatar
Guolin Ke committed
319
320
      data_size_t loop_size = end - begin;
      #pragma omp parallel for schedule(static, 512) if(loop_size >= 1024)
Guolin Ke's avatar
Guolin Ke committed
321
322
323
      for (data_size_t i = begin; i < end; ++i) {
        is_data_in_leaf_[indices[i]] = 1;
      }
324
      OMP_INIT_EX();
Guolin Ke's avatar
Guolin Ke committed
325
      // initialize ordered bin
326
      #pragma omp parallel for schedule(static)
Guolin Ke's avatar
Guolin Ke committed
327
      for (int i = 0; i < static_cast<int>(ordered_bin_indices_.size()); ++i) {
328
        OMP_LOOP_EX_BEGIN();
Guolin Ke's avatar
Guolin Ke committed
329
        ordered_bins_[ordered_bin_indices_[i]]->Init(is_data_in_leaf_.data(), tree_config_->num_leaves);
330
        OMP_LOOP_EX_END();
Guolin Ke's avatar
Guolin Ke committed
331
      }
332
      OMP_THROW_EX();
Guolin Ke's avatar
Guolin Ke committed
333
      #pragma omp parallel for schedule(static, 512) if(loop_size >= 1024)
Guolin Ke's avatar
Guolin Ke committed
334
335
336
      for (data_size_t i = begin; i < end; ++i) {
        is_data_in_leaf_[indices[i]] = 0;
      }
Guolin Ke's avatar
Guolin Ke committed
337
    }
338
    #ifdef TIMETAG
Guolin Ke's avatar
Guolin Ke committed
339
    ordered_bin_time += std::chrono::steady_clock::now() - start_time;
340
    #endif
Guolin Ke's avatar
Guolin Ke committed
341
342
343
  }
}

Guolin Ke's avatar
Guolin Ke committed
344
bool SerialTreeLearner::BeforeFindBestSplit(const Tree* tree, int left_leaf, int right_leaf) {
Guolin Ke's avatar
Guolin Ke committed
345
  // check depth of current leaf
Guolin Ke's avatar
Guolin Ke committed
346
  if (tree_config_->max_depth > 0) {
Guolin Ke's avatar
Guolin Ke committed
347
    // only need to check left leaf, since right leaf is in same level of left leaf
Guolin Ke's avatar
Guolin Ke committed
348
    if (tree->leaf_depth(left_leaf) >= tree_config_->max_depth) {
Guolin Ke's avatar
Guolin Ke committed
349
350
351
352
353
354
355
      best_split_per_leaf_[left_leaf].gain = kMinScore;
      if (right_leaf >= 0) {
        best_split_per_leaf_[right_leaf].gain = kMinScore;
      }
      return false;
    }
  }
Guolin Ke's avatar
Guolin Ke committed
356
357
358
  data_size_t num_data_in_left_child = GetGlobalDataCountInLeaf(left_leaf);
  data_size_t num_data_in_right_child = GetGlobalDataCountInLeaf(right_leaf);
  // no enough data to continue
Guolin Ke's avatar
Guolin Ke committed
359
  if (num_data_in_right_child < static_cast<data_size_t>(tree_config_->min_data_in_leaf * 2)
Guolin Ke's avatar
Guolin Ke committed
360
      && num_data_in_left_child < static_cast<data_size_t>(tree_config_->min_data_in_leaf * 2)) {
Guolin Ke's avatar
Guolin Ke committed
361
362
363
364
365
366
    best_split_per_leaf_[left_leaf].gain = kMinScore;
    if (right_leaf >= 0) {
      best_split_per_leaf_[right_leaf].gain = kMinScore;
    }
    return false;
  }
367
  parent_leaf_histogram_array_ = nullptr;
Guolin Ke's avatar
Guolin Ke committed
368
369
  // only have root
  if (right_leaf < 0) {
370
    histogram_pool_.Get(left_leaf, &smaller_leaf_histogram_array_);
Guolin Ke's avatar
Guolin Ke committed
371
372
    larger_leaf_histogram_array_ = nullptr;
  } else if (num_data_in_left_child < num_data_in_right_child) {
Hui Xue's avatar
Hui Xue committed
373
    // put parent(left) leaf's histograms into larger leaf's histograms
374
375
376
    if (histogram_pool_.Get(left_leaf, &larger_leaf_histogram_array_)) { parent_leaf_histogram_array_ = larger_leaf_histogram_array_; }
    histogram_pool_.Move(left_leaf, right_leaf);
    histogram_pool_.Get(left_leaf, &smaller_leaf_histogram_array_);
Guolin Ke's avatar
Guolin Ke committed
377
  } else {
Hui Xue's avatar
Hui Xue committed
378
    // put parent(left) leaf's histograms to larger leaf's histograms
379
380
    if (histogram_pool_.Get(left_leaf, &larger_leaf_histogram_array_)) { parent_leaf_histogram_array_ = larger_leaf_histogram_array_; }
    histogram_pool_.Get(right_leaf, &smaller_leaf_histogram_array_);
Guolin Ke's avatar
Guolin Ke committed
381
382
383
  }
  // split for the ordered bin
  if (has_ordered_bin_ && right_leaf >= 0) {
384
    #ifdef TIMETAG
Guolin Ke's avatar
Guolin Ke committed
385
    auto start_time = std::chrono::steady_clock::now();
386
    #endif
Guolin Ke's avatar
Guolin Ke committed
387
388
    // mark data that at left-leaf
    const data_size_t* indices = data_partition_->indices();
Guolin Ke's avatar
Guolin Ke committed
389
390
391
    const auto left_cnt = data_partition_->leaf_count(left_leaf);
    const auto right_cnt = data_partition_->leaf_count(right_leaf);
    char mark = 1;
Guolin Ke's avatar
Guolin Ke committed
392
    data_size_t begin = data_partition_->leaf_begin(left_leaf);
Guolin Ke's avatar
Guolin Ke committed
393
    data_size_t end = begin + left_cnt;
Guolin Ke's avatar
Guolin Ke committed
394
    data_size_t loop_size = end - begin;
Guolin Ke's avatar
Guolin Ke committed
395
396
397
398
399
    if (left_cnt > right_cnt) {
      begin = data_partition_->leaf_begin(right_leaf);
      end = begin + right_cnt;
      mark = 0;
    }
Guolin Ke's avatar
Guolin Ke committed
400
    #pragma omp parallel for schedule(static, 512) if(loop_size >= 1024)
Guolin Ke's avatar
Guolin Ke committed
401
402
403
    for (data_size_t i = begin; i < end; ++i) {
      is_data_in_leaf_[indices[i]] = 1;
    }
404
    OMP_INIT_EX();
Guolin Ke's avatar
Guolin Ke committed
405
    // split the ordered bin
406
    #pragma omp parallel for schedule(static)
Guolin Ke's avatar
Guolin Ke committed
407
    for (int i = 0; i < static_cast<int>(ordered_bin_indices_.size()); ++i) {
408
      OMP_LOOP_EX_BEGIN();
Guolin Ke's avatar
Guolin Ke committed
409
      ordered_bins_[ordered_bin_indices_[i]]->Split(left_leaf, right_leaf, is_data_in_leaf_.data(), mark);
410
      OMP_LOOP_EX_END();
Guolin Ke's avatar
Guolin Ke committed
411
    }
412
    OMP_THROW_EX();
Guolin Ke's avatar
Guolin Ke committed
413
    #pragma omp parallel for schedule(static, 512) if(loop_size >= 1024)
Guolin Ke's avatar
Guolin Ke committed
414
415
416
    for (data_size_t i = begin; i < end; ++i) {
      is_data_in_leaf_[indices[i]] = 0;
    }
417
    #ifdef TIMETAG
Guolin Ke's avatar
Guolin Ke committed
418
    ordered_bin_time += std::chrono::steady_clock::now() - start_time;
419
    #endif
Guolin Ke's avatar
Guolin Ke committed
420
421
422
423
  }
  return true;
}

424
425
void SerialTreeLearner::ConstructHistograms(const std::vector<int8_t>& is_feature_used, bool use_subtract) {
#ifdef TIMETAG
Guolin Ke's avatar
Guolin Ke committed
426
  auto start_time = std::chrono::steady_clock::now();
427
#endif
Guolin Ke's avatar
Guolin Ke committed
428
429
430
  // construct smaller leaf
  HistogramBinEntry* ptr_smaller_leaf_hist_data = smaller_leaf_histogram_array_[0].RawData() - 1;
  train_data_->ConstructHistograms(is_feature_used,
Guolin Ke's avatar
Guolin Ke committed
431
432
433
                                   smaller_leaf_splits_->data_indices(), smaller_leaf_splits_->num_data_in_leaf(),
                                   smaller_leaf_splits_->LeafIndex(),
                                   ordered_bins_, gradients_, hessians_,
434
                                   ordered_gradients_.data(), ordered_hessians_.data(), is_constant_hessian_,
Guolin Ke's avatar
Guolin Ke committed
435
                                   ptr_smaller_leaf_hist_data);
Guolin Ke's avatar
Guolin Ke committed
436
437
438
439
440

  if (larger_leaf_histogram_array_ != nullptr && !use_subtract) {
    // construct larger leaf
    HistogramBinEntry* ptr_larger_leaf_hist_data = larger_leaf_histogram_array_[0].RawData() - 1;
    train_data_->ConstructHistograms(is_feature_used,
Guolin Ke's avatar
Guolin Ke committed
441
442
443
                                     larger_leaf_splits_->data_indices(), larger_leaf_splits_->num_data_in_leaf(),
                                     larger_leaf_splits_->LeafIndex(),
                                     ordered_bins_, gradients_, hessians_,
444
                                     ordered_gradients_.data(), ordered_hessians_.data(), is_constant_hessian_,
Guolin Ke's avatar
Guolin Ke committed
445
                                     ptr_larger_leaf_hist_data);
Guolin Ke's avatar
Guolin Ke committed
446
  }
447
#ifdef TIMETAG
Guolin Ke's avatar
Guolin Ke committed
448
  hist_time += std::chrono::steady_clock::now() - start_time;
449
450
451
452
453
#endif
}

void SerialTreeLearner::FindBestThresholds() {
  std::vector<int8_t> is_feature_used(num_features_, 0);
Guolin Ke's avatar
Guolin Ke committed
454
  #pragma omp parallel for schedule(static,1024) if (num_features_ >= 2048)
455
456
457
458
459
460
461
462
463
464
465
466
467
468
469
  for (int feature_index = 0; feature_index < num_features_; ++feature_index) {
    if (!is_feature_used_[feature_index]) continue;
    if (parent_leaf_histogram_array_ != nullptr
        && !parent_leaf_histogram_array_[feature_index].is_splittable()) {
      smaller_leaf_histogram_array_[feature_index].set_is_splittable(false);
      continue;
    }
    is_feature_used[feature_index] = 1;
  }

  bool use_subtract = true;
  if (parent_leaf_histogram_array_ == nullptr) {
    use_subtract = false;
  }
  ConstructHistograms(is_feature_used, use_subtract);
470
  #ifdef TIMETAG
471
  auto start_time = std::chrono::steady_clock::now();
472
  #endif
Guolin Ke's avatar
Guolin Ke committed
473
474
  std::vector<SplitInfo> smaller_best(num_threads_);
  std::vector<SplitInfo> larger_best(num_threads_);
475
  OMP_INIT_EX();
Guolin Ke's avatar
Guolin Ke committed
476
  // find splits
477
  #pragma omp parallel for schedule(static)
Guolin Ke's avatar
Guolin Ke committed
478
  for (int feature_index = 0; feature_index < num_features_; ++feature_index) {
479
    OMP_LOOP_EX_BEGIN();
Guolin Ke's avatar
Guolin Ke committed
480
481
482
    if (!is_feature_used[feature_index]) { continue; }
    const int tid = omp_get_thread_num();
    SplitInfo smaller_split;
Guolin Ke's avatar
Guolin Ke committed
483
484
485
486
    train_data_->FixHistogram(feature_index,
                              smaller_leaf_splits_->sum_gradients(), smaller_leaf_splits_->sum_hessians(),
                              smaller_leaf_splits_->num_data_in_leaf(),
                              smaller_leaf_histogram_array_[feature_index].RawData());
Guolin Ke's avatar
Guolin Ke committed
487

Guolin Ke's avatar
Guolin Ke committed
488
489
490
491
    smaller_leaf_histogram_array_[feature_index].FindBestThreshold(
      smaller_leaf_splits_->sum_gradients(),
      smaller_leaf_splits_->sum_hessians(),
      smaller_leaf_splits_->num_data_in_leaf(),
Guolin Ke's avatar
Guolin Ke committed
492
493
494
      &smaller_split);
    if (smaller_split.gain > smaller_best[tid].gain) {
      smaller_best[tid] = smaller_split;
Guolin Ke's avatar
Guolin Ke committed
495
      smaller_best[tid].feature = train_data_->RealFeatureIndex(feature_index);
Guolin Ke's avatar
Guolin Ke committed
496
    }
Guolin Ke's avatar
Guolin Ke committed
497
    // only has root leaf
Guolin Ke's avatar
Guolin Ke committed
498
    if (larger_leaf_splits_ == nullptr || larger_leaf_splits_->LeafIndex() < 0) { continue; }
Guolin Ke's avatar
Guolin Ke committed
499

Guolin Ke's avatar
Guolin Ke committed
500
    if (use_subtract) {
501
502
      larger_leaf_histogram_array_[feature_index].Subtract(smaller_leaf_histogram_array_[feature_index]);
    } else {
Guolin Ke's avatar
Guolin Ke committed
503
      train_data_->FixHistogram(feature_index, larger_leaf_splits_->sum_gradients(), larger_leaf_splits_->sum_hessians(),
Guolin Ke's avatar
Guolin Ke committed
504
505
                                larger_leaf_splits_->num_data_in_leaf(),
                                larger_leaf_histogram_array_[feature_index].RawData());
506
    }
Guolin Ke's avatar
Guolin Ke committed
507
    SplitInfo larger_split;
Guolin Ke's avatar
Guolin Ke committed
508
    // find best threshold for larger child
Guolin Ke's avatar
Guolin Ke committed
509
510
511
512
    larger_leaf_histogram_array_[feature_index].FindBestThreshold(
      larger_leaf_splits_->sum_gradients(),
      larger_leaf_splits_->sum_hessians(),
      larger_leaf_splits_->num_data_in_leaf(),
Guolin Ke's avatar
Guolin Ke committed
513
514
515
      &larger_split);
    if (larger_split.gain > larger_best[tid].gain) {
      larger_best[tid] = larger_split;
Guolin Ke's avatar
Guolin Ke committed
516
      larger_best[tid].feature = train_data_->RealFeatureIndex(feature_index);
Guolin Ke's avatar
Guolin Ke committed
517
    }
518
    OMP_LOOP_EX_END();
Guolin Ke's avatar
Guolin Ke committed
519
  }
520
  OMP_THROW_EX();
Guolin Ke's avatar
Guolin Ke committed
521
522
523
524
525
526
527
528
529
530

  auto smaller_best_idx = ArrayArgs<SplitInfo>::ArgMax(smaller_best);
  int leaf = smaller_leaf_splits_->LeafIndex();
  best_split_per_leaf_[leaf] = smaller_best[smaller_best_idx];

  if (larger_leaf_splits_ != nullptr && larger_leaf_splits_->LeafIndex() >= 0) {
    leaf = larger_leaf_splits_->LeafIndex();
    auto larger_best_idx = ArrayArgs<SplitInfo>::ArgMax(larger_best);
    best_split_per_leaf_[leaf] = larger_best[larger_best_idx];
  }
531
  #ifdef TIMETAG
Guolin Ke's avatar
Guolin Ke committed
532
  find_split_time += std::chrono::steady_clock::now() - start_time;
533
  #endif
Guolin Ke's avatar
Guolin Ke committed
534
535
536
537
}

void SerialTreeLearner::FindBestSplitsForLeaves() {

Guolin Ke's avatar
Guolin Ke committed
538
539
540
541
542
}


void SerialTreeLearner::Split(Tree* tree, int best_Leaf, int* left_leaf, int* right_leaf) {
  const SplitInfo& best_split_info = best_split_per_leaf_[best_Leaf];
Guolin Ke's avatar
Guolin Ke committed
543
  const int inner_feature_index = train_data_->InnerFeatureIndex(best_split_info.feature);
Guolin Ke's avatar
Guolin Ke committed
544
545
546
  // left = parent
  *left_leaf = best_Leaf;
  // split tree, will return right leaf
Guolin Ke's avatar
Guolin Ke committed
547
548
549
550
551
552
553
554
555
556
557
  *right_leaf = tree->Split(best_Leaf,
                            inner_feature_index,
                            train_data_->FeatureBinMapper(inner_feature_index)->bin_type(),
                            best_split_info.threshold,
                            best_split_info.feature,
                            train_data_->RealThreshold(inner_feature_index, best_split_info.threshold),
                            static_cast<double>(best_split_info.left_output),
                            static_cast<double>(best_split_info.right_output),
                            static_cast<data_size_t>(best_split_info.left_count),
                            static_cast<data_size_t>(best_split_info.right_count),
                            static_cast<double>(best_split_info.gain));
Guolin Ke's avatar
Guolin Ke committed
558
  // split data partition
Guolin Ke's avatar
Guolin Ke committed
559
  data_partition_->Split(best_Leaf, train_data_, inner_feature_index,
Guolin Ke's avatar
Guolin Ke committed
560
561
562
563
                         best_split_info.threshold, *right_leaf);

  // init the leaves that used on next iteration
  if (best_split_info.left_count < best_split_info.right_count) {
Guolin Ke's avatar
Guolin Ke committed
564
    smaller_leaf_splits_->Init(*left_leaf, data_partition_.get(),
Guolin Ke's avatar
Guolin Ke committed
565
566
                               best_split_info.left_sum_gradient,
                               best_split_info.left_sum_hessian);
Guolin Ke's avatar
Guolin Ke committed
567
    larger_leaf_splits_->Init(*right_leaf, data_partition_.get(),
Guolin Ke's avatar
Guolin Ke committed
568
569
                              best_split_info.right_sum_gradient,
                              best_split_info.right_sum_hessian);
Guolin Ke's avatar
Guolin Ke committed
570
  } else {
Guolin Ke's avatar
Guolin Ke committed
571
572
    smaller_leaf_splits_->Init(*right_leaf, data_partition_.get(), best_split_info.right_sum_gradient, best_split_info.right_sum_hessian);
    larger_leaf_splits_->Init(*left_leaf, data_partition_.get(), best_split_info.left_sum_gradient, best_split_info.left_sum_hessian);
Guolin Ke's avatar
Guolin Ke committed
573
574
575
576
  }
}

}  // namespace LightGBM