{"id":412,"date":"2022-11-25T14:13:29","date_gmt":"2022-11-25T06:13:29","guid":{"rendered":"https:\/\/iichen.cn\/?p=412"},"modified":"2022-11-25T14:13:29","modified_gmt":"2022-11-25T06:13:29","slug":"kotlin-%e5%8d%8f%e7%a8%8b%e5%bc%82%e5%b8%b8%e5%88%86%e6%9e%90%e5%a4%84%e7%90%86%e4%b8%80","status":"publish","type":"post","link":"https:\/\/iichen.cn\/?p=412","title":{"rendered":"kotlin-\u534f\u7a0b\u5f02\u5e38\u5206\u6790\u5904\u7406(\u4e00)"},"content":{"rendered":"<h5>1.CoroutineScheduler<\/h5>\n<div class=\"mind no-emojify\" style=\"width:100%;overflow:auto\"><canvas><\/canvas><\/p>\n<div class=\"mindTxt\" style=\"display:none\"><script type=\"text\/javascript\">document.write(\"-CoroutineScheduler\\n    -DispatchedTask\\n\");<\/script><\/div>\n<\/div>\n<pre><code class=\"language-java line-numbers\">    internal class CoroutineScheduler(...) : Executor, Closeable {\n        @JvmField\n        val globalBlockingQueue = GlobalQueue()\n        fun runSafely(task: Task) {\n            try {\n                task.run()\n            } catch (e: Throwable) {\n                val thread = Thread.currentThread()\n                thread.uncaughtExceptionHandler.uncaughtException(thread, e)\n            } finally {\n                unTrackTask()\n            }\n        }\n\n         \/\/\u7701\u7565... \n        internal inner class Worker private constructor() : Thread() {\n            override fun run() = runWorker()\n\n            private fun runWorker() {\n                var rescanned = false\n                while (!isTerminated &amp;&amp; state != WorkerState.TERMINATED) {\n                    val task = findTask(mayHaveLocalTasks)\n                    if (task != null) {\n                        rescanned = false\n                        minDelayUntilStealableTaskNs = 0L\n                        executeTask(task)\n                        continue\n                    } else {\n                        mayHaveLocalTasks = false\n                    }\n                    \/\/\u7701\u7565...\n                    continue\n                }\n            }\n\n            private fun executeTask(task: Task) {\n                \/\/\u7701\u7565...\n                runSafely(task)\n               \/\/\u7701\u7565...\n            }\n\n            fun findTask(scanLocalQueue: Boolean): Task? {\n                if (tryAcquireCpuPermit()) return findAnyTask(scanLocalQueue)\n                val task = if (scanLocalQueue) {\n                    localQueue.poll() ?: globalBlockingQueue.removeFirstOrNull()\n                } else {\n                    globalBlockingQueue.removeFirstOrNull()\n                }\n                return task ?: trySteal(blockingOnly = true)\n            }\n\n            \/\/\u7701\u7565... \n        }\n        \/\/\u7701\u7565... \n    }\n<\/code><\/pre>\n<blockquote><p>\n  <strong>CoroutineScheduler\u7ee7\u627fExecutor\uff0cWorker\u7ee7\u627fThread\uff0c\u540c\u65f6runWorker\u4e5f\u662f\u7ebf\u7a0b\u7684run\u65b9\u6cd5\u3002\u5728runWorker\u6267\u884c\u4e86executeTask(task)\uff0c\u63a5\u7740\u5728executeTask\u8c03\u7528\u4e2drunSafely(task)\uff0c\u7136\u540e\u6211\u4eec\u770b\u5230runSafely\u4f7f\u7528try..catch\u4e86\u8fd9\u4e2atask\u4efb\u52a1\u7684\u6267\u884c\uff0c\u6700\u540e\u5728catch\u4e2d\u629b\u51fa\u4e86\u672a\u6355\u83b7\u7684\u5f02\u5e38<\/strong>\n<\/p><\/blockquote>\n<pre><code class=\"language-java line-numbers\">internal abstract class DispatchedTask&lt;in T&gt;(\n    @JvmField public var resumeMode: Int\n) : SchedulerTask() {\n \/\/\u7701\u7565...\n internal open fun getExceptionalResult(state: Any?): Throwable? =\n        (state as? CompletedExceptionally)?.cause\n\n public final override fun run() {\n      assert { resumeMode != MODE_UNINITIALIZED }\n      val taskContext = this.taskContext\n      var fatalException: Throwable? = null\n    try {\n            \/\/ continuation \u901a\u8fc7  DispatchedContinuation\u83b7\u53d6\n            val delegate = delegate as DispatchedContinuation&lt;T&gt;\n            val continuation = delegate.continuation\n            withContinuationContext(continuation, delegate.countOrElement) {\n                val context = continuation.context\n                val state = takeState()\n                val exception = getExceptionalResult(state)\n                val job = if (exception == null &amp;&amp; resumeMode.isCancellableMode) context[Job] else null\n                if (job != null &amp;&amp; !job.isActive) {\n                    val cause = job.getCancellationException()\n                    cancelCompletedResult(state, cause)\n                    continuation.resumeWithStackTrace(cause)\n                } else {\n                    if (exception != null) {\n                        \/\/ \u5b9e\u9645\u8c03\u7528\u7684\u662f resumeWith\u51fd\u6570\u7684\u6269\u5c55\uff0c\u53ea\u80fd\u8fd4\u56de Result.Fail\n                        continuation.resumeWithException(exception)\n                    } else {\n                        continuation.resume(getSuccessfulResult(state))\n                    }\n                }\n            }\n        } catch (e: Throwable) {\n            fatalException = e\n        } finally {\n            val result = runCatching { taskContext.afterTask() }\n            \/\/ kotlinx.coroutines\u5e93\u76f8\u5173\u7684\u5f02\u5e38\uff0c\u5982\u4e0a\u4e0b\u6587\u3001\u7f16\u8bd1\u5668\u7b49\n            handleFatalException(fatalException, result.exceptionOrNull())\n        }\n    }\n}\n<\/code><\/pre>\n<h5>2.BaseContinuationImpl<\/h5>\n<div class=\"mind no-emojify\" style=\"width:100%;overflow:auto\"><canvas><\/canvas><\/p>\n<div class=\"mindTxt\" style=\"display:none\"><script type=\"text\/javascript\">document.write(\"-DispatchedTask\\n    -BaseContinuationImpl\\n\");<\/script><\/div>\n<\/div>\n<pre><code class=\"language-java line-numbers\">internal abstract class BaseContinuationImpl(\n    public val completion: Continuation&lt;Any?&gt;?\n) : Continuation&lt;Any?&gt;, CoroutineStackFrame, Serializable {\n     public final override fun resumeWith(result: Result&lt;Any?&gt;) {\n        var current = this\n        var param = result\n        while (true) {\n            probeCoroutineResumed(current)\n            with(current) {\n                val completion = completion!! \/\/ fail fast when trying to resume continuation \n                val outcome: Result&lt;Any?&gt; =\n                    try {\n                        val outcome = invokeSuspend(param)\n                        if (outcome === COROUTINE_SUSPENDED) return\n                        Result.success(outcome)\n                    } catch (exception: Throwable) {\n                        Result.failure(exception)\n                    }\n                releaseIntercepted() \/\/ this state machine instance is terminating\n                if (completion is BaseContinuationImpl) {\n                    current = completion\n                    param = outcome\n                } else {\n                    completion.resumeWith(outcome)\n                    return\n                }\n            }\n        }\n    }\n}\n<\/code><\/pre>\n<h6>3.\u5f02\u5e38\u7684\u5904\u7406<\/h6>\n<pre><code class=\"language-java line-numbers\">private fun testException(){\n    \/\/ \u5b9a\u4e49\u5f02\u5e38\u5904\u7406\u5668\n    val exceptionHandler = CoroutineExceptionHandler { coroutineContext, throwable -&gt;\n        Log.d(\"exceptionHandler\", \"${coroutineContext[CoroutineName]} \uff1a$throwable\")\n    }\n    \/\/ \u901a\u8fc7plus\u6dfb\u52a0\n     GlobalScope.launch(CoroutineName(\"\u5f02\u5e38\u5904\u7406\") + exceptionHandler){\n         val job = launch{\n             Log.d(\"${Thread.currentThread().name}\",\"\u6211\u8981\u5f00\u59cb\u629b\u5f02\u5e38\u4e86\" )\n             throw NullPointerException(\"\u5f02\u5e38\u6d4b\u8bd5\")\n         }\n         Log.d(\"${Thread.currentThread().name}\", \"end\")\n}\n<\/code><\/pre>\n<blockquote><p>\n  \u6e90\u7801\u5982\u4f55\u53d6 \u6211\u4eec\u5b9a\u4e49\u7684\u5f02\u5e38\u5904\u7406\u5668\n<\/p><\/blockquote>\n<pre><code class=\"language-java line-numbers\">public fun handleCoroutineException(context: CoroutineContext, exception: Throwable) {\n    try {\n        \/\/ \u5c1d\u8bd5\u53bb\u53d6\u662f\u5426\u5b9a\u4e49 \u5f02\u5e38\u5904\u7406\u5668\n        context[CoroutineExceptionHandler]?.let {\n            it.handleException(context, exception)\n            return\n        }\n    } catch (t: Throwable) {\n        handleCoroutineExceptionImpl(context, handlerException(exception, t))\n        return\n    }\n    \/\/ \u6ca1\u6709\u7684\u8bdd\u76f4\u63a5 \u629b\u51fa\u5f02\u5e38\u5bfc\u81f4\u7a0b\u5e8f\u5d29\u6e83\n    handleCoroutineExceptionImpl(context, exception)\n}\n<\/code><\/pre>\n","protected":false},"excerpt":{"rendered":"<p>1.CoroutineScheduler internal class CoroutineScheduler( [&hellip;]<\/p>\n","protected":false},"author":1,"featured_media":0,"comment_status":"open","ping_status":"open","sticky":false,"template":"","format":"standard","meta":{"footnotes":""},"categories":[11,8],"tags":[],"class_list":["post-412","post","type-post","status-publish","format-standard","hentry","category-android","category-8"],"yoast_head":"<!-- This site is optimized with the Yoast SEO plugin v24.4 - https:\/\/yoast.com\/wordpress\/plugins\/seo\/ -->\n<title>kotlin-\u534f\u7a0b\u5f02\u5e38\u5206\u6790\u5904\u7406(\u4e00) - IIchen<\/title>\n<meta name=\"robots\" content=\"index, follow, max-snippet:-1, max-image-preview:large, max-video-preview:-1\" \/>\n<link rel=\"canonical\" href=\"https:\/\/iichen.cn\/?p=412\" \/>\n<meta property=\"og:locale\" content=\"zh_CN\" \/>\n<meta property=\"og:type\" content=\"article\" \/>\n<meta property=\"og:title\" content=\"kotlin-\u534f\u7a0b\u5f02\u5e38\u5206\u6790\u5904\u7406(\u4e00) - IIchen\" \/>\n<meta property=\"og:description\" content=\"1.CoroutineScheduler internal class CoroutineScheduler( [&hellip;]\" \/>\n<meta property=\"og:url\" content=\"https:\/\/iichen.cn\/?p=412\" \/>\n<meta property=\"og:site_name\" content=\"IIchen\" \/>\n<meta property=\"article:published_time\" content=\"2022-11-25T06:13:29+00:00\" \/>\n<meta name=\"author\" content=\"iichen\" \/>\n<meta name=\"twitter:card\" content=\"summary_large_image\" \/>\n<meta name=\"twitter:label1\" content=\"\u4f5c\u8005\" \/>\n\t<meta name=\"twitter:data1\" content=\"iichen\" \/>\n<script type=\"application\/ld+json\" class=\"yoast-schema-graph\">{\"@context\":\"https:\/\/schema.org\",\"@graph\":[{\"@type\":\"Article\",\"@id\":\"https:\/\/iichen.cn\/?p=412#article\",\"isPartOf\":{\"@id\":\"https:\/\/iichen.cn\/?p=412\"},\"author\":{\"name\":\"iichen\",\"@id\":\"https:\/\/iichen.cn\/#\/schema\/person\/4a47edf85ab49841df9e8f6aee40b77c\"},\"headline\":\"kotlin-\u534f\u7a0b\u5f02\u5e38\u5206\u6790\u5904\u7406(\u4e00)\",\"datePublished\":\"2022-11-25T06:13:29+00:00\",\"mainEntityOfPage\":{\"@id\":\"https:\/\/iichen.cn\/?p=412\"},\"wordCount\":20,\"commentCount\":0,\"publisher\":{\"@id\":\"https:\/\/iichen.cn\/#\/schema\/person\/4a47edf85ab49841df9e8f6aee40b77c\"},\"articleSection\":[\"Android\",\"\u7b14\u8bb0\"],\"inLanguage\":\"zh-Hans\",\"potentialAction\":[{\"@type\":\"CommentAction\",\"name\":\"Comment\",\"target\":[\"https:\/\/iichen.cn\/?p=412#respond\"]}]},{\"@type\":\"WebPage\",\"@id\":\"https:\/\/iichen.cn\/?p=412\",\"url\":\"https:\/\/iichen.cn\/?p=412\",\"name\":\"kotlin-\u534f\u7a0b\u5f02\u5e38\u5206\u6790\u5904\u7406(\u4e00) - IIchen\",\"isPartOf\":{\"@id\":\"https:\/\/iichen.cn\/#website\"},\"datePublished\":\"2022-11-25T06:13:29+00:00\",\"breadcrumb\":{\"@id\":\"https:\/\/iichen.cn\/?p=412#breadcrumb\"},\"inLanguage\":\"zh-Hans\",\"potentialAction\":[{\"@type\":\"ReadAction\",\"target\":[\"https:\/\/iichen.cn\/?p=412\"]}]},{\"@type\":\"BreadcrumbList\",\"@id\":\"https:\/\/iichen.cn\/?p=412#breadcrumb\",\"itemListElement\":[{\"@type\":\"ListItem\",\"position\":1,\"name\":\"\u9996\u9875\",\"item\":\"https:\/\/iichen.cn\/\"},{\"@type\":\"ListItem\",\"position\":2,\"name\":\"kotlin-\u534f\u7a0b\u5f02\u5e38\u5206\u6790\u5904\u7406(\u4e00)\"}]},{\"@type\":\"WebSite\",\"@id\":\"https:\/\/iichen.cn\/#website\",\"url\":\"https:\/\/iichen.cn\/\",\"name\":\"IIchen\",\"description\":\"Just do it!\",\"publisher\":{\"@id\":\"https:\/\/iichen.cn\/#\/schema\/person\/4a47edf85ab49841df9e8f6aee40b77c\"},\"potentialAction\":[{\"@type\":\"SearchAction\",\"target\":{\"@type\":\"EntryPoint\",\"urlTemplate\":\"https:\/\/iichen.cn\/?s={search_term_string}\"},\"query-input\":{\"@type\":\"PropertyValueSpecification\",\"valueRequired\":true,\"valueName\":\"search_term_string\"}}],\"inLanguage\":\"zh-Hans\"},{\"@type\":[\"Person\",\"Organization\"],\"@id\":\"https:\/\/iichen.cn\/#\/schema\/person\/4a47edf85ab49841df9e8f6aee40b77c\",\"name\":\"iichen\",\"image\":{\"@type\":\"ImageObject\",\"inLanguage\":\"zh-Hans\",\"@id\":\"https:\/\/iichen.cn\/#\/schema\/person\/image\/\",\"url\":\"https:\/\/iichen.cn\/wp-content\/uploads\/2025\/01\/avatar.jpg\",\"contentUrl\":\"https:\/\/iichen.cn\/wp-content\/uploads\/2025\/01\/avatar.jpg\",\"width\":940,\"height\":940,\"caption\":\"iichen\"},\"logo\":{\"@id\":\"https:\/\/iichen.cn\/#\/schema\/person\/image\/\"},\"sameAs\":[\"https:\/\/www.iichen.cn\"],\"url\":\"https:\/\/iichen.cn\/?author=1\"}]}<\/script>\n<!-- \/ Yoast SEO plugin. -->","yoast_head_json":{"title":"kotlin-\u534f\u7a0b\u5f02\u5e38\u5206\u6790\u5904\u7406(\u4e00) - IIchen","robots":{"index":"index","follow":"follow","max-snippet":"max-snippet:-1","max-image-preview":"max-image-preview:large","max-video-preview":"max-video-preview:-1"},"canonical":"https:\/\/iichen.cn\/?p=412","og_locale":"zh_CN","og_type":"article","og_title":"kotlin-\u534f\u7a0b\u5f02\u5e38\u5206\u6790\u5904\u7406(\u4e00) - IIchen","og_description":"1.CoroutineScheduler internal class CoroutineScheduler( [&hellip;]","og_url":"https:\/\/iichen.cn\/?p=412","og_site_name":"IIchen","article_published_time":"2022-11-25T06:13:29+00:00","author":"iichen","twitter_card":"summary_large_image","twitter_misc":{"\u4f5c\u8005":"iichen"},"schema":{"@context":"https:\/\/schema.org","@graph":[{"@type":"Article","@id":"https:\/\/iichen.cn\/?p=412#article","isPartOf":{"@id":"https:\/\/iichen.cn\/?p=412"},"author":{"name":"iichen","@id":"https:\/\/iichen.cn\/#\/schema\/person\/4a47edf85ab49841df9e8f6aee40b77c"},"headline":"kotlin-\u534f\u7a0b\u5f02\u5e38\u5206\u6790\u5904\u7406(\u4e00)","datePublished":"2022-11-25T06:13:29+00:00","mainEntityOfPage":{"@id":"https:\/\/iichen.cn\/?p=412"},"wordCount":20,"commentCount":0,"publisher":{"@id":"https:\/\/iichen.cn\/#\/schema\/person\/4a47edf85ab49841df9e8f6aee40b77c"},"articleSection":["Android","\u7b14\u8bb0"],"inLanguage":"zh-Hans","potentialAction":[{"@type":"CommentAction","name":"Comment","target":["https:\/\/iichen.cn\/?p=412#respond"]}]},{"@type":"WebPage","@id":"https:\/\/iichen.cn\/?p=412","url":"https:\/\/iichen.cn\/?p=412","name":"kotlin-\u534f\u7a0b\u5f02\u5e38\u5206\u6790\u5904\u7406(\u4e00) - IIchen","isPartOf":{"@id":"https:\/\/iichen.cn\/#website"},"datePublished":"2022-11-25T06:13:29+00:00","breadcrumb":{"@id":"https:\/\/iichen.cn\/?p=412#breadcrumb"},"inLanguage":"zh-Hans","potentialAction":[{"@type":"ReadAction","target":["https:\/\/iichen.cn\/?p=412"]}]},{"@type":"BreadcrumbList","@id":"https:\/\/iichen.cn\/?p=412#breadcrumb","itemListElement":[{"@type":"ListItem","position":1,"name":"\u9996\u9875","item":"https:\/\/iichen.cn\/"},{"@type":"ListItem","position":2,"name":"kotlin-\u534f\u7a0b\u5f02\u5e38\u5206\u6790\u5904\u7406(\u4e00)"}]},{"@type":"WebSite","@id":"https:\/\/iichen.cn\/#website","url":"https:\/\/iichen.cn\/","name":"IIchen","description":"Just do it!","publisher":{"@id":"https:\/\/iichen.cn\/#\/schema\/person\/4a47edf85ab49841df9e8f6aee40b77c"},"potentialAction":[{"@type":"SearchAction","target":{"@type":"EntryPoint","urlTemplate":"https:\/\/iichen.cn\/?s={search_term_string}"},"query-input":{"@type":"PropertyValueSpecification","valueRequired":true,"valueName":"search_term_string"}}],"inLanguage":"zh-Hans"},{"@type":["Person","Organization"],"@id":"https:\/\/iichen.cn\/#\/schema\/person\/4a47edf85ab49841df9e8f6aee40b77c","name":"iichen","image":{"@type":"ImageObject","inLanguage":"zh-Hans","@id":"https:\/\/iichen.cn\/#\/schema\/person\/image\/","url":"https:\/\/iichen.cn\/wp-content\/uploads\/2025\/01\/avatar.jpg","contentUrl":"https:\/\/iichen.cn\/wp-content\/uploads\/2025\/01\/avatar.jpg","width":940,"height":940,"caption":"iichen"},"logo":{"@id":"https:\/\/iichen.cn\/#\/schema\/person\/image\/"},"sameAs":["https:\/\/www.iichen.cn"],"url":"https:\/\/iichen.cn\/?author=1"}]}},"_links":{"self":[{"href":"https:\/\/iichen.cn\/index.php?rest_route=\/wp\/v2\/posts\/412","targetHints":{"allow":["GET"]}}],"collection":[{"href":"https:\/\/iichen.cn\/index.php?rest_route=\/wp\/v2\/posts"}],"about":[{"href":"https:\/\/iichen.cn\/index.php?rest_route=\/wp\/v2\/types\/post"}],"author":[{"embeddable":true,"href":"https:\/\/iichen.cn\/index.php?rest_route=\/wp\/v2\/users\/1"}],"replies":[{"embeddable":true,"href":"https:\/\/iichen.cn\/index.php?rest_route=%2Fwp%2Fv2%2Fcomments&post=412"}],"version-history":[{"count":0,"href":"https:\/\/iichen.cn\/index.php?rest_route=\/wp\/v2\/posts\/412\/revisions"}],"wp:attachment":[{"href":"https:\/\/iichen.cn\/index.php?rest_route=%2Fwp%2Fv2%2Fmedia&parent=412"}],"wp:term":[{"taxonomy":"category","embeddable":true,"href":"https:\/\/iichen.cn\/index.php?rest_route=%2Fwp%2Fv2%2Fcategories&post=412"},{"taxonomy":"post_tag","embeddable":true,"href":"https:\/\/iichen.cn\/index.php?rest_route=%2Fwp%2Fv2%2Ftags&post=412"}],"curies":[{"name":"wp","href":"https:\/\/api.w.org\/{rel}","templated":true}]}}