From 1f13dca44822c38c52fffe4aae5bfcbcf9a5bbf7 Mon Sep 17 00:00:00 2001
From: =?UTF-8?q?=E5=BE=AE=E5=B8=8C=E5=A4=B7?= <63851587@qq.com>
Date: Wed, 15 Jun 2022 07:40:48 +0000
Subject: [PATCH] =?UTF-8?q?!18=20!optimize=20cpu=20used=20*=20!optimize=20?=
 =?UTF-8?q?=E6=97=B6=E9=97=B4=E8=BF=BD=E5=B9=B3=E6=BC=82=E7=A7=BB=E9=87=8F?=
 =?UTF-8?q?=E6=97=B6=EF=BC=8C=E6=8D=9F=E8=80=97=E4=B8=80=E7=82=B9=E6=97=B6?=
 =?UTF-8?q?=E9=97=B4(=E5=BE=AE=E5=A6=99=E7=BA=A7=E5=88=AB)=E9=99=8D?=
 =?UTF-8?q?=E4=BD=8ECPU=E5=8D=A0=E7=94=A8?=
MIME-Version: 1.0
Content-Type: text/plain; charset=UTF-8
Content-Transfer-Encoding: 8bit

---
 PHP/src/snowflake/snowflake.c | 52 +++++++++++++++++++++--------------
 1 file changed, 32 insertions(+), 20 deletions(-)

diff --git a/PHP/src/snowflake/snowflake.c b/PHP/src/snowflake/snowflake.c
index d4325cc..0f32a6e 100644
--- a/PHP/src/snowflake/snowflake.c
+++ b/PHP/src/snowflake/snowflake.c
@@ -4,6 +4,7 @@
 #else
 #include <unistd.h>
 #include <sys/time.h>
+#include <time.h>
 #endif
 #include <stdlib.h>
 #include <stdio.h>
@@ -11,19 +12,19 @@
 #include "spinlock.h"
 
 // static void EndOverCostAction(uint64_t useTimeTick, snowflake *flake);
-static inline uint64_t NextOverCostId(snowflake* flake);
-static inline uint64_t NextNormalId(snowflake* flake);
-static inline uint64_t GetCurrentTimeTick(snowflake* flake);
-static inline uint64_t GetNextTimeTick(snowflake* flake);
-static inline uint64_t CalcId(snowflake* flake);
-static inline uint64_t CalcTurnBackId(snowflake* flake);
+static inline uint64_t NextOverCostId(snowflake *flake);
+static inline uint64_t NextNormalId(snowflake *flake);
+static inline uint64_t GetCurrentTimeTick(snowflake *flake);
+static inline uint64_t GetNextTimeTick(snowflake *flake);
+static inline uint64_t CalcId(snowflake *flake);
+static inline uint64_t CalcTurnBackId(snowflake *flake);
 static inline uint64_t GetSysCurrentTime();
 
 int ncpu;
 uint16_t spin = 2048;
 uint32_t pid = 0;
 
-void Config(snowflake* flake)
+void Config(snowflake *flake)
 {
 	if (pid == 0)
 	{
@@ -132,7 +133,7 @@ void Config(snowflake* flake)
 //   }
 // }
 
-static inline uint64_t NextOverCostId(snowflake* flake)
+static inline uint64_t NextOverCostId(snowflake *flake)
 {
 	uint64_t currentTimeTick = GetCurrentTimeTick(flake);
 	if (currentTimeTick > flake->_LastTimeTick)
@@ -169,7 +170,7 @@ static inline uint64_t NextOverCostId(snowflake* flake)
 	return CalcId(flake);
 }
 
-static inline uint64_t NextNormalId(snowflake* flake)
+static inline uint64_t NextNormalId(snowflake *flake)
 {
 	uint64_t currentTimeTick = GetCurrentTimeTick(flake);
 	if (currentTimeTick < flake->_LastTimeTick)
@@ -221,39 +222,50 @@ static inline uint64_t GetSysCurrentTime()
 	gettimeofday(&t, NULL);
 	return (uint64_t)(t.tv_sec * 1000 + t.tv_usec / 1000);
 #endif
-
 }
 
-static inline uint64_t GetCurrentTimeTick(snowflake* flake)
+static inline uint64_t GetCurrentTimeTick(snowflake *flake)
 {
 	return GetSysCurrentTime() - flake->BaseTime;
 }
 
-static inline uint64_t GetNextTimeTick(snowflake* flake)
+static inline uint64_t GetNextTimeTick(snowflake *flake)
 {
 	uint64_t tempTimeTicker = GetCurrentTimeTick(flake);
-	while (tempTimeTicker <= flake->_LastTimeTick)
+	struct timespec delay;
+	delay.tv_sec = 0;
+	delay.tv_nsec = 500000;
+	while (1)
 	{
 		tempTimeTicker = GetCurrentTimeTick(flake);
+		if (tempTimeTicker > flake->_LastTimeTick)
+		{
+			break;
+		}
+#ifdef WIN32
+		SwitchToThread();
+#else
+		nanosleep(&delay, NULL);
+#endif
 	}
 	return tempTimeTicker;
 }
 
-static inline uint64_t CalcId(snowflake* flake)
+static inline uint64_t CalcId(snowflake *flake)
 {
 	uint64_t result = (flake->_LastTimeTick << flake->_TimestampShift) + (flake->WorkerId << flake->SeqBitLength) + (flake->_CurrentSeqNumber);
 	flake->_CurrentSeqNumber++;
 	return result;
 }
 
-static inline uint64_t CalcTurnBackId(snowflake* flake)
+static inline uint64_t CalcTurnBackId(snowflake *flake)
 {
 	uint64_t result = (flake->_LastTimeTick << flake->_TimestampShift) + (flake->WorkerId << flake->SeqBitLength) + (flake->_TurnBackTimeTick);
 	flake->_TurnBackTimeTick--;
 	return result;
 }
 
-static inline uint64_t NextSonwId(snowflake* flake)
+static inline uint64_t NextSonwId(snowflake *flake)
 {
 	uint64_t currentTimeTick = GetCurrentTimeTick(flake);
 	if (flake->_LastTimeTick == currentTimeTick)
@@ -273,12 +285,12 @@ static inline uint64_t NextSonwId(snowflake* flake)
 	return (uint64_t)((currentTimeTick << flake->_TimestampShift) | (flake->WorkerId << flake->SeqBitLength) | flake->_CurrentSeqNumber);
 }
 
-static inline uint64_t GetId(snowflake* flake)
+static inline uint64_t GetId(snowflake *flake)
 {
 	return flake->Method == 1 ? (flake->_IsOverCost != 0 ? NextOverCostId(flake) : NextNormalId(flake)) : NextSonwId(flake);
 }
 
-uint64_t NextId(snowflake* flake)
+uint64_t NextId(snowflake *flake)
 {
 	spin_lock(&flake->_Lock, pid);
 	uint64_t id = GetId(flake);
@@ -286,9 +298,9 @@ uint64_t NextId(snowflake* flake)
 	return id;
 }
 
-uint64_t* NextNumId(snowflake* flake, uint32_t num)
+uint64_t *NextNumId(snowflake *flake, uint32_t num)
 {
-	uint64_t* arr = (uint64_t*)malloc(sizeof(uint64_t) * num);
+	uint64_t *arr = (uint64_t *)malloc(sizeof(uint64_t) * num);
 	spin_lock(&flake->_Lock, pid);
 	uint32_t i;
 	for (i = 0; i < num; i++)
-- 
GitLab