Allocate semaphore of page parallel job on heap.

BUG=

Review URL: https://codereview.chromium.org/1806283002

Cr-Commit-Position: refs/heads/master@{#34924}

src/heap/mark-compact.cc

@@ -3541,16 +3541,14 @@ int NumberOfPointerUpdateTasks(int pages) {
 
 template <PointerDirection direction>
 void UpdatePointersInParallel(Heap* heap) {
-  PageParallelJob<PointerUpdateJobTraits<direction> >* job =
-      new PageParallelJob<PointerUpdateJobTraits<direction> >(
+  PageParallelJob<PointerUpdateJobTraits<direction> > job(
       heap, heap->isolate()->cancelable_task_manager());
   RememberedSet<direction>::IterateMemoryChunks(
-      heap, [job](MemoryChunk* chunk) { job->AddPage(chunk, 0); });
+      heap, [&job](MemoryChunk* chunk) { job.AddPage(chunk, 0); });
   PointersUpdatingVisitor visitor(heap);
-  int num_pages = job->NumberOfPages();
+  int num_pages = job.NumberOfPages();
   int num_tasks = NumberOfPointerUpdateTasks(num_pages);
-  job->Run(num_tasks, [&visitor](int i) { return &visitor; });
-  delete job;
+  job.Run(num_tasks, [&visitor](int i) { return &visitor; });
 }
 
 class ToSpacePointerUpdateJobTraits {

src/heap/page-parallel-job.h

@@ -38,7 +38,8 @@ class PageParallelJob {
         cancelable_task_manager_(cancelable_task_manager),
         items_(nullptr),
         num_items_(0),
-        pending_tasks_(0) {}
+        num_tasks_(0),
+        pending_tasks_(new base::Semaphore(0)) {}
 
   ~PageParallelJob() {
     Item* item = items_;
@@ -47,6 +48,7 @@ class PageParallelJob {
       delete item;
       item = next;
     }
+    delete pending_tasks_;
   }
 
   void AddPage(MemoryChunk* chunk, typename JobTraits::PerPageData data) {
@@ -81,7 +83,7 @@ class PageParallelJob {
         start_index -= num_items_;
       }
       Task* task = new Task(heap_, items_, num_items_, start_index,
-                            &pending_tasks_, per_task_data_callback(i));
+                            pending_tasks_, per_task_data_callback(i));
       task_ids[i] = task->id();
       if (i > 0) {
         V8::GetCurrentPlatform()->CallOnBackgroundThread(
@@ -96,7 +98,7 @@ class PageParallelJob {
     // Wait for background tasks.
     for (int i = 0; i < num_tasks_; i++) {
       if (!cancelable_task_manager_->TryAbort(task_ids[i])) {
-        pending_tasks_.Wait();
+        pending_tasks_->Wait();
       }
     }
     if (JobTraits::NeedSequentialFinalization) {
@@ -176,7 +178,7 @@ class PageParallelJob {
   Item* items_;
   int num_items_;
   int num_tasks_;
-  base::Semaphore pending_tasks_;
+  base::Semaphore* pending_tasks_;
   DISALLOW_COPY_AND_ASSIGN(PageParallelJob);
 };