diff --git a/ComputingServices/ComputingServices.vbproj b/ComputingServices/ComputingServices.vbproj index d529560..5c3bb92 100644 --- a/ComputingServices/ComputingServices.vbproj +++ b/ComputingServices/ComputingServices.vbproj @@ -208,6 +208,7 @@ + True @@ -224,9 +225,9 @@ True - - - + + + diff --git a/ComputingServices/Taskhost.d/Linq/ILinq(Of T).vb b/ComputingServices/Linq/ILinq(Of T).vb similarity index 100% rename from ComputingServices/Taskhost.d/Linq/ILinq(Of T).vb rename to ComputingServices/Linq/ILinq(Of T).vb diff --git a/ComputingServices/Taskhost.d/Linq/LinqPool.vb b/ComputingServices/Linq/LinqPool.vb similarity index 97% rename from ComputingServices/Taskhost.d/Linq/LinqPool.vb rename to ComputingServices/Linq/LinqPool.vb index e9b7ea0..86733b3 100644 --- a/ComputingServices/Taskhost.d/Linq/LinqPool.vb +++ b/ComputingServices/Linq/LinqPool.vb @@ -1,167 +1,167 @@ -#Region "Microsoft.VisualBasic::069775a9dca65fb20879e79072bf05f8, ComputingServices\Taskhost.d\Linq\LinqPool.vb" - - ' Author: - ' - ' asuka (amethyst.asuka@gcmodeller.org) - ' xie (genetics@smrucc.org) - ' xieguigang (xie.guigang@live.com) - ' - ' Copyright (c) 2018 GPL3 Licensed - ' - ' - ' GNU GENERAL PUBLIC LICENSE (GPL3) - ' - ' - ' This program is free software: you can redistribute it and/or modify - ' it under the terms of the GNU General Public License as published by - ' the Free Software Foundation, either version 3 of the License, or - ' (at your option) any later version. - ' - ' This program is distributed in the hope that it will be useful, - ' but WITHOUT ANY WARRANTY; without even the implied warranty of - ' MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the - ' GNU General Public License for more details. - ' - ' You should have received a copy of the GNU General Public License - ' along with this program. If not, see . - - - - ' /********************************************************************************/ - - ' Summaries: - - ' Class LinqPool - ' - ' Function: GetLinq, OpenQuery - ' - ' Sub: (+2 Overloads) Dispose, Free - ' Class __openTask - ' - ' Constructor: (+1 Overloads) Sub New - ' Function: OpenQuery - ' - ' - ' - ' - ' /********************************************************************************/ - -#End Region - -Imports System.Threading -Imports Microsoft.VisualBasic.Net -Imports Microsoft.VisualBasic.Parallel.Tasks - -Namespace TaskHost - - Public Class LinqPool : Implements IDisposable - - ''' - ''' linq池 - ''' - ReadOnly __linq As New Dictionary(Of String, LinqProvider) - ReadOnly __openQuerys As New TaskQueue(Of IPEndPoint) - - Public Function GetLinq(uid As String) As LinqProvider - Return __linq(uid) - End Function - - ''' - ''' uid参数是Linq Portal的Tostring函数的结果 - ''' - ''' - Public Sub Free(uid As String) - If Not __linq.ContainsKey(uid) Then Return - - Dim x As LinqProvider = __linq(uid) - Call x.Free ' 释放Linq数据源的指针 - - SyncLock __linq - Call __linq.Remove(uid) ' 从哈希表之中移除数据源释放服务器资源 - End SyncLock - End Sub - - ''' - ''' - ''' - ''' - ''' - ''' 这里应该是集合的类型，函数会自动从这个类型信息之中得到元素的类型； - ''' 假若函数获取得到集合之中的元素的类型失败的话，则会直接使用所传入的类型参数作为集合之中的元素类型 - ''' - ''' - Public Function OpenQuery(source As IEnumerable, type As Type) As IPEndPoint - Dim elType As Type = type.GetTypeElement(True) - If elType Is Nothing Then - elType = type - End If - - Dim task As New __openTask(__linq) With { - .elType = elType, - .source = source - } - Return __openQuerys.Join(AddressOf task.OpenQuery) - End Function - - Private Class __openTask - - ReadOnly __linq As Dictionary(Of String, LinqProvider) - - Public source As IEnumerable - Public elType As Type - - Sub New(ByRef linq As Dictionary(Of String, LinqProvider)) - __linq = linq - End Sub - - Public Function OpenQuery() As IPEndPoint - Dim linq As New LinqProvider(source, elType) ' 创建 Linq 数据源 - Dim portal As IPEndPoint = linq.Portal - Dim uid As String = portal.ToString - - Call __linq.Add(portal.ToString, linq) ' 数据源添加入哈希表之中 - - Return portal - End Function - End Class - -#Region "IDisposable Support" - Private disposedValue As Boolean ' To detect redundant calls - - ' IDisposable - Protected Overridable Sub Dispose(disposing As Boolean) - If Not Me.disposedValue Then - If disposing Then - ' TODO: dispose managed state (managed objects). - - For Each x In __linq - Call Free(x.Key) - Next - - Call __linq.Free - End If - - ' TODO: free unmanaged resources (unmanaged objects) and override Finalize() below. - ' TODO: set large fields to null. - End If - Me.disposedValue = True - End Sub - - ' TODO: override Finalize() only if Dispose(disposing As Boolean) above has code to free unmanaged resources. - 'Protected Overrides Sub Finalize() - ' ' Do not change this code. Put cleanup code in Dispose(disposing As Boolean) above. - ' Dispose(False) - ' MyBase.Finalize() - 'End Sub - - ' This code added by Visual Basic to correctly implement the disposable pattern. - Public Sub Dispose() Implements IDisposable.Dispose - ' Do not change this code. Put cleanup code in Dispose(disposing As Boolean) above. - Dispose(True) - ' TODO: uncomment the following line if Finalize() is overridden above. - ' GC.SuppressFinalize(Me) - End Sub -#End Region - - End Class -End Namespace +#Region "Microsoft.VisualBasic::069775a9dca65fb20879e79072bf05f8, ComputingServices\Taskhost.d\Linq\LinqPool.vb" + + ' Author: + ' + ' asuka (amethyst.asuka@gcmodeller.org) + ' xie (genetics@smrucc.org) + ' xieguigang (xie.guigang@live.com) + ' + ' Copyright (c) 2018 GPL3 Licensed + ' + ' + ' GNU GENERAL PUBLIC LICENSE (GPL3) + ' + ' + ' This program is free software: you can redistribute it and/or modify + ' it under the terms of the GNU General Public License as published by + ' the Free Software Foundation, either version 3 of the License, or + ' (at your option) any later version. + ' + ' This program is distributed in the hope that it will be useful, + ' but WITHOUT ANY WARRANTY; without even the implied warranty of + ' MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the + ' GNU General Public License for more details. + ' + ' You should have received a copy of the GNU General Public License + ' along with this program. If not, see . + + + + ' /********************************************************************************/ + + ' Summaries: + + ' Class LinqPool + ' + ' Function: GetLinq, OpenQuery + ' + ' Sub: (+2 Overloads) Dispose, Free + ' Class __openTask + ' + ' Constructor: (+1 Overloads) Sub New + ' Function: OpenQuery + ' + ' + ' + ' + ' /********************************************************************************/ + +#End Region + +Imports System.Threading +Imports Microsoft.VisualBasic.Net +Imports Microsoft.VisualBasic.Parallel.Tasks + +Namespace TaskHost + + Public Class LinqPool : Implements IDisposable + + ''' + ''' linq池 + ''' + ReadOnly __linq As New Dictionary(Of String, LinqProvider) + ReadOnly __openQuerys As New TaskQueue(Of IPEndPoint) + + Public Function GetLinq(uid As String) As LinqProvider + Return __linq(uid) + End Function + + ''' + ''' uid参数是Linq Portal的Tostring函数的结果 + ''' + ''' + Public Sub Free(uid As String) + If Not __linq.ContainsKey(uid) Then Return + + Dim x As LinqProvider = __linq(uid) + Call x.Free ' 释放Linq数据源的指针 + + SyncLock __linq + Call __linq.Remove(uid) ' 从哈希表之中移除数据源释放服务器资源 + End SyncLock + End Sub + + ''' + ''' + ''' + ''' + ''' + ''' 这里应该是集合的类型，函数会自动从这个类型信息之中得到元素的类型； + ''' 假若函数获取得到集合之中的元素的类型失败的话，则会直接使用所传入的类型参数作为集合之中的元素类型 + ''' + ''' + Public Function OpenQuery(source As IEnumerable, type As Type) As IPEndPoint + Dim elType As Type = type.GetTypeElement(True) + If elType Is Nothing Then + elType = type + End If + + Dim task As New __openTask(__linq) With { + .elType = elType, + .source = source + } + Return __openQuerys.Join(AddressOf task.OpenQuery) + End Function + + Private Class __openTask + + ReadOnly __linq As Dictionary(Of String, LinqProvider) + + Public source As IEnumerable + Public elType As Type + + Sub New(ByRef linq As Dictionary(Of String, LinqProvider)) + __linq = linq + End Sub + + Public Function OpenQuery() As IPEndPoint + Dim linq As New LinqProvider(source, elType) ' 创建 Linq 数据源 + Dim portal As IPEndPoint = linq.Portal + Dim uid As String = portal.ToString + + Call __linq.Add(portal.ToString, linq) ' 数据源添加入哈希表之中 + + Return portal + End Function + End Class + +#Region "IDisposable Support" + Private disposedValue As Boolean ' To detect redundant calls + + ' IDisposable + Protected Overridable Sub Dispose(disposing As Boolean) + If Not Me.disposedValue Then + If disposing Then + ' TODO: dispose managed state (managed objects). + + For Each x In __linq + Call Free(x.Key) + Next + + Call __linq.Free + End If + + ' TODO: free unmanaged resources (unmanaged objects) and override Finalize() below. + ' TODO: set large fields to null. + End If + Me.disposedValue = True + End Sub + + ' TODO: override Finalize() only if Dispose(disposing As Boolean) above has code to free unmanaged resources. + 'Protected Overrides Sub Finalize() + ' ' Do not change this code. Put cleanup code in Dispose(disposing As Boolean) above. + ' Dispose(False) + ' MyBase.Finalize() + 'End Sub + + ' This code added by Visual Basic to correctly implement the disposable pattern. + Public Sub Dispose() Implements IDisposable.Dispose + ' Do not change this code. Put cleanup code in Dispose(disposing As Boolean) above. + Dispose(True) + ' TODO: uncomment the following line if Finalize() is overridden above. + ' GC.SuppressFinalize(Me) + End Sub +#End Region + + End Class +End Namespace diff --git a/ComputingServices/Taskhost.d/Linq/LinqProvider.vb b/ComputingServices/Linq/LinqProvider.vb similarity index 100% rename from ComputingServices/Taskhost.d/Linq/LinqProvider.vb rename to ComputingServices/Linq/LinqProvider.vb diff --git a/ComputingServices/Linq/NamespaceDoc.vb b/ComputingServices/Linq/NamespaceDoc.vb new file mode 100644 index 0000000..c4a46f7 --- /dev/null +++ b/ComputingServices/Linq/NamespaceDoc.vb @@ -0,0 +1,8 @@ +Namespace Linq + + ''' + ''' Linq校本化: 通过Linq查询表达式进行数据查询以及复杂函数运算 + ''' + Module NamespaceDoc + End Module +End Namespace \ No newline at end of file