go之channel任意任务完成、全部任务完成退出

import (
  "fmt"
  "runtime"
  "testing"
  "time"
)
 
func runTask(id int) string {
  time.Sleep(time.Millisecond * 10)
  return fmt.Sprintf("The result is from %d", id)
}
 
//任意任务完成
func FirstReponse() string {
  numOfRunner := 10
  //buffer chan防止协程泄露
  ch := make(chan string, numOfRunner)
  for i := 0; i < numOfRunner; i++ {
    go func(i int) {
      ret := runTask(i)
      ch <- ret
    }(i)
  }
  //任意任务完成
  return <-ch
}

import (
  "fmt"
  "runtime"
  "testing"
  "time"
)
 
func runTask(id int) string {
  time.Sleep(time.Millisecond * 10)
  return fmt.Sprintf("The result is from %d", id)
}
 
//全部任务完成后返回
func AllReponse() string {
  numOfRunner := 10
  //buffer chan防止协程泄露
  ch := make(chan string, numOfRunner)
  for i := 0; i < numOfRunner; i++ {
    go func(i int) {
      ret := runTask(i)
      ch <- ret
    }(i)
  }
  finalRet := ""
  for n := 0; n < numOfRunner; n++ {
    finalRet += <-ch + "\n"
  }
  return finalRet
}

import (
  "fmt"
  "runtime"
  "testing"
  "time"
)
 
func runTask(id int) string {
  time.Sleep(time.Millisecond * 10)
  return fmt.Sprintf("The result is from %d", id)
}
 
//任意任务完成
func FirstReponse() string {
  numOfRunner := 10
  //buffer chan防止协程泄露
  ch := make(chan string, numOfRunner)
  for i := 0; i < numOfRunner; i++ {
    go func(i int) {
      ret := runTask(i)
      ch <- ret
    }(i)
  }
  //任意任务完成
  return <-ch
}
 
//全部任务完成后返回
func AllReponse() string {
  numOfRunner := 10
  //buffer chan防止协程泄露
  ch := make(chan string, numOfRunner)
  for i := 0; i < numOfRunner; i++ {
    go func(i int) {
      ret := runTask(i)
      ch <- ret
    }(i)
  }
  finalRet := ""
  for n := 0; n < numOfRunner; n++ {
    finalRet += <-ch + "\n"
  }
  return finalRet
}
func TestFirstResponse(t *testing.T) {
  t.Log("Before:", runtime.NumGoroutine())
  //t.Log(FirstReponse())
  t.Log(AllReponse())
  time.Sleep(time.Second * 1)
  t.Log("After:", runtime.NumGoroutine())
}