专家坐堂-【求方案】多线程或计划管理实现多任务同时操作Foxtable(狐表) - 新一代数据库软件，完美融合Access、Foxpro、Excel、vb.net之优势，人人都能掌握的快速软件开发工具!

以文本方式查看主题

-  Foxtable(狐表)  (http://foxtable.com/bbs/index.asp)
--  专家坐堂  (http://foxtable.com/bbs/list.asp?boardid=2)
----  【求方案】多线程或计划管理实现多任务同时操作  (http://foxtable.com/bbs/dispbbs.asp?boardid=2&id=75616)

--  作者：ycli368
--  发布时间：2015/10/11 15:10:00
--  【求方案】多线程或计划管理实现多任务同时操作

想通过多线程或计划管理实现多任务同时操作的目的，目前来看是失败的

1.多线程设计是想多任务同时操作的，现在是一个线程在从CSV读取数据写到datatable中，且这个时间特别久，数据量较大，会导致其他加载表执行失败

‘’‘Dim t As Table = e.For m.Controls("Table1").Table
\'\'\'\'\'\'\'\'\'\'\'\'\'\'\'t.Fill("Select * fr o m creditinquiry where 1 = 2",Conn,False)
t.Cols("quirytime").DataCol.SetDateTimeFormat(DateTimeFormatEnum.DateLongTime)"
-----另外一个窗口数据写入开始，这个窗口打开就报quirytime不存在，说明没加到数据
t.AllowEdit = False
ConfigTable(t.Name,t)
\'For ms("frmWangwangLogin").show()
2.使用委托知会解决UI资源使用问题，委托BASEmainFro m 还是会导致程序假死

--  作者：大红袍
--  发布时间：2015/10/11 16:12:00
--

做例子上来测试

http://www.foxtable.com/bbs/dispbbs.asp?boardid=2&Id=75580

[此贴子已经被作者于2015/10/11 16:12:28编辑过]

--  作者：ycli368
--  发布时间：2015/10/11 16:36:00
--

测试没问题，有问题请上传例子测试

全局代码

Public Sub thread_sub1(ByVal obj As Object)
    functions. Execute("多线程操作", obj)
End Sub

内部函数

Do While vars("stop") = False
    Dim nr As Row = CurrentTable.addnew
    nr(0) = 123456
nr.save() --这里做SAVE操作，然后其他窗口做任意表的加载操作
Loop

调用

vars("stop") = False
Dim nthread As New System.Threading.Thread(AddressOf thread_sub1)
nthread.start(Nothing)

[此贴子已经被作者于2015/10/11 16:36:56编辑过]

--  作者：大红袍
--  发布时间：2015/10/11 16:37:00
--
没问题啊

--  作者：大红袍
--  发布时间：2015/10/11 16:37:00
--
做出错的例子发上来。

--  作者：ycli368
--  发布时间：2015/10/11 16:39:00
--
不会吧，不过我的是外部数据源的表
Dim t As Table = e.Form.Controls("Table1").Table
t.Fill("Select * fro m creditinquiry where 1 = 2",Conn,False)
\'t.DataTable.LoadFilter = "1 = 2"
\'t.DataTable.Load()
t.Cols("quirytime").DataCol.SetDateTimeFormat(DateTimeFormatEnum.DateLongTime)
t.AllowEdit = False
ConfigTable(t.Name,t)
\'Forms("frmWangwangLogin").show()

所有窗口的 afterload 里的类似代码都有问题

--  作者：大红袍
--  发布时间：2015/10/11 16:40:00
--

不理解你想说什么，做例子上传上来。

--  作者：ycli368
--  发布时间：2015/10/11 18:58:00
--
例子做了，重现不了，估计是函数实现的问题，有个报错，请老师帮忙看下

此主题相关图片如下：2015-10-11_185538.jpg

--  作者：ycli368
--  发布时间：2015/10/11 19:05:00
--

Dim TaskName As String = args(0)
Dim Filecsv As String = args(1)
Dim TableNam As String = args(2)
Dim HeadRow As Integer
Dim BootomRow As Integer
Dim cmd As SQLCommand
Dim DtYueShu As DataTable
Dim SaveFlag As Integer = 0
Dim dradd As Row

If cstr(args(3)) = "" Then
HeadRow = 1 \'标题头占几行,为空默认为1
Else If cint(args(3)) < 0 Then
messagebox.show("行参数错误","注意")
Return 1
Else
HeadRow = args(3)
End If

If cstr(args(4)) = "" Then
BootomRow = 0 \'底部汇总占几行,为空默认为0
Else If cint(args(4)) < 0 Then
messagebox.show("底部行参数错误","注意")
Return 1
Else
BootomRow = args(4)
End If

Dim ColNum As Integer
Dim YsFiler As String
Dim zd As New Dictionary(Of String, Integer)
Dim zdfan As New Dictionary(Of Integer, String)
Dim drs As List(of DataRow)
Dim path As String

Dim tempstr() As String = Filecsv.split("\\")
path = left(filecsv,len(filecsv) - len(tempstr(tempstr.length - 1)))

\'获取内外部对应数据及约束列
cmd = New SQLCommand
cmd.CommandText = "select * Fro m {importrelation} where 1 = 2"
cmd.Cfont-family: Verdana;">DtYueShu = cmd.ExecuteReader()

\'messagebox.show(2)

\'Dim YingShe As List(of DataRow) = DataTables("importrelation").sqlselect("表名称 = \'" & TableNam & "\'")
Dim YingShe As List(of DataRow) = DtYueShu.sqlselect("表名称 = \'" & TableNam & "\'")
Dim YsCount As Integer = YingShe.count
\'messagebox.show(1)
If YingShe Is Nothing Then

FileSys.WriteAllText(path & "log.txt", Date.now & ": " & filecsv & "表格式未设置映射,请及时查看" & chr(10), True, Encoding.Default)

Return 1
End If

\'第一次需加载表
If taskctrdic.containskey(taskname) Then
If TaskCtrDic(taskname).Tableisconfig = False Then
\'messagebox.show(2)

\'设置字段类型
For i As Integer = 0 To YsCount - 1

If YingShe(i)("数据类型") = "DateTime" Then
DataTables(TableNam).DataCols(YingShe(i)("外部列字段")).SetDateTimeFormat(DateTimeFormatEnum.DateLongTime)

End If
Next
TaskCtrDic(taskname).Tableisconfig = True


End If
End If
\'messagebox.show("aaa")

\'读取数据然后分行
Dim str As String = FileSys.ReadAllText(Filecsv, Encoding.Default)

\'符号处理
str = str.replace("""", "").trim()
str = str.replace("null", "0").trim()
str = str.replace("\'", "").trim()

\'分行处理
Dim ary() As String = str.Split(chr(10))

\'获取约束列信息
Dim YueShu As List(of DataRow) = DtYueShu.sqlselect("表名称 = \'" & TableNam & "\' And 是否约束列 = True")
\'Dim YueShu As List(of DataRow) = DataTables("importrelation").sqlselect("表名称 = \'" & TableNam & "\' And 是否约束列 = True")
Dim YssCount As Integer = YueShu.count

Dim DataStartRow As Integer
If headrow <> 0 Then
DataStartRow = headrow - 1
Else
DataStartRow = headrow
End If
\'messagebox.show(3)

\'分行处理
For Rowi As Integer = 0 To ary.Length - 1 - BootomRow
\'yanshi(1)
Application.Doevents
\'taskctrdic(taskname).ThreadOpe.sleep(10)
If Rowi Mod 50 = 0 Then
If taskctrdic.containskey(taskname) = False Then
\'taskctrdic.remove(taskname)
Return 1
End If
End If



\'messagebox.show(ary.length - 1 - BootomRow)
\'Return 1
\'第一列为列标头,需要判断是否和存储表一致
Dim ColumnStr() As String = ary(Rowi).Split(",")
ColNum = Columnstr.length
If Rowi <> DataStartRow Then
If vars("ColNum") <> ColNum - 1 Then
FileSys.WriteAllText(path & "log.txt", Date.now & ": " & filecsv & "第" & (Rowi + 1) & "行,表格式有问题,请及时查看" & chr(10), True, Encoding.Default)
Return 1
End If
End If
\'messagebox.show(Colnum)
\'默认第一行未标题,未对无列标题的异常进行判断,暂未发现由此场景
If Rowi = DataStartRow Then
vars("ColNum") = ColNum - 1

For m As Integer = 0 To ColNum - 1
Application.Doevents
Dim Drtmp As DataRow
Drtmp = DtYueShu.sqlfind("内部列字段 = \'" & ColumnStr(m).trim(" ") & "\'" & " And 表名称 = \'" & TableNam & "\'")

If Drtmp IsNot Nothing Then
zd.Add(ColumnStr(m).trim(" "),m)
zdfan.add(m,drtmp("外部列字段"))
\'messagebox.show(ColumnStr(m))
Else
FileSys.WriteAllText(path & "log.txt", Date.now & ": " & filecsv & "表格式有问题,请及时查看" & chr(10), True, Encoding.Default)
Return 1
End If
Next

If ColNum > YsCount Then

messagebox.show("导入表的列数大于存储表列数,请检查","注意")
Return 1
Else \'列头编号

End If

Continue For

End If

\'数据导入
YsFiler = ""
For n As Integer = 0 To YssCount - 1
If n = YssCount - 1 Then

YsFiler = YsFiler & YueShu(n)("外部列字段") & " = \'" & ColumnStr(zd(YueShu(n)("内部列字段"))).trim(""""," ","=") & "\'"
Else

YsFiler = YsFiler & YueShu(n)("外部列字段") & " = \'" & ColumnStr(zd(YueShu(n)("内部列字段"))).trim(""""," ","=") & "\' And "

End If
Application.Doevents
Next

drs = DataTables(TableNam).SQLSelect(YsFiler)
If drs.count = 0 Then


dradd = Tables(TableNam).AddNew()
For j As Integer = 0 To ColNum - 1
\'messagebox.show(j)
\'messagebox.show(YingShe(j)("内部列字段"))
\'messagebox.show(YingShe(j)("外部列字段"))
\'messagebox.show(zd(YingShe(j)("内部列字段")))
\'messagebox.show("OK")
\'dradd(YingShe(j)("外部列字段")) = ColumnStr(zd(YingShe(j)("内部列字段"))).trim(""""," ","=","元")
dradd(zdfan(j)) = ColumnStr(j)
Application.Doevents
Next



While dradd.DataRow.RowState <> DataRowState.Unchanged

\'If dradd.DataRow.RowState <> DataRowState.Unchanged Then
dradd.save()
Application.Doevents
End While

Else
\'更新数据暂未考虑
Application.Doevents

End If
\'SaveFlag = SaveFlag + 1
\'If SaveFlag Mod 50 = 0 Then
\' DataTables(TableNam).save()
\'End If
Next
\'DataTables(TableNam).save()
If taskctrdic.containskey(taskname) Then
TaskCtrDic(Taskname).CurrentNum = TaskCtrDic(Taskname).CurrentNum + 1
End If
Return 0

[此贴子已经被作者于2015/10/11 19:51:01编辑过]

--  作者：sloyy
--  发布时间：2015/10/11 19:39:00
--
多线程,多任务没试过 ,但是多线程单任务我做过,读取新浪的股票数据,用了10线程,8秒读写完2市所有股票 ,蛮好用的.