多线程 覆盖写出字节集 还没有单线程来的快啊

帅气与大侠

写了个序号生成，从1-11600000，用了5-10个线程跑，cpu都跑满了，磁盘写入速度才1.3mb左右，耗时40秒，1个线程反而磁盘写入速度能达到4mb，是不是多线程写的不行啊

  

快速生成索引文件 (“e:\123.txt”, 11600000)

子程序名	返回值类型	公开	备 注
快速生成索引文件	双精度小数型
参数名	类 型	参考	可空	数组	备 注
文件路径	文本型
最大索引	长整数型

变量名	类 型	静态	数组	备 注
文件号	整数型
线程数	整数型
块值	整数型
余数	双精度小数型
i	整数型
启动时间	整数型

' 快速创建一个以空白字节填充的文件
文件号 ＝ 文件_打开文件A (文件路径, , , #CREATE_ALWAYS )
文件_移动读写位置Ex (文件号, #FILE_BEGIN, 求索引序号占用字节 (最大索引))
文件_设置文件尾 (文件号)
文件_关闭文件 (文件号)
线程数 ＝ 3
块值 ＝ 绝对取整 (最大索引 ÷ 线程数)
余数 ＝ 绝对取整 (最大索引 ％ 线程数)
启动时间 ＝ 取启动时间 ()
集_线程池.创建 (线程数, 线程数, , , )
计次循环首 (线程数, i)
集_线程池.投递任务 (&子程序1, i － 1, 块值)
程序_延时 (100)
计次循环尾 ()
如果真 (余数 ≠ 0)
子程序1 (i － 1, 块值, 余数)

判断循环首 (集_线程池.取_是否空闲 () ＝ 假)
程序_延时 (100)
判断循环尾 ()
集_线程池.销毁 ()
调试输出 (“执行完毕”, 取启动时间 () － 启动时间)
返回 (0)

子程序名	返回值类型	公开	备 注
子程序1
参数名	类 型	参考	可空	数组	备 注
索引	整数型
块值	整数型
余数	整数型

变量名	类 型	静态	数组	备 注
文件号	整数型
i	整数型
初始值	双精度小数型
文本	字节集
写入的文本	字节集
计次	整数型

文件号 ＝ 文件_打开文件A (“e:\123.txt”, , #FILE_SHARE_READ ＋ #FILE_SHARE_WRITE, #OPEN_ALWAYS, )
初始值 ＝ 索引 × 块值
文件_移动读写位置 (文件号, #FILE_BEGIN, 求索引序号占用字节 (初始值))
如果真 (余数 ＞ 0)
块值 ＝ 余数
计次循环首 (块值, i)
文本 ＝ 到字节集 (到文本 (初始值 ＋ i))
写入的文本 ＝ 写入的文本 ＋ 文本 ＋ { 13, 10 }
计次 ＝ 计次 ＋ 1
如果真 (计次 ＝ 50)
文件_写出字节集 (文件号, 写入的文本)
计次 ＝ 0
写入的文本 ＝ {  }

计次循环尾 ()
如果真 (写入的文本 ≠ {  })
文件_写出字节集 (文件号, 写入的文本)
计次 ＝ 0
写入的文本 ＝ {  }
关闭文件 (文件号)

子程序名	返回值类型	公开	备 注
求索引序号占用字节	长整数型
参数名	类 型	参考	可空	数组	备 注
最大索引序号	长整数型				填写整数

变量名	类 型	静态	数组	备 注
字节数	长整数型
数字长度	整数型
剩余数	长整数型
换行长度	整数型
积数	长整数型
十的次方	长整数型
循环次数	整数型
最大索引	长整数型

换行长度 ＝ 2
最大索引 ＝ 最大索引序号
判断循环首 (最大索引 ＞ 0)
循环次数 ＝ 循环次数 ＋ 1
数字长度 ＝ 取文本长度 (到文本 (最大索引))
判断 (数字长度 ＞ 1)
十的次方 ＝ 求次方 (10, 数字长度 － 1)
剩余数 ＝ 最大索引 ��� (最大索引 － 十的次方) － 1
积数 ＝ 最大索引 － 剩余数
最大索引 ＝ 剩余数
字节数 ＝ 字节数 ＋ 积数 �� (数字长度 ＋ 换行长度)

字节数 ＝ 字节数 ＋ 最大索引 �� (1 ＋ 换行长度)
跳出循环 ()

判断循环尾 ()
返回 (字节数)

i支持库列表	支持库注释
spec	特殊功能支持库

.版本 2<br /> .支持库 spec<br /> <br /> 快速生成索引文件 (“e:\123.txt”, 11600000)<br /> <br /> .子程序 快速生成索引文件, 双精度小数型<br /> .参数 文件路径, 文本型, 可空<br /> .参数 最大索引, 长整数型, 可空<br /> .局部变量 文件号, 整数型<br /> .局部变量 线程数, 整数型<br /> .局部变量 块值, 整数型<br /> .局部变量 余数, 双精度小数型<br /> .局部变量 i, 整数型<br /> .局部变量 启动时间, 整数型<br /> '快速创建一个以空白字节填充的文件<br /> 文件号 ＝ 文件_打开文件A (文件路径, , , #CREATE_ALWAYS)<br /> 文件_移动读写位置Ex (文件号, #FILE_BEGIN, 求索引序号占用字节 (最大索引))<br /> 文件_设置文件尾 (文件号)<br /> 文件_关闭文件 (文件号)<br /> <br /> 线程数 ＝ 3<br /> 块值 ＝ 绝对取整 (最大索引 ÷ 线程数)<br /> 余数 ＝ 绝对取整 (最大索引 ％ 线程数)<br /> 启动时间 ＝ 取启动时间 ()<br /> <br /> 集_线程池.创建 (线程数, 线程数, , , )<br /> .计次循环首 (线程数, i)<br />     集_线程池.投递任务 (&子程序1, i － 1, 块值)<br />     程序_延时 (100)<br /> .计次循环尾 ()<br /> .如果真 (余数 ≠ 0)<br />     子程序1 (i － 1, 块值, 余数)<br /> .如果真结束<br /> <br /> .判断循环首 (集_线程池.取_是否空闲 () ＝ 假)<br />     程序_延时 (100)<br /> .判断循环尾 ()<br /> 集_线程池.销毁 ()<br /> 调试输出 (“执行完毕”, 取启动时间 () － 启动时间)<br /> 返回 (0)<br /> <br /> .子程序 子程序1<br /> .参数 索引, 整数型<br /> .参数 块值, 整数型<br /> .参数 余数, 整数型<br /> .局部变量 文件号, 整数型<br /> .局部变量 i, 整数型<br /> .局部变量 初始值, 双精度小数型<br /> .局部变量 文本, 字节集<br /> .局部变量 写入的文本, 字节集<br /> .局部变量 计次, 整数型<br /> <br /> 文件号 ＝ 文件_打开文件A (“e:\123.txt”, , #FILE_SHARE_READ ＋ #FILE_SHARE_WRITE, #OPEN_ALWAYS, )<br /> 初始值 ＝ 索引 × 块值<br /> 文件_移动读写位置 (文件号, #FILE_BEGIN, 求索引序号占用字节 (初始值))<br /> <br /> .如果真 (余数 ＞ 0)<br />     块值 ＝ 余数<br /> .如果真结束<br /> .计次循环首 (块值, i)<br /> <br />     文本 ＝ 到字节集 (到文本 (初始值 ＋ i))<br />     写入的文本 ＝ 写入的文本 ＋ 文本 ＋ { 13, 10 }<br /> <br />     计次 ＝ 计次 ＋ 1<br />     .如果真 (计次 ＝ 50)<br />         文件_写出字节集 (文件号, 写入的文本)<br />         计次 ＝ 0<br />         写入的文本 ＝ {  }<br />     .如果真结束<br /> <br /> <br /> .计次循环尾 ()<br /> <br /> .如果真 (写入的文本 ≠ {  })<br />     文件_写出字节集 (文件号, 写入的文本)<br />     计次 ＝ 0<br />     写入的文本 ＝ {  }<br /> <br /> .如果真结束<br /> 关闭文件 (文件号)<br /> <br /> <br /> .子程序 求索引序号占用字节, 长整数型<br /> .参数 最大索引序号, 长整数型, , 填写整数<br /> .局部变量 字节数, 长整数型<br /> .局部变量 数字长度, 整数型<br /> .局部变量 剩余数, 长整数型<br /> .局部变量 换行长度, 整数型<br /> .局部变量 积数, 长整数型<br /> .局部变量 十的次方, 长整数型<br /> .局部变量 循环次数, 整数型<br /> .局部变量 最大索引, 长整数型<br /> <br /> 换行长度 ＝ 2<br /> 最大索引 ＝ 最大索引序号<br /> <br /> .判断循环首 (最大索引 ＞ 0)<br />     循环次数 ＝ 循环次数 ＋ 1<br />     数字长度 ＝ 取文本长度 (到文本 (最大索引))<br /> <br />     .判断开始 (数字长度 ＞ 1)<br />         十的次方 ＝ 求次方 (10, 数字长度 － 1)<br />         剩余数 ＝ 最大索引 － (最大索引 － 十的次方) － 1<br />         积数 ＝ 最大索引 － 剩余数<br />         最大索引 ＝ 剩余数<br />         字节数 ＝ 字节数 ＋ 积数 × (数字长度 ＋ 换行长度)<br /> <br />     .默认<br />         字节数 ＝ 字节数 ＋ 最大索引 × (1 ＋ 换行长度)<br />         跳出循环 ()<br />     .判断结束<br /> <br /> .判断循环尾 ()<br /> 返回 (字节数)

福仔

会不会是多个线程打架? 这个线程要写入这个位置, 另一个线程又要写入其他位置, 如果加锁的话, 那么切换线程就会花费时间
可以试试每个线程写一个文件, 等所有线程执行完毕后把每个线程写入的数据拼接到一个文件上
也没测试过, 也不知道速度会不会快

风清云游

7ian 发表于 2023-7-7 18:21
哎，你同一个文件每条线程都打开一遍…第一次打开保留文件号，后面每个线程都往这个文件号写就行 ...

问题不在这儿
1，对文本一言难尽的处理方式
2，多线程只是cpu的职权范围 却要参合硬盘的事儿
3，明明可以顺序读写 折腾成了乱序

帅气与大侠

7ian 发表于 2023-7-7 18:21
哎，你同一个文件每条线程都打开一遍…第一次打开保留文件号，后面每个线程都往这个文件号写就行 ...

我知道的，最早用的就是一个文件号，多个线程公用一个文件号写入，但是效果不理想，速度慢，每个线程还要自己不断的记录各个线程的读写位置，测试来测试去，1160万的序号生成，单线程要25秒，2-3个线程20秒左右，线程数超过5个以上速度反而更慢了

7ian

风清云游 发表于 2023-7-7 18:20
一个人买10杯奶茶 和 十人 一人一杯奶茶
孰快孰慢？

不是，他就是要一杯奶茶10个人喝，但是每人10根吸管只能从一个口吸，没有做开10个口分别吸

7ian

哎，你同一个文件每条线程都打开一遍…第一次打开保留文件号，后面每个线程都往这个文件号写就行

风清云游

一个人买10杯奶茶 和 十人 一人一杯奶茶
孰快孰慢？