iMessageExecutorPool 关于线程模型

[testwen00]

在一个pc上测试，运行两个KcpRttExampleClient，连接KcpRttExampleServer
ScheduleTask，ReadTask，WriteTask其实都是一个线程在运行，都是串行在操作，这设计是为何？

[l42111996]

运行两个KcpRttExampleClient 是两个进程吗？ 对于单个Ukcp的连接来说 ScheduleTask，ReadTask，WriteTask其实都是一个线程在运行，都是串行在操作。对于多个Ukcp来说他们都是并行的，这样子业务都是无锁的，这样子单连接串行多连接并行充分利用了多核，对cpu的缓存也友好

[l42111996]

如果是同一个进程的话，最佳实践是new一个KcpRttExampleClient实例然后多次调用connect不同的server

[testwen00]

希望读和写能分开线程，如果单线程，这样怕性能上有影响。

[l42111996]

这里的线程只处理kcp层的逻辑不会处理网络io，逻辑通过visual分析不是瓶颈，测试的单线程单连接带fec的逻辑处理预计每秒可以处理6万个包，每个包如果算1K的话也有6W1K字节，这个应该满足99%的业务了，而且并行的话最少可以跑到70%cpu+的性能，整体吞吐量等于 cpu数6W1K70%
如果读写分离必须要加锁，单连接的吞吐可能上去20%，整个系统吞吐量会降低很多。

[testwen00]

实际测试下来，性能有影响，发送方数据包在20w以上，receivequeue或writequeue数据一多，就造成所有数据处理延迟，发送不及时，最终服务端读取超时。

[testwen00]

例如用 #15 的例子，接收数据非常缓慢，耗时很长

[l42111996]

例如用 #15 的例子，接收数据非常缓慢，耗时很长
上面的问题在我本地没跑出来，从上面的日志分析可能是带宽满了或者你局域网路由器达到极限了，局域网达到了50%的丢包率，
可以试试再本地跑几个虚拟机试试

[testwen00]

1、我的是pc机，本机运行，用的无线网卡。
2、数据包要大，200000字节。

我的猜测是数据包太大，拆分成了很多分片，每个分片都需要ack来回，造成了时间延长。

[l42111996]

1、我的是pc机，本机运行，用的无线网卡。
2、数据包要大，200000字节。

我的猜测是数据包太大，拆分成了很多分片，每个分片都需要ack来回，造成了时间延长。

我这边用你的例子在本地跑了两个进程，连接的127.0.0.1，看带宽峰值在38MB，来回rtt打印的在10ms以内,所以我感觉可能是网卡问题或者路由器问题，快手那边用这个库做过类似的测试瓶颈也出现在了公司内部路由器。

[testwen00]

测算下来，耗时在fec编，解码，平均耗时1毫秒，累计起来，延迟增加。

[l42111996]

测算下来，耗时在fec编，解码，平均耗时1毫秒，累计起来，延迟增加。

啥配置的cpu？怎么这么耗时，fec的编码可以独立出去搞个线程 ，解码现在还不好搞出去单独搞个线程

[testwen00]

i7-7700 3.6GHz
内存16g
测试10000个字节以下性能很好。
100000个字节，就不行了。

打印的时间代码 ReedSolomon：

    long start = System.currentTimeMillis();
    // Do the coding.
    LOOP.codeSomeShards(
            parityRows,
            shards, dataShardCount,
            outputs, parityShardCount,
            offset, byteCount);
    long end = System.currentTimeMillis();
    if ((end - start) > 0)
        System.out.println("codeSomeShards use time = " + (end - start));

[l42111996]

i7-7700 3.6GHz

内存16g

测试10000个字节以下性能很好。

100000个字节，就不行了。

打印的时间代码 ReedSolomon：

    long start = System.currentTimeMillis();

    // Do the coding.

    LOOP.codeSomeShards(

            parityRows,

            shards, dataShardCount,

            outputs, parityShardCount,

            offset, byteCount);

    long end = System.currentTimeMillis();

    if ((end - start) > 0)

        System.out.println("codeSomeShards use time = " + (end - start));

Windows操作系统吗？明天我测试一下试试

[testwen00]

windows10
jdk1.8

[l42111996]

windows10
jdk1.8

有完整的测试代码吗？