#Region "Microsoft.VisualBasic::a3a8716019759962594f97202009f9eb, ..\sciBASIC.ComputingServices\ComputingServices\Environment.vb"

    ' Author:
    ' 
    '       asuka (amethyst.asuka@gcmodeller.org)
    '       xieguigang (xie.guigang@live.com)
    '       xie (genetics@smrucc.org)
    ' 
    ' Copyright (c) 2016 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 <http://www.gnu.org/licenses/>.

#End Region

Imports System.Runtime.CompilerServices
Imports System.Threading
Imports Microsoft.VisualBasic.Language
Imports Microsoft.VisualBasic.Linq
Imports Microsoft.VisualBasic.Parallel.Linq
Imports Microsoft.VisualBasic.Parallel.Tasks
Imports sciBASIC.ComputingServices.TaskHost

''' <summary>
''' 分布式计算环境，因为这里是为了做高性能计算而构建的一个内部网络的计算集群，
''' 所以数据再网络传输的过程之中加密与否已经无所谓了
''' </summary>
''' <remarks>
''' ```vbnet
''' '
''' ' ------Dragon be here!------
''' '        ┏┓    ┏┓
''' '     ┏━━┛┻━━━━┛┻━━┓
''' '     ┃            ┃
''' '     ┃     ━━     ┃
''' '     ┃  ┳━┛  ┗━┳  ┃
''' '     ┃　　　 　　　┃
''' '     ┃     ━┻━    ┃
''' '     ┃            ┃
''' '     ┗━┓        ┏━┛
''' '       ┃        ┃ 神兽保佑
''' '       ┃        ┃ 代码无BUG
''' '       ┃        ┗━━┓
''' '       ┃           ┣┓
''' '       ┃           ┏┛
''' '       ┗━━┓┓┏━━┳┓┏━┛
''' '          ┃┫┫  ┃┫┫
''' '          ┗┻┛  ┗┻┛
''' ' ━━━━━━━━━━神兽出没━━━━━━━━━━
''' ```
''' </remarks>
Public Module Environment

    Dim cluster As Cluster.Master

    ''' <summary>
    ''' 扫描局域网内所有可用的计算节点
    ''' </summary>
    ''' <param name="port">The default port of the <see cref="TaskInvoke"/> cluster nodes is **1234**</param>
    Public Sub Start(netRange$, Optional port% = 1234)
        cluster = New Cluster.Master(netRange, port)
        cluster.ScanTask()

        Call Thread.Sleep(1000)
    End Sub

    ''' <summary>
    ''' Running this task sequence in distribution mode.(使用分布式的方式来执行这个任务集合序列)
    ''' </summary>
    ''' <typeparam name="T"></typeparam>
    ''' <typeparam name="Tout"></typeparam>
    ''' <param name="source"></param>
    ''' <returns></returns>
    ''' 
    <Extension>
    Public Iterator Function AsDistributed(Of T, Tout)(source As IEnumerable(Of T), task As [Delegate], ParamArray args As Object()) As IEnumerable(Of Tout)
        Dim partitions = TaskPartitions.SplitIterator(source, source.Count / cluster.Nodes)
        Dim tasks As New List(Of AsyncHandle(Of Tout()))

        For Each part As T() In partitions
            tasks += New AsyncHandle(Of Tout())(Function() cluster.Select(Of T, Tout)(part, task, args).ToArray)
        Next

        For Each out As AsyncHandle(Of Tout()) In tasks
            For Each x As Tout In out.GetValue
                Yield x
            Next
        Next
    End Function
End Module