并行数据处理系统及方法

摘要

本发明公开了一种并行数据处理系统和方法。该系统包括：终端装置，用于输入信用风险计量所需参数，以及开始计量信用风险的请求数据；主控单元，根据所述请求数据，将系统当前CPU和内存使用百分比与CPU使用百分比上限以及内存使用百分比上限进行比较，根据比较结果执行相应处理；行业相关性系数生成单元，用于生成计算池的池内相关性系数；并行处理控制单元，用于判断当前的CPU和内存空闲状况是否能够满足N个并行任务的需求，如果能满足，则将资源平均分配给N个并行处理单元；并行处理单元，用于根据所述池内相关性系数以及数据存储装置中存储的相关参数计算违约损失计量。利用本发明的系统和方法能够减少计算时间，提高时效性。

主权项

一种并行数据处理系统，该系统包括：终端装置（3），与主控单元相连接，用于输入信用风险计量所需参数，以及开始计量信用风险的请求数据；主控单元（10），根据从终端装置（3）接收的所述请求数据，将系统当前CPU和内存使用百分比与CPU使用百分比上限以及内存使用百分比上限进行比较，根据比较结果执行相应处理；并行处理控制单元（12），用于判断当前的CPU和内存空闲状况是否能够满足N个并行任务的需求，如果能满足，则将资源平均分配给n个并行处理单元（20）；n个并行处理单元（20），用于计算违约损失计量；数据存储装置（1），与主控单元相连接，用于存储数据；行业相关性系数生成单元（11），用于生成计算池的池内相关性系数；其中，如果比较结果为系统当前CPU和内存使用百分比小于CPU使用百分比上限以及内存使用百分比上限，则调用行业相关性系数生成单元（11）执行相应处理，并行处理单元（20）根据所述池内相关性系数以及数据存储装置（1）中存储的相关参数计算违约损失计量,所述并行处理单元（20）进一步包括：控制单元（200），用于当接收到并行处理控制单元（12）的并行调用请求以及抽样次数后，调用行业系统性收益随机数生成处理单元（201），并传递抽样次数Cases给随机数生成处理单元（201）；随机数生成处理单元（201），用于为n个行业随机抽样生成这n个行业的系统性收益随机数；条件违约概率生成处理单元（202），用于根据行业内的相关系数，在各行业的系统性收益给定的情况下，计算各行业在各个信用等级下的条件违约概率；分池违约损失模拟处理单元（203），将每个计算池按照信用评级个数分成相应个数的统计池，按照统计分池的类型及客户数多少，对于每个统计分池计算每次模拟的违约损失；分池违约损失加总处理单元（204），负责从数据存储装置（1）中读取每个统计池的条件违约概率，对其进行累加，得到整个信贷组合的违约损失，其中，并行处理控制单元（12）从数据存储装置（1）中读取并行任务的并发个数N，如果判断当前的CPU和内存空闲状况不满足并行任务的个数需求，则根据实际资源情况，计算当前系统CPU和内存的空闲资源最大能满足的并发数，将资源平均分配给相应个数的并行处理单元（20），调用其开始并行处理；并行处理单元（20）中按如下规则分配任务：假设总的抽样次数为Cases次，总的统计池数为m，当前系统资源允许n个并行处理单元（20）同时执行并行处理，则系统将对m个统计池的Cases次抽样及相关操作平均分配到各并行处理单元（20）上去完成，每个并行处理单元，一旦接收到并行处理控制单元（12）的调用请求，并获得相应系统资源后，则开始进行违约损失计量。