Advertisement
Not a member of Pastebin yet?
Sign Up,
it unlocks many cool features!
- import java.util.*
- import java.util.concurrent.Executors
- import java.util.concurrent.TimeUnit
- var value: HashMap<String, String> = HashMap()
- val executor = Executors.newFixedThreadPool(40)!!
- fun main(args: Array<String>) {
- for (i in 0..20) {
- executor.submit {
- try {
- (0..99999).forEach { i ->
- value.put("value$i", "$i")
- value.put("thread", Thread.currentThread().id.toString())
- }
- } catch (e: Exception) {
- e.printStackTrace()
- }
- }
- }
- for (i in 0..20) {
- executor.submit {
- try {
- (0..99999).forEach { i ->
- var iterator = value.iterator()
- while (iterator.hasNext()) {
- iterator.next().value
- }
- }
- } catch (e: Exception) {
- e.printStackTrace()
- }
- }
- }
- executor.shutdown()
- executor.awaitTermination(60, TimeUnit.SECONDS)
- }
Advertisement
Add Comment
Please, Sign In to add comment
Advertisement