小编jon*_*jon的帖子

当我在1个线程中做100个非块套接字连接时,它非常慢(连接数逐个增加),但是如果我在100个并行线程中进行阻塞套接字连接(每个线程一个连接),那就非常快(立即完成)

sock = socket(AF_INET, SOCK_STREAM, IPPROTO_TCP);
if (fcntl(sock, F_SETFL,O_NONBLOCK)!=0)
{
 perror("fcntl nonblock");
 return -1;
}

if (setsockopt(sock, SOL_SOCKET, SO_REUSEADDR,&reuseAddr, sizeof(reuseAddr))!=0)
{
  perror("reuse addr");
  return -1;
}

sAddr.sin_addr.s_addr = inet_addr(SRV_ADDR);
sAddr.sin_port = htons(1972);

if ((n=connect(sock, (const struct sockaddr *) &sAddr, sizeof(sAddr))) < 0) 
{
  if (errno !=EINPROGRESS) {
      perror("client connect error");
      return -1;
  }     
}
else if (n>=0)
{
  printf("#%d connected\n",sock);
}

return sock;

我做了一个测试来比较 golang 通道和 C++ tbb 并发队列性能，我设置了 8 个写入器和 1 个读取器，它们位于不同的线程中。结果显示 golang 比 C++ 版本快得多（无论延迟和整体发送/接收速度如何），是是真的？或者我的代码有什么错误？

golang 结果，单位是微秒

延迟最大值：1505，平均：1073 发送开始：1495593677683232，接收结束：1495593677901854，时间：218622

package main

import (
    "flag"
    "time"
    "fmt"
    "sync"
    "runtime"
)

var (
    producer = flag.Int("producer", 8, "producer")
    consumer = flag.Int("consumer", 1, "consumer")
    start_signal sync.WaitGroup
)

const (
    TEST_NUM = 1000000
)

type Item struct  {
    id int
    sendtime int64
    recvtime int64
}

var g_vec[TEST_NUM] Item

func sender(out chan int, begin int, end int) {
    start_signal.Wait()
    runtime.LockOSThread()
    println("i am in sender", begin, end) …