donnyep / cosmosframework Goto Github PK

        public void PauseAllTask()
        {
            foreach (var taskId in taskDict.Keys)
            {
                PauseTask(taskId);
            }
        }

        public void UnPauseAllTask()
        {
            foreach (var taskId in taskDict.Keys)
            {
                UnPauseTask(taskId);
            }
        }

  public bool PauseTask(int taskId)
        {
            if (!taskDict.TryRemove(taskId, out TickTask task))
                return false;
            task.IsPause = true;
                var remainTime= task.DestTime - GetUTCMilliseconds();
            task.PauseRemainTime = remainTime > 0 ? remainTime : 0;
            return true;
        }
        public bool UnPauseTask(int taskId)
        {
            if (!taskDict.TryRemove(taskId, out TickTask task))
                return false;
            task.IsPause = false;
            task.DestTime = task.PauseRemainTime + GetUTCMilliseconds();
            return true;
        }

NullReferenceException: Object reference not set to an instance of an object
Cosmos.Test.MyObjectSpawner+<Start>d__13.MoveNext () (at Assets/Examples/ExampleScripts/08_ObjectPool/MyObjectSpawner.cs:36)
--- End of stack trace from previous location where exception was thrown ---
System.Runtime.ExceptionServices.ExceptionDispatchInfo.Throw () (at <eae584ce26bc40229c1b1aa476bfa589>:0)
System.Runtime.CompilerServices.AsyncMethodBuilderCore+<>c.<ThrowAsync>b__6_0 (System.Object state) (at <eae584ce26bc40229c1b1aa476bfa589>:0)
UnityEngine.UnitySynchronizationContext+WorkRequest.Invoke () (at /Users/bokken/buildslave/unity/build/Runtime/Export/Scripting/UnitySynchronizationContext.cs:153)
UnityEngine.UnitySynchronizationContext:ExecuteTasks() (at /Users/bokken/buildslave/unity/build/Runtime/Export/Scripting/UnitySynchronizationContext.cs:107)

            //注意，这里是毫秒单位；
            tickTimer.AddTask(100, OnSpawnTime, null, int.MaxValue);
            //此写法的实际意义为，生成的单位存活时间为15秒；
            //await new WaitForSeconds(15f);
            tickTimer.AddTask(10, 1500, OnDespawnTime, null, int.MaxValue);

NullReferenceException: Object reference not set to an instance of an object
Cosmos.TickTimer.TickRefresh () (at Assets/CosmosFramework/Runtime/Base/Timer/TickTimer.cs:192)
Cosmos.Test.MyObjectSpawner.Update () (at Assets/Examples/ExampleScripts/08_ObjectPool/MyObjectSpawner.cs:52)

task.TaskCallback.Invoke(task.TaskId,task.UserData);

        // add 'Disconnected' event to receive pipe so that the caller
        // knows that the Connect failed. otherwise they will never know
        state.receivePipe.Enqueue(0, EventType.Disconnected, default);
        
        // sendthread might be waiting on ManualResetEvent,
        // so let's make sure to end it if the connection
        // closed.
        // otherwise the send thread would only end if it's
        // actually sending data while the connection is
        // closed.
        sendThread?.Interrupt();

        // Connect might have failed. thread might have been closed.
        // let's reset connecting state no matter what.
        state.Connecting = false;

        // if we got here then we are done. ReceiveLoop cleans up already,
        // but we may never get there if connect fails. so let's clean up
        // here too.
        state.client?.Close();
    }

    IEnumerator EnumGetFileSize(string uri, Action<long> callback)
    {
        using (UnityWebRequest request = UnityWebRequest.Head(uri))
        {
            yield return request.SendWebRequest();
            string size = request.GetResponseHeader("Content-Length");

            if (request.result != UnityWebRequest.Result.ConnectionError && request.result != UnityWebRequest.Result.ProtocolError)
                callback?.Invoke(-1);
            else
                callback?.Invoke(Convert.ToInt64(size));
        }
    }

    public Square[] GetNearbySquares(float posX, float posY, int level = 0)
    {
        if (!IsOverlapping(posX, posY))
            return new Square[0];

        level = level >= 0 ? level : 0;
        if (level == 0)
            return new Square[] { square2d[col, row] };
        if (level == CellSection)
            return square1d;
        int sideCellCount = level * 2 + 1;
        int squareCount = sideCellCount * sideCellCount;
        Square[] neabySquares = new Square[squareCount + 1];
        int idx = 0;
        for (int x = -level; x <= level; x++)
        {
            for (int y = -level; y <= level; y++)
            {
                int idxX = col + x;
                int idxY = row + y;
                if (idxX < CellSection && idxX >= 0 && idxY < CellSection && idxY >= 0)
                {
                    neabySquares[idx] = square2d[idxX, idxY];
                    idx++;
                }
            }
        }
        var dstSquares = new Square[idx];

        Array.Copy(neabySquares, 0, dstSquares, 0, idx);
        return dstSquares;
    }