多线程并发环境生产者-消费者，kotlin

秒速五厘米 2023-09-25 20:23 47阅读 0赞

多个生产者-多个消费者，消费者竞争抢占生产者制造的资源。

//存放资源的仓储
    val store = arrayOfNulls<Int>(1)
    
    //资源
    var RESOURCE: Int = 0
    
    fun producer(tid: Long) {
        synchronized(store) {
            if (isFull()) {
                return
            }
    
            println("生产->$RESOURCE $tid @${System.currentTimeMillis()}")
            store[0] = RESOURCE //生产的资源
    
            RESOURCE++
        }
    }
    
    fun consumer(tid: Long) {
        synchronized(store) {
            if (!isFull()) {
                return
            }
    
            val i = store[0]
            println("消费<-$i $tid @${System.currentTimeMillis()}")
            store[0] = null //资源被消耗
        }
    }
    
    fun isFull(): Boolean {
        return store[0] != null
    }
    
    fun go() {
        //多个消费者，竞争消耗资源
        for (i in 0 until 5) {
            object : Thread() {
                override fun run() {
                    while (true) {
                        sleep(3)
    
                        consumer(this.threadId())
                    }
                }
            }.start()
        }
    
        //多个生产者
        for (i in 0 until 5) {
            val t = object : Thread() {
                override fun run() {
                    while (true) {
                        sleep(3)
    
                        producer(this.threadId())
                    }
                }
            }
            t.start()
        }
    }
    
    fun main(args: Array<String>) {
        go()
    }

> 生产->0 31 @1680141217600  
> 消费<-0 26 @1680141217600  
> 生产->1 30 @1680141217600  
> 消费<-1 24 @1680141217604  
> 生产->2 28 @1680141217605  
> 消费<-2 26 @1680141217605  
> 生产->3 30 @1680141217605  
> 消费<-3 24 @1680141217607  
> 生产->4 31 @1680141217608  
> 消费<-4 26 @1680141217608  
> 生产->5 32 @1680141217608  
> 消费<-5 27 @1680141217608  
> 生产->6 30 @1680141217608  
> 消费<-6 23 @1680141217610  
> 生产->7 31 @1680141217611  
> 消费<-7 27 @1680141217612  
> 生产->8 29 @1680141217612  
> 消费<-8 25 @1680141217613  
> 生产->9 32 @1680141217614  
> 消费<-9 26 @1680141217614  
> 生产->10 28 @1680141217614  
> 消费<-10 27 @1680141217615  
> 生产->11 29 @1680141217615  
> 消费<-11 25 @1680141217616  
> 生产->12 31 @1680141217617  
> 消费<-12 27 @1680141217618  
> 生产->13 29 @1680141217619  
> 消费<-13 25 @1680141217619  
> 生产->14 28 @1680141217620  
> 消费<-14 26 @1680141217620  
> 生产->15 31 @1680141217620  
> 消费<-15 27 @1680141217622  
> 生产->16 29 @1680141217623  
> 消费<-16 25 @1680141217623

[Java线程同步：生产者-消费者 模型（代码示例）\_zhangphil的博客-CSDN博客public class ThreadSyn \{public static void main(String\[\] args) \{new ThreadSyn();\}public ThreadSyn() \{Queue queue = new Queue();Producter p = new Producter(queue);Consumer c = new![favicon32.ico][]https://blog.csdn.net/zhangphil/article/details/43800967][Java_-_ _zhangphil_-CSDN_public class ThreadSyn _public static void main_String_ args_ _new ThreadSyn_public ThreadSyn_ _Queue queue _ new Queue_Producter p _ new Producter_queue_Consumer c _ new_favicon32.ico_https_blog.csdn.net_zhangphil_article_details_43800967]

[favicon32.ico]: https://g.csdnimg.cn/static/logo/favicon32.ico
[Java_-_ _zhangphil_-CSDN_public class ThreadSyn _public static void main_String_ args_ _new ThreadSyn_public ThreadSyn_ _Queue queue _ new Queue_Producter p _ new Producter_queue_Consumer c _ new_favicon32.ico_https_blog.csdn.net_zhangphil_article_details_43800967]: https://blog.csdn.net/zhangphil/article/details/43800967