pull/2136/head
821938089 2 years ago
parent c140085437
commit 270030c3be
  1. 8
      app/src/main/java/io/legado/app/base/BaseService.kt
  2. 10
      app/src/main/java/io/legado/app/help/coroutine/Coroutine.kt
  3. 8
      app/src/main/java/io/legado/app/service/CheckSourceService.kt
  4. 2
      app/src/main/java/io/legado/app/ui/book/source/manage/BookSourceActivity.kt
  5. 19
      app/src/main/java/io/legado/app/ui/book/source/manage/BookSourceAdapter.kt

@ -6,10 +6,7 @@ import android.os.IBinder
import androidx.annotation.CallSuper
import io.legado.app.help.LifecycleHelp
import io.legado.app.help.coroutine.Coroutine
import kotlinx.coroutines.CoroutineScope
import kotlinx.coroutines.Dispatchers
import kotlinx.coroutines.MainScope
import kotlinx.coroutines.cancel
import kotlinx.coroutines.*
import kotlin.coroutines.CoroutineContext
abstract class BaseService : Service(), CoroutineScope by MainScope() {
@ -17,8 +14,9 @@ abstract class BaseService : Service(), CoroutineScope by MainScope() {
fun <T> execute(
scope: CoroutineScope = this,
context: CoroutineContext = Dispatchers.IO,
start: CoroutineStart = CoroutineStart.DEFAULT,
block: suspend CoroutineScope.() -> T
) = Coroutine.async(scope, context) { block() }
) = Coroutine.async(scope, context, start) { block() }
@CallSuper
override fun onCreate() {

@ -12,6 +12,7 @@ import kotlin.coroutines.CoroutineContext
class Coroutine<T>(
val scope: CoroutineScope,
context: CoroutineContext = Dispatchers.IO,
val startOption: CoroutineStart = CoroutineStart.DEFAULT,
block: suspend CoroutineScope.() -> T
) {
@ -22,9 +23,10 @@ class Coroutine<T>(
fun <T> async(
scope: CoroutineScope = DEFAULT,
context: CoroutineContext = Dispatchers.IO,
start: CoroutineStart = CoroutineStart.DEFAULT,
block: suspend CoroutineScope.() -> T
): Coroutine<T> {
return Coroutine(scope, context, block)
return Coroutine(scope, context, start, block)
}
}
@ -135,11 +137,15 @@ class Coroutine<T>(
return job.invokeOnCompletion(handler)
}
fun start() {
job.start()
}
private fun executeInternal(
context: CoroutineContext,
block: suspend CoroutineScope.() -> T
): Job {
return (scope + Dispatchers.Main).launch {
return (scope + Dispatchers.Main).launch(start = startOption) {
try {
start?.let { dispatchVoidCallback(this, it) }
ensureActive()

@ -24,10 +24,8 @@ import io.legado.app.utils.activityPendingIntent
import io.legado.app.utils.postEvent
import io.legado.app.utils.servicePendingIntent
import io.legado.app.utils.toastOnUi
import kotlinx.coroutines.*
import kotlinx.coroutines.Dispatchers.IO
import kotlinx.coroutines.TimeoutCancellationException
import kotlinx.coroutines.asCoroutineDispatcher
import kotlinx.coroutines.launch
import org.mozilla.javascript.WrappedException
import java.util.concurrent.Executors
import kotlin.math.min
@ -122,7 +120,7 @@ class CheckSourceService : BaseService() {
*校验书源
*/
private fun check(source: BookSource) {
execute(context = searchCoroutine) {
execute(context = searchCoroutine, start = CoroutineStart.LAZY) {
Debug.startChecking(source)
var searchWord = CheckSource.keyword
source.ruleSearch?.checkKeyWord?.let {
@ -194,7 +192,7 @@ class CheckSourceService : BaseService() {
source.respondTime = Debug.getRespondTime(source.bookSourceUrl)
appDb.bookSourceDao.update(source)
onNext(source.bookSourceUrl, source.bookSourceName)
}
}.start()
}
/**

@ -531,7 +531,7 @@ class BookSourceActivity : VMBaseActivity<ActivityBookSourceBinding, BookSourceV
/**
* 保持亮屏
*/
fun keepScreenOn(on: Boolean) {
private fun keepScreenOn(on: Boolean) {
val isScreenOn = (window.attributes.flags and WindowManager.LayoutParams.FLAG_KEEP_SCREEN_ON) != 0
if (on == isScreenOn) return
if (on) {

@ -32,7 +32,6 @@ class BookSourceAdapter(context: Context, val callBack: CallBack) :
ItemTouchCallback.Callback {
private val selected = linkedSetOf<BookSource>()
private val selectedPosition = linkedSetOf<Int>()
val selection: List<BookSource>
get() {
@ -143,10 +142,8 @@ class BookSourceAdapter(context: Context, val callBack: CallBack) :
if (view.isPressed) {
if (checked) {
selected.add(it)
selectedPosition.add(holder.layoutPosition)
} else {
selected.remove(it)
selectedPosition.remove(holder.layoutPosition)
}
callBack.upCountView()
}
@ -219,22 +216,19 @@ class BookSourceAdapter(context: Context, val callBack: CallBack) :
}
fun selectAll() {
getItems().forEachIndexed { index, it ->
getItems().forEach {
selected.add(it)
selectedPosition.add(index)
}
notifyItemRangeChanged(0, itemCount, bundleOf(Pair("selected", null)))
callBack.upCountView()
}
fun revertSelection() {
getItems().forEachIndexed { index, it ->
getItems().forEach {
if (selected.contains(it)) {
selected.remove(it)
selectedPosition.remove(index)
} else {
selected.add(it)
selectedPosition.add(index)
}
}
notifyItemRangeChanged(0, itemCount, bundleOf(Pair("selected", null)))
@ -242,13 +236,18 @@ class BookSourceAdapter(context: Context, val callBack: CallBack) :
}
fun checkSelectedInterval() {
val selectedPosition = linkedSetOf<Int>()
getItems().forEachIndexed { index, it ->
if (selected.contains(it)) {
selectedPosition.add(index)
}
}
val minPosition = Collections.min(selectedPosition)
val maxPosition = Collections.max(selectedPosition)
val itemCount = maxPosition - minPosition + 1
for (i in minPosition..maxPosition) {
getItem(i)?.let {
selected.add(it)
selectedPosition.add(i)
}
}
notifyItemRangeChanged(minPosition, itemCount, bundleOf(Pair("selected", null)))
@ -296,10 +295,8 @@ class BookSourceAdapter(context: Context, val callBack: CallBack) :
getItem(position)?.let {
if (isSelected) {
selected.add(it)
selectedPosition.add(position)
} else {
selected.remove(it)
selectedPosition.remove(position)
}
notifyItemChanged(position, bundleOf(Pair("selected", null)))
callBack.upCountView()

Loading…
Cancel
Save