C\#병렬 및 다 중 스 레 드 프로 그래 밍-병렬 집합 과 PLinq
병렬 산법 의 등장 에 따라 발생 하 는 것 도 병렬 집합 과 스 레 드 안전 집합 이 있다.마이크로소프트 방향 도 주도면밀 하고 링크 를 잊 지 않 았 으 며 링크 의 병렬 버 전,plinq-Parallel Linq 를 출시 했다.
1.병렬 집합―스 레 드 안전 집합
병렬 컴 퓨 팅 에 사용 되 는 여러 스 레 드 를 동시에 계산 하기 때문에 모든 스 레 드 가 자원 에 대한 접근 을 제어 해 야 합 니 다.우 리 는 평소에 자주 사용 하 는 List
using System;
using System.Collections.Generic;
using System.Linq;
using System.Text;
using System.Threading.Tasks;
using System.Collections.Concurrent;
namespace ThreadPool
{
public class PEnumerable
{
public static void ListWithParallel()
{
List<int> list = new List<int>();
Parallel.For(0, 10000, item =>
{
list.Add(item);
});
Console.WriteLine("List's count is {0}",list.Count());
}
}
}
결과 에 나타 난 5851 을 보 았 지만 우 리 는 10000 번 을 순환 했다!왜 결과 가 틀 렸 지?이것 은 List
다음은 병렬 집합-스 레 드 안전 집합 을 살 펴 보 겠 습 니 다.System.collections.Concurrent 네 임 스페이스 에서 먼저 ConcurrentBag
public static void ConcurrentBagWithPallel()
{
ConcurrentBag<int> list = new ConcurrentBag<int>();
Parallel.For(0, 10000, item =>
{
list.Add(item);
});
Console.WriteLine("ConcurrentBag's count is {0}", list.Count());
}
컨 커 런 트 백 집합 결과 가 정확 하 다 는 것 을 알 수 있다.다음은 코드 를 수정 하여 ConcurrentBag 안의 데 이 터 를 어떻게 저장 하 는 지 보 겠 습 니 다.코드 를 수정 하면 다음 과 같 습 니 다.
public static void ConcurrentBagWithPallel()
{
ConcurrentBag<int> list = new ConcurrentBag<int>();
Parallel.For(0, 10000, item =>
{
list.Add(item);
});
Console.WriteLine("ConcurrentBag's count is {0}", list.Count());
int n = 0;
foreach(int i in list)
{
if (n > 10)
break;
n++;
Console.WriteLine("Item[{0}] = {1}",n,i);
}
Console.WriteLine("ConcurrentBag's max item is {0}", list.Max());
}
이 를 통 해 알 수 있 듯 이 ConcurrentBag 의 데 이 터 는 순서대로 배열 되 어 있 지 않 고 순서 가 어 지 럽 고 무 작위 적 이다.우리 가 평소에 사용 하 는 Max,First,Last 등 linq 방법 은 모두 있다.그 시 기 는 Enumerable 과 유사 한 용법 이 므 로 마이크로소프트 의 MSDN 을 참고 하여 구체 적 인 용법 을 알 수 있다.
스 레 드 안전 에 관 한 집합 은 아직도 많 습 니 다.우리 가 평소에 사용 하 는 집합 과 차이 가 많 지 않 습 니 다.예 를 들 어 Dictionary 와 유사 한 Concurrent Dictionary,그리고 Concurrent Stack,ConcurrentQueue 등 이 있 습 니 다.
2.Parallel Linq 의 용법 및 성능
1、AsParallel
앞서 병행 하 는 For 와 foreach 에 대해 알 아 봤 는데,오늘 은 Linq 의 병행 버 전이 어떤 지 볼 까요?테스트 를 위해 사용자 정의 클래스 를 추가 합 니 다.코드 는 다음 과 같 습 니 다.
public class Custom
{
public string Name { get; set; }
public int Age { get; set; }
public string Address { get; set; }
}
public static void TestPLinq()
{
Stopwatch sw = new Stopwatch();
List<Custom> customs = new List<Custom>();
for (int i = 0; i < 2000000; i++)
{
customs.Add(new Custom() { Name = "Jack", Age = 21, Address = "NewYork" });
customs.Add(new Custom() { Name = "Jime", Age = 26, Address = "China" });
customs.Add(new Custom() { Name = "Tina", Age = 29, Address = "ShangHai" });
customs.Add(new Custom() { Name = "Luo", Age = 30, Address = "Beijing" });
customs.Add(new Custom() { Name = "Wang", Age = 60, Address = "Guangdong" });
customs.Add(new Custom() { Name = "Feng", Age = 25, Address = "YunNan" });
}
sw.Start();
var result = customs.Where<Custom>(c => c.Age > 26).ToList();
sw.Stop();
Console.WriteLine("Linq time is {0}.",sw.ElapsedMilliseconds);
sw.Restart();
sw.Start();
var result2 = customs.AsParallel().Where<Custom>(c => c.Age > 26).ToList();
sw.Stop();
Console.WriteLine("Parallel Linq time is {0}.", sw.ElapsedMilliseconds);
}
시간 이 배로 차이 가 났 지만 가끔 은 이렇게 차이 가 나 지 않 을 때 가 있 습 니 다.시스템 의 현재 자원 이 용 률 을 봐 야 합 니 다.많이 테스트 해 보 세 요.
사실,AsParallel()이 방법 은 List
2,GroupBy 방법
프로젝트 에서 우 리 는 항상 데 이 터 를 처리 해 야 합 니 다.예 를 들 어 조별 통 계 를 통 해 우 리 는 linq 에서 도 실현 할 수 있다 는 것 을 알 고 있 습 니 다.오늘 은 새로운 ToLookup 방법 을 배우 고 테스트 방법 을 쓰 겠 습 니 다.코드 는 다음 과 같 습 니 다.
public static void OrderByTest()
{
Stopwatch stopWatch = new Stopwatch();
List<Custom> customs = new List<Custom>();
for (int i = 0; i < 2000000; i++)
{
customs.Add(new Custom() { Name = "Jack", Age = 21, Address = "NewYork" });
customs.Add(new Custom() { Name = "Jime", Age = 26, Address = "China" });
customs.Add(new Custom() { Name = "Tina", Age = 29, Address = "ShangHai" });
customs.Add(new Custom() { Name = "Luo", Age = 30, Address = "Beijing" });
customs.Add(new Custom() { Name = "Wang", Age = 60, Address = "Guangdong" });
customs.Add(new Custom() { Name = "Feng", Age = 25, Address = "YunNan" });
}
stopWatch.Restart();
var groupByAge = customs.GroupBy(item => item.Age).ToList();
foreach (var item in groupByAge)
{
Console.WriteLine("Age={0},count = {1}", item.Key, item.Count());
}
stopWatch.Stop();
Console.WriteLine("Linq group by time is: " + stopWatch.ElapsedMilliseconds);
stopWatch.Restart();
var lookupList = customs.ToLookup(i => i.Age);
foreach (var item in lookupList)
{
Console.WriteLine("LookUP:Age={0},count = {1}", item.Key, item.Count());
}
stopWatch.Stop();
Console.WriteLine("LookUp group by time is: " + stopWatch.ElapsedMilliseconds);
}
ToLookup 방법 은 집합 을 읽 기 전용 집합 으로 바 꾸 는 것 이기 때문에 빅 데 이 터 를 그룹 으로 나 눌 때 List 보다 성능 이 좋 습 니 다.관련 자 료 를 찾 아 볼 수 있 습 니 다.여 기 는 지면 문제 로 더 이상 자세히 말 하지 않 습 니 다.
이상 은 C\#병렬 및 다 중 스 레 드 프로 그래 밍-병렬 집합 과 PLinq 의 상세 한 내용 입 니 다.C\#병렬 및 다 중 스 레 드 프로 그래 밍 에 관 한 자 료 는 다른 관련 글 을 주목 하 십시오!
이 내용에 흥미가 있습니까?
현재 기사가 여러분의 문제를 해결하지 못하는 경우 AI 엔진은 머신러닝 분석(스마트 모델이 방금 만들어져 부정확한 경우가 있을 수 있음)을 통해 가장 유사한 기사를 추천합니다:
C#Task를 사용하여 비동기식 작업을 수행하는 방법라인이 완성된 후에 이 라인을 다시 시작할 수 없습니다.반대로 조인(Join)만 결합할 수 있습니다 (프로세스가 현재 라인을 막습니다). 임무는 조합할 수 있는 것이다. 연장을 사용하여 그것들을 한데 연결시키는 것이...
텍스트를 자유롭게 공유하거나 복사할 수 있습니다.하지만 이 문서의 URL은 참조 URL로 남겨 두십시오.
CC BY-SA 2.5, CC BY-SA 3.0 및 CC BY-SA 4.0에 따라 라이센스가 부여됩니다.
좋은 웹페이지 즐겨찾기
