lineage2/l2j_mobius
2
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

Add pending update when it does not exist in list.

Browse Source
This commit is contained in:
MobiusDevelopment
2021-01-23 13:03:14 +00:00
parent b1ad584b76
commit 89f2e72b69
2 changed files with 26 additions and 12 deletions
Download Patch File Download Diff File Expand all files Collapse all files

19
L2J_Mobius_C4_ScionsOfDestiny/java/org/l2jmobius/gameserver/taskmanager/BuyListTaskManager.java
View File

@@ -53,7 +53,10 @@ public class BuyListTaskManager
final Integer time = entry.getKey(); final Integer time = entry.getKey();
synchronized (PENDING_UPDATES) synchronized (PENDING_UPDATES)
{ {
PENDING_UPDATES.add(time); if (!PENDING_UPDATES.contains(time))
{
PENDING_UPDATES.add(time);
}
} }
REFRESH_TIME.put(time, currentTime + (time.intValue() * 60 * 60 * 1000L)); REFRESH_TIME.put(time, currentTime + (time.intValue() * 60 * 60 * 1000L));
} }
@@ -86,19 +89,23 @@ public class BuyListTaskManager
}, 50, 50); }, 50, 50);
} }
public void addTime(int time, long refreshTime) public void addTime(int timeValue, long updateValue)
{ {
if (refreshTime == 0) final Integer time = Integer.valueOf(timeValue);
if (updateValue == 0)
{ {
synchronized (PENDING_UPDATES) synchronized (PENDING_UPDATES)
{ {
PENDING_UPDATES.add(time); if (!PENDING_UPDATES.contains(time))
{
PENDING_UPDATES.add(time);
}
} }
REFRESH_TIME.put(time, System.currentTimeMillis() + (time * 60 * 60 * 1000L)); REFRESH_TIME.put(time, System.currentTimeMillis() + (timeValue * 60 * 60 * 1000L));
} }
else else
{ {
REFRESH_TIME.put(time, refreshTime); REFRESH_TIME.put(time, updateValue);
} }
} }

19
L2J_Mobius_C6_Interlude/java/org/l2jmobius/gameserver/taskmanager/BuyListTaskManager.java
View File

@@ -53,7 +53,10 @@ public class BuyListTaskManager
final Integer time = entry.getKey(); final Integer time = entry.getKey();
synchronized (PENDING_UPDATES) synchronized (PENDING_UPDATES)
{ {
PENDING_UPDATES.add(time); if (!PENDING_UPDATES.contains(time))
{
PENDING_UPDATES.add(time);
}
} }
REFRESH_TIME.put(time, currentTime + (time.intValue() * 60 * 60 * 1000L)); REFRESH_TIME.put(time, currentTime + (time.intValue() * 60 * 60 * 1000L));
} }
@@ -86,19 +89,23 @@ public class BuyListTaskManager
}, 50, 50); }, 50, 50);
} }
public void addTime(int time, long refreshTime) public void addTime(int timeValue, long updateValue)
{ {
if (refreshTime == 0) final Integer time = Integer.valueOf(timeValue);
if (updateValue == 0)
{ {
synchronized (PENDING_UPDATES) synchronized (PENDING_UPDATES)
{ {
PENDING_UPDATES.add(time); if (!PENDING_UPDATES.contains(time))
{
PENDING_UPDATES.add(time);
}
} }
REFRESH_TIME.put(time, System.currentTimeMillis() + (time * 60 * 60 * 1000L)); REFRESH_TIME.put(time, System.currentTimeMillis() + (timeValue * 60 * 60 * 1000L));
} }
else else
{ {
REFRESH_TIME.put(time, refreshTime); REFRESH_TIME.put(time, updateValue);
} }
} }