Make WebTaskRunner ThreadSafeRefCounted

third_party/WebKit/Source/core/html/parser/HTMLParserScheduler.cpp

 /*
  * Copyright (C) 2010 Google, Inc. All Rights Reserved.
  *
  * Redistribution and use in source and binary forms, with or without
  * modification, are permitted provided that the following conditions
  * are met:
  * 1. Redistributions of source code must retain the above copyright
  *    notice, this list of conditions and the following disclaimer.
  * 2. Redistributions in binary form must reproduce the above copyright
  *    notice, this list of conditions and the following disclaimer in the
@@ skipping 38 matching lines @@
 SpeculationsPumpSession::~SpeculationsPumpSession() {}
 
 inline double SpeculationsPumpSession::elapsedTime() const {
   return currentTime() - m_startTime;
 }
 
 void SpeculationsPumpSession::addedElementTokens(size_t count) {
   m_processedElementTokens += count;
 }
 
-HTMLParserScheduler::HTMLParserScheduler(HTMLDocumentParser* parser,
-                                         WebTaskRunner* loadingTaskRunner)
+HTMLParserScheduler::HTMLParserScheduler(
+    HTMLDocumentParser* parser,
+    RefPtr<WebTaskRunner> loadingTaskRunner)
     : m_parser(parser),
-      m_loadingTaskRunner(loadingTaskRunner->clone()),
+      m_loadingTaskRunner(std::move(loadingTaskRunner)),
       m_isSuspendedWithActiveTimer(false) {}
 
 HTMLParserScheduler::~HTMLParserScheduler() {}
 
 DEFINE_TRACE(HTMLParserScheduler) {
   visitor->trace(m_parser);
 }
 
 bool HTMLParserScheduler::isScheduledForResume() const {
   return m_isSuspendedWithActiveTimer ||
@@ skipping 70 matching lines @@
 void HTMLParserScheduler::forceResumeAfterYield() {
   DCHECK(!m_cancellableContinueParseTaskHandle.isActive());
   m_isSuspendedWithActiveTimer = true;
 }
 
 void HTMLParserScheduler::continueParsing() {
   m_parser->resumeParsingAfterYield();
 }
 
 }  // namespace blink