Полностью параллельный процесс

[Altodor]

У меня RTS, в ней выбранные юниты по определённой команде начинают вычисление небольшой задачки. Но эту небольшую задачку они решают где-то 0.25 сек. На это время игра подвисает. Эта задача реализована в виде простой функции, возвращающей ArrayList. Как её запустить отдельным процессом? Чтобы подвисла не вся игра, а только тот юнит, которому дали команду? Смотрел StartCoroutine, но не понял никакого смысла в yield... Если эта проблема решается с помощью StartCoroutine, прокомментируйте пожалуйста, как это сделать.. Проблема ещё в том, что эта функция обязательно должна возвратить юниту результат своей работы, а StartCoroutine просто запускается, без возвращения чего-либо.

[DbIMok]

Синтаксис:

Синтаксис: [ Показать ]

Используется csharp

using UnityEngine;
using System.Collections;

public class example : MonoBehaviour {

    private ArrayList _arrList; // для передачи результата

    void Start()
    {
        StartCoroutine(MyCalc()); // запускаем корутину
    }

    IEnumerator MyCalc()
    {
        for (...)
        {
            _arrList.Add(...)
            yield return 0;  // в этом месте непрерывность выполнения прерывается
        }
        WorkFinished();  // вызвать действие над результатом работы
    }

    void WorkFinished()
    {
        _arrList...
    }
}

[burlak]

Вроде про Корутины написано, что они не кушают потоки - т.е. выполняются в основном процессе. С другой стороны тред нужен в основном, чтобы распараллелить работу. Если же юнит будет ожидать от треда результат, зачем нужен тред?

Возможно стоит разделить код на исполнение задачи и постановку задачи. Тред, например регулярно обновляет какие то данные для юнита, а юнит выполняет то, что на текущий момент записано в его данных. В данном случае юнит не ждет а вычисление реально запихать в System.Threading.Thread

Может быть если каждый юнит будет решать задачу в свое время - не все вместе, вразнобой, то игрушка не будет подвисать столь ощутимо.

[zoon]

Вы можете делать вычисления в отдельном потоке средствами C# и фреймворка. Советую почитать гениальный e-book http://www.albahari.com/threading/

Можно взять готовую обертку, типа Task из C# 4. Но поскольку в Unity фреймворк только 3.5, можно использовать упрощенный аналог отсюда: http://msdn.microsoft.com/en-us/magazine/cc163552.aspx

Синтаксис:

Синтаксис: [ Показать ]

Используется csharp

public class Future<T> : IDisposable
{

    // Fields
    private readonly Func<T> _func;
    private Exception _except;
    private T _value;
    private ManualResetEvent _mre;

    // Constructors
    public Future(Func<T> func)
    {
        _func = func;
        ThreadPool.QueueUserWorkItem(Worker);
    }

    // Properties
    public bool IsDone { get; private set; }

    public T Value
    {
        get
        {
            // If the future isn't completed, we wait.
            if (!IsDone)
            {
                _mre = new ManualResetEvent(false);
                Thread.MemoryBarrier();
                if (IsDone)
                {
                    _mre.Close();
                    _mre = null;
                }
                else
                {
                    _mre.WaitOne();
                }
            }

            // If an exception was thrown by the future, repropagate it.
            if (_except != null)
            {
                throw _except;
            }

            return _value;
        }
    }

    // Methods
    public void Dispose()
    {
        if (_mre != null)
        {
            _mre.Close();
            _mre = null;
        }
    }

    private void Worker(object obj)
    {
        try
        {
            _value = _func();
        }
        catch (Exception e)
        {
            // Capture the exception. It will be propagated when the consumer
            // rendezvous with the future.
            _except = e;
        }
        finally
        {
            IsDone = true;
            Thread.MemoryBarrier();
            if (_mre != null)
            {
                _mre.Set();
            }
        }
    }

}
 

PS. Rx Reactive не советую, а то опять Neodrop будет заставлять писать тьюториал

[Neodrop]

Посмотрите на асинхронные делегаты, чтобы не городить воркеров на 100500 строк.

[zoon]

Посмотрите на асинхронные делегаты, чтобы не городить воркеров на 100500 строк.

Асинхронные делегаты медленные и слишком низкоуровневые и кудрявые для использования напрямую. Фьючерсы (код которого я привел) или Таски во всех отношениях лучше и удобнее.

[romeo_ftv]

http://forum.unity3d.com/threads/90128- ... ing-Helper

[gnoblin]

Еще потенциально интересная штука вот http://code.google.com/p/retlang/
Я не пользовался

[raul82]

интересно а треды роботают в ios android?