import java.util.concurrent.*

// 優(yōu)先級(jí)任務(wù)基類
abstract class PriorityRunnable(
    private val priority: Int // 值越大優(yōu)先級(jí)越高
) : Runnable, Comparable<PriorityRunnable> {
    override fun compareTo(other: PriorityRunnable): Int {
        return other.priority.compareTo(priority) // 降序排列
    }
}

// 優(yōu)先級(jí)線程池
class PriorityThreadPool {
    private val executor: ThreadPoolExecutor

    companion object {
        private const val CORE_POOL_SIZE = 4
        private const val MAX_POOL_SIZE = 8
        private const val KEEP_ALIVE_TIME = 60L
    }

    init {
        val queue = PriorityBlockingQueue<Runnable>()
        executor = ThreadPoolExecutor(
            CORE_POOL_SIZE,
            MAX_POOL_SIZE,
            KEEP_ALIVE_TIME,
            TimeUnit.SECONDS,
            queue
        ).apply {
            allowCoreThreadTimeOut(true)
        }
    }

    fun execute(task: PriorityRunnable) {
        executor.execute(task)
    }
}

// 使用示例
fun testPriorityThreadPool() {
    val pool = PriorityThreadPool()

    // 低優(yōu)先級(jí)任務(wù)
    pool.execute(object : PriorityRunnable(1) {
        override fun run() {
            println("低優(yōu)先級(jí)任務(wù)開始")
            Thread.sleep(1000)
            println("低優(yōu)先級(jí)任務(wù)完成")
        }
    })

    // 高優(yōu)先級(jí)任務(wù)（后提交但先執(zhí)行）
    Thread.sleep(100) // 確保低優(yōu)先級(jí)任務(wù)先入隊(duì)
    pool.execute(object : PriorityRunnable(10) {
        override fun run() {
            println("高優(yōu)先級(jí)任務(wù)開始")
            Thread.sleep(500)
            println("高優(yōu)先級(jí)任務(wù)完成")
        }
    })
}

import android.os.Handler
import android.os.Looper
import android.os.Message

class PriorityHandler(looper: Looper) : Handler(looper) {

    companion object {
        const val HIGH_PRIORITY = 10
        const val NORMAL_PRIORITY = 5
        const val LOW_PRIORITY = 1
    }

    // 按優(yōu)先級(jí)插入消息隊(duì)列
    override fun sendMessageAtTime(msg: Message, uptimeMillis: Long): Boolean {
        msg.data?.putInt("priority", msg.arg1) // 存儲(chǔ)優(yōu)先級(jí)
        
        synchronized(queue) {
            var cur = queue
            var prev: Message? = null
            
            // 遍歷找到插入位置
            while (cur != null && (cur.data?.getInt("priority") ?: 0) >= msg.arg1) {
                prev = cur
                cur = cur.next
            }
            
            // 插入操作
            msg.next = cur
            prev?.next = msg ?: run { queue = msg }
        }
        return true
    }
}

// 使用示例
fun testPriorityHandler() {
    val handler = PriorityHandler(Looper.getMainLooper())

    // 低優(yōu)先級(jí)任務(wù)
    handler.obtainMessage().apply {
        arg1 = PriorityHandler.LOW_PRIORITY
        handler.sendMessage(this)
    }

    // 高優(yōu)先級(jí)任務(wù)
    handler.obtainMessage().apply {
        arg1 = PriorityHandler.HIGH_PRIORITY
        handler.sendMessage(this) // 將插入隊(duì)列頭部
    }
    
    // 消息處理
    object : Handler(Looper.getMainLooper()) {
        override fun handleMessage(msg: Message) {
            when (msg.arg1) {
                PriorityHandler.HIGH_PRIORITY -> 
                    println("處理高優(yōu)先級(jí)UI任務(wù)")
                PriorityHandler.LOW_PRIORITY -> 
                    println("處理低優(yōu)先級(jí)UI任務(wù)")
            }
        }
    }
}

val queue = Volley.newRequestQueue(context)

// 高優(yōu)先級(jí)請(qǐng)求
val highPriorityRequest = object : StringRequest(
    Method.GET, 
    "https://api.example.com/user",
    { response -> /* 處理響應(yīng) */ },
    { error -> /* 處理錯(cuò)誤 */ }
) {
    override fun getPriority() = Priority.HIGH
}

// 低優(yōu)先級(jí)請(qǐng)求
val lowPriorityRequest = object : ImageRequest(
    "https://cdn.example.com/image.jpg",
    { bitmap -> /* 顯示圖片 */ },
    0, 0, null,
    { error -> /* 處理錯(cuò)誤 */ }
) {
    override fun getPriority() = Priority.LOW
}

queue.add(highPriorityRequest)
queue.add(lowPriorityRequest)

val client = OkHttpClient()

// 自定義調(diào)度器
val dispatcher = Dispatcher().apply {
    maxRequests = 64
    maxRequestsPerHost = 16
}

val client = OkHttpClient.Builder()
    .dispatcher(dispatcher)
    .build()

// 帶優(yōu)先級(jí)的請(qǐng)求封裝
class PriorityRequest(
    private val request: Request,
    private val priority: Int
) : Comparable<PriorityRequest> {
    override fun compareTo(other: PriorityRequest) = 
        other.priority.compareTo(priority)
}

// 使用優(yōu)先級(jí)隊(duì)列
val priorityQueue = PriorityBlockingQueue<PriorityRequest>()

// 執(zhí)行請(qǐng)求
fun enqueueRequest(priorityRequest: PriorityRequest) {
    client.newCall(priorityRequest.request).enqueue(object : Callback {
        override fun onResponse(call: Call, response: Response) {
            // 處理響應(yīng)
        }
        override fun onFailure(call: Call, e: IOException) {
            // 處理失敗
        }
    })
}

import androidx.work.*

// 高優(yōu)先級(jí)工作器
class HighPriorityWorker(
    context: Context,
    params: WorkerParameters
) : Worker(context, params) {

    override fun doWork(): Result {
        // 執(zhí)行重要后臺(tái)任務(wù)
        return Result.success()
    }
}

// 低優(yōu)先級(jí)工作器
class LowPriorityWorker(
    context: Context,
    params: WorkerParameters
) : Worker(context, params) {

    override fun doWork(): Result {
        // 執(zhí)行普通后臺(tái)任務(wù)
        return Result.success()
    }
}

// 任務(wù)調(diào)度管理
class WorkScheduler(private val context: Context) {

    fun scheduleHighPriorityWork() {
        val constraints = Constraints.Builder()
            .setRequiredNetworkType(NetworkType.CONNECTED)
            .setRequiresBatteryNotLow(true)
            .build()

        val request = OneTimeWorkRequestBuilder<HighPriorityWorker>()
            .setExpedited(OutOfQuotaPolicy.RUN_AS_NON_EXPEDITED_WORK_REQUEST)
            .setConstraints(constraints)
            .build()

        WorkManager.getInstance(context).enqueue(request)
    }

    fun scheduleLowPriorityWork() {
        val request = OneTimeWorkRequestBuilder<LowPriorityWorker>()
            .setConstraints(
                Constraints.Builder()
                    .setRequiredNetworkType(NetworkType.UNMETERED) // 僅WiFi
                    .build()
            )
            .build()

        WorkManager.getInstance(context)
            .beginWith(request)
            .enqueue()
    }
}

object PriorityLevel {
    const val CRITICAL = 100 // 用戶直接操作
    const val HIGH = 80      // 實(shí)時(shí)反饋
    const val MEDIUM = 50    // 常規(guī)任務(wù)
    const val LOW = 10       // 后臺(tái)清理
}

executor.execute {
    val future = pool.submit(task)
    future.get(500, TimeUnit.MILLISECONDS) // 設(shè)置超時(shí)
}

// 監(jiān)控線程池狀態(tài)
fun monitorThreadPool(executor: ThreadPoolExecutor) {
    Timer().scheduleAtFixedRate({
        println("""
            活躍線程: ${executor.activeCount}
            隊(duì)列任務(wù): ${executor.queue.size}
            完成數(shù): ${executor.completedTaskCount}
        """.trimIndent())
    }, 0, 5000)
}

fun scheduleMixedTask(task: Task) {
    when (task.type) {
        TaskType.UI_CRITICAL -> mainHandler.sendPriorityMessage(task)
        TaskType.NETWORK -> volleyQueue.add(task)
        TaskType.BACKGROUND -> WorkManager.enqueue(task)
        else -> threadPool.execute(task)
    }
}

// 創(chuàng)建優(yōu)先級(jí)調(diào)度器
val priorityDispatcher = Executors.newFixedThreadPool(4).asCoroutineDispatcher()

// 帶優(yōu)先級(jí)啟動(dòng)協(xié)程
fun launchPriorityTask(priority: Int) = runBlocking {
    val job = launch(priorityDispatcher) {
        setTaskPriority(priority) // 自定義優(yōu)先級(jí)邏輯
        // 任務(wù)代碼
    }
    
    // 優(yōu)先級(jí)控制
    job.invokeOnCompletion { 
        println("任務(wù)完成，優(yōu)先級(jí):$priority") 
    }
}

// 使用結(jié)構(gòu)化并發(fā)管理
suspend fun fetchDataWithPriority() = coroutineScope {
    val urgent = async(Dispatchers.IO) { fetchUrgentData() }
    val normal = async(Dispatchers.IO) { fetchNormalData() }
    
    // 優(yōu)先處理緊急數(shù)據(jù)
    val result = urgent.await().process()
    normal.await() // 等待普通數(shù)據(jù)完成
    return result
}