Вот я создал тестовые приложения
сервис
1.
2.
3.
4.
5.
6.
7.
8.
9.
10.
11.
12.
13.
14.
15.
16.
17.
18.
19.
20.
21.
22.
23.
24.
25.
26.
27.
28.
29.
[ServiceContract]
public interface IService1
{
[OperationContract]
void AddData(IEnumerable<double> values);
[OperationContract]
double GetData();
}
[ServiceBehavior(InstanceContextMode = InstanceContextMode.Single, ConcurrencyMode = ConcurrencyMode.Multiple)]
public class Service1 : IService1
{
Queue<double> _q = new Queue<double>();
public void AddData(IEnumerable<double> values)
{
foreach (var val in values)
{
_q.Enqueue(val);
Thread.Sleep(500);
}
}
public double GetData()
{
return _q.Dequeue();
}
}
клиент
1.
2.
3.
4.
5.
6.
7.
8.
9.
10.
11.
12.
13.
14.
15.
16.
17.
18.
19.
20.
21.
22.
23.
24.
25.
26.
27.
28.
29.
30.
31.
32.
33.
34.
class Program
{
static double[] v1 = new double[] { 1, 11, 111, 1111 };
static double[] v2 = new double[] { 2, 22, 222, 2222 };
static double[] v3 = new double[] { 3, 33, 333, 3333 };
static void Main(string[] args)
{
Service1Client client = new Service1Client();
new Thread(
new ThreadStart(
() =>
{
client.AddData(v1);
client.AddData(v2);
client.AddData(v3);
}))
.Start();
new Thread(
new ThreadStart(
() =>
{
while (true)
{
Thread.Sleep(200);
Console.WriteLine(client.GetData());
}
}))
.Start();
}
}
Результат вывода клиента:
ждёт 2 секунды
выводит 1
ждёт 2 секунды
выводит 11
ждёт 2 секунды
выводит 111
затем примерно каждые полсекунды выводит всё остальное - т. е. 1111, 2, 22 и т. д.
Как я это объясняю: сервис отработал синхронно, несмотря на то, что у него стояла настройка ConcurrencyMode.Multiple и клиент тоже работал многопоточно. Т. е. сначала клиент в первом потоке вызвал метод AddData сервиса и сервис добавлял четыре элемента по полсекунды - это и есть первая задержка в 2 секунды в выводе клиента. Затем второй поток клиента достучался до сервиса и выдал первый элемент из очереди. Затем первый поток снова добавлял данные 2 секунды в сервис, потом снова второй поток клиента достал очередное данное из очереди. И так, пока первый поток не добавил все данные в сервис, второй постоянно ждал его. Ну а потом работу продолжил один второй поток на клиенте.
Так почему же не получилось поработать на сервисе многопоточно?
