9

Как правильно уменьшить размер стека для .NET приложения? Возможно есть какие либо директивы или опции в Visual Studio.

17
  • 1
    Так, уже теплее. А зачем вам 2000 потоков? Может быть, лучше перейти на async/await?
    – VladD
    14 окт 2015 в 19:58
  • 1
    (1) Для увеличения количества потоков нужно по идее не увеличить, а уменьшить стек. (2) Всё равно непонятно, почему не async/await. TCP-сервер вполне можно писать на async/await. Выделять на каждый запрос по потоку — слишком дорогой вариант.
    – VladD
    14 окт 2015 в 20:01
  • 2
    Но всё же, мне кажется, вы идёте неверным путём. Выделять отдельный поток каждому реквесту очень накладно, и вы тем самым налагаете жёсткое ограничение на количество одновременных запросов. Вас можно будет легко заДОСить, просто открыв 20000 соединений и медленно отвечая на запросы. Почему всё же на async/await?
    – VladD
    14 окт 2015 в 20:08
  • 1
    Попробуйте сами ConnectAsync, вы удивитесь :) Потоки не нужны.
    – VladD
    14 окт 2015 в 20:25
  • 3
    Мне сложно говорить по поводу конкретно вашего приложения, но для хорошего сетевого кода очень нетипична синхронная обработка в отдельных потоках. Я бы не советовал идти этим путём, а вместо этого «асинхронизировать» ваше приложение. Но вам, как архитектору проекта, в любом случае виднее.
    – VladD
    14 окт 2015 в 20:32

1 ответ 1

9

Вы можете, например, воспользоваться конструктором Thread с указанием максимального размера стека.


Если вы планируете запускать Task на этом потоке, имеет смысл реализовать TaskScheduler, который перекинет Task в этот поток.

Или можно воспользоваться готовым scheduler'ом, например, WPF.


Пример кода:

При помощи этого метода можно «перебросить» async-метод в поток, на котором бежит данный WPF-диспетчер:

static class AsyncHelper
{
    public static DispatcherRedirector RedirectTo(Dispatcher d)
    {
        return new DispatcherRedirector(d);
    }
}

// http://blogs.msdn.com/b/pfxteam/archive/2011/01/13/10115642.aspx
public struct DispatcherRedirector : INotifyCompletion
{
    public DispatcherRedirector(Dispatcher dispatcher)
    {
        this.dispatcher = dispatcher;
    }

    #region awaiter
    public DispatcherRedirector GetAwaiter()
    {
        // combined awaiter and awaitable
        return this;
    }
    #endregion

    #region awaitable
    public bool IsCompleted
    {
        get
        {
            // true means execute continuation inline
            return dispatcher.CheckAccess();
        }
    }

    public void OnCompleted(Action continuation)
    {
        dispatcher.BeginInvoke(continuation);
    }

    public void GetResult() { }
    #endregion

    Dispatcher dispatcher;
}

Теперь вам нужен поток, в котором бежит диспетчер.

public class DispatcherThread : IDisposable
{
    public Dispatcher Dispatcher { get; private set; }
    public TaskScheduler TaskScheduler { get; private set; }

    Thread thread;

    public DispatcherThread(int maxStackSize)
    {
        using (var barrier = new AutoResetEvent(false))
        {
            thread = new Thread(() =>
            {
                Dispatcher = Dispatcher.CurrentDispatcher;
                barrier.Set();
                Dispatcher.Run();
            }, maxStackSize);

            thread.SetApartmentState(ApartmentState.STA);
            thread.Start();
            barrier.WaitOne();
        }

        TaskScheduler = Get(() => TaskScheduler.FromCurrentSynchronizationContext());
    }

    // ---------------------------------------------
    // остальные функции вам не нужны для вашей задачи, но могут пригодиться впоследствии
    public void Execute(Action a)
    {
        if (Dispatcher.CheckAccess())
            a();
        else
            Dispatcher.Invoke(a);
    }

    public void FireAndForget(Action a)
    {
        Dispatcher.BeginInvoke(a);
    }

    public T Get<T>(Func<T> getter)
    {
        if (Dispatcher.CheckAccess())
            return getter();
        else
        {
            T t = default(T);
            Dispatcher.Invoke((Action)(() => { t = getter(); }));
            return t;
        }
    }

    public Task<T> GetAsync<T>(Func<T> getter)
    {
        return Dispatcher.InvokeAsync(getter).Task;
    }

    public Task StartNewTask(Action action)
    {
        return Task.Factory.StartNew(
                    action: action,
                    cancellationToken: CancellationToken.None,
                    creationOptions: TaskCreationOptions.None,
                    scheduler: TaskScheduler);
    }

    public Task<T> StartNewTask<T>(Func<T> function)
    {
        return Task.Factory.StartNew(
                    function: function,
                    cancellationToken: CancellationToken.None,
                    creationOptions: TaskCreationOptions.None,
                    scheduler: TaskScheduler);
    }

    public void Dispose()
    {
        Dispatcher.InvokeShutdown();
        if (thread != Thread.CurrentThread)
            thread.Join();
    }
}

Этим можно пользоваться, например, так:

using (var t = new DispatcherThread(maxStackSize))
{
    await AsyncHelper.RedirectTo(t.Dispatcher);
    // остаток метода
}

Обновление: совсем забыл, надо же по идее сбежать из умирающего потока! Например, в thread pool.

static class AsyncHelper
{
    public static ThreadPoolRedirector RedirectToThreadPool()
    {
        return new ThreadPoolRedirector();
    }
}

public struct ThreadPoolRedirector : INotifyCompletion
{
    #region awaiter
    public ThreadPoolRedirector GetAwaiter()
    {
        // combined awaiter and awaitable
        return this;
    }
    #endregion

    #region awaitable
    public bool IsCompleted
    {
        get
        {
            // true means execute continuation inline
            return Thread.CurrentThread.IsThreadPoolThread;
        }
    }

    public void OnCompleted(Action continuation)
    {
        ThreadPool.QueueUserWorkItem(o => continuation());
    }

    public void GetResult() { }
    #endregion
}

и использовать как

using (var t = new DispatcherThread(maxStackSize))
{
    await AsyncHelper.RedirectTo(t.Dispatcher);
    // остаток метода
    await AsyncHelper.RedirectToThreadPool();
}

Хотя может быть это и не нужно, InvokeShutdown не убивает поток немедленно. Но тем не менее.


Более современная версия DispatcherThread — в этом ответе.

21
  • А как быть для Task? Я не использую Thread.
    – Alexis
    14 окт 2015 в 20:12
  • 1
    @z668: Окей, тогда вам нужен собственный TaskScheduler, который будет выполнять Task на указанном вами потоке или потоках.
    – VladD
    14 окт 2015 в 20:22
  • Благодарю, думаю стоит добавить это в ответ. Пошел ковырять исходники LongRunning.
    – Alexis
    14 окт 2015 в 20:31
  • 1
    @z668: LongRunning просто запускает Task на thread pool'е.
    – VladD
    14 окт 2015 в 20:33
  • 1
    @z668: Вот и хорошо :) Не стоит благодарности, информация должна быть свободной!
    – VladD
    14 окт 2015 в 20:53

Ваш ответ

Нажимая на кнопку «Отправить ответ», вы соглашаетесь с нашими условиями использования и подтверждаете, что прочитали и поняли наши политику конфиденциальности и нормы поведения.

Всё ещё ищете ответ? Посмотрите другие вопросы с метками или задайте свой вопрос.