如何在单例中正确使用协程

Question

我想用协程创建一个单例来从网络加载图像。我已经实现了单例并且可以将网络图像加载到 imageView 中。这是我的单身课程。

class Singleton(context: Context) {

    private val TAG = "Singleton"

    private val scope =
        CoroutineScope(SupervisorJob() + Dispatchers.Main + CoroutineExceptionHandler { _, exception ->
            Log.e(TAG, "Caught $exception")
        })

    private var job:Job? = null

    companion object {

        private var INSTANCE: Singleton? = null

        @Synchronized
        fun with(context: Context): Singleton {

            require(context != null) {
                "ImageLoader:with - Context should not be null."
            }

            return INSTANCE ?: Singleton(context).also {
                INSTANCE = it
                Log.d("ImageLoader", "First Init")
            }

        }
    }

    private fun onAttachStateChange(imageView: ImageView, job: Job) {
        imageView.addOnAttachStateChangeListener(object : View.OnAttachStateChangeListener {
            override fun onViewAttachedToWindow(v: View?) {
            }

            override fun onViewDetachedFromWindow(v: View?) {
                job.cancel()
            }

        })
    }

    fun loadImage(url: String, imageView: ImageView) {
        job = scope.launch {
            try {
                updateData(URL(url), imageView)
            } catch (e: CancellationException) {
                Log.d(TAG, "work cancelled!")
            }
        }.also {
            onAttachStateChange(imageView, it)
        }
    }

    suspend fun updateData(url: URL, imageView: ImageView) = run {
        fetchImage(url)?.apply { imageView.setImageBitmap(this) }
            ?: imageView.setImageResource(R.drawable.ic_launcher_background)
    }

    fun stopUpdate() {
        scope.cancel()
    }

    private suspend fun fetchImage(url: URL): Bitmap? {
        return withContext(Dispatchers.IO) {
            try {
                val connection = url.openConnection() as HttpURLConnection
                val bufferedInputStream = BufferedInputStream(connection.inputStream)
                BitmapFactory.decodeStream(bufferedInputStream)
            } catch (e: Exception) {
                Log.e("TAG", e.toString())
                null
            }
        }
    }
}

我的问题是，当我在 ActivityB 中取消 onDestroy() 中的协程范围，然后在 ActivityA 中再次使用我的单例时，它不会做任何事情，因为范围已被取消（）。那么，当活动为onDestroy() 时，有什么方法可以通过 scope.cancel() 在单例中正确使用协程。这是一个演示：

class MainActivityA : AppCompatActivity() {
    override fun onCreate(savedInstanceState: Bundle?) {
        super.onCreate(savedInstanceState)
        setContentView(R.layout.activity_main_activity)
        
        Singleton.with(this).updateData(url, imageView)
    }
}

class MainActivityB : AppCompatActivity() {
    override fun onCreate(savedInstanceState: Bundle?) {
        super.onCreate(savedInstanceState)
        setContentView(R.layout.activity_main_activity)
    }

    override fun onDestroy() {
        super.onDestroy()
        // Do not need to call scope.cancel(). Cause when the view is 
        // detached it will cancel the job.
        // Singleton.with(this).stopUpdate()
    }
}

---

已编辑
我想出了一个想法并添加到 Singleton 类中。使用view.onAttachStateChange 检测视图是否仍然附加到窗口。如果是分离的，那么我们可以取消作业。这是一个好方法吗？

Answer 1

根据定义，单例永远存在，所以我不确定取消它的范围是否有意义。如果您需要同时使用来自多个组件的单例怎么办？他们会取消其他组件的工作。

为确保您不会泄露已损坏组件的作业，您可以为每个组件创建一个子作业并将所有任务放在其下，或者根本不定义自定义范围并重用调用者的协程上下文。