java 线程安全代码 +原子方法问题

发布于 2024-08-12 21:09:59 字数 831 浏览 1 评论 0原文

我有一个类管理器将被多个线程同时访问，我想知道我是否以正确的方式进行了操作？
我也认为我需要 RemoveFoo 是原子的，但我不确定

public class Manager
{
    private ConcurrentHashMap<String, Foo> foos;
    //init in constructor

    public RemoveFoo(String name)
    {
        Foo foo = foos.Get(name);
        foo.RemoveAll();
        foos.Remove(name);
    }

    public AddFoo(Foo foo)
    {...}
}

public class Foo
{
    private Map<String,Bar> bars;
    //intialize it in constructor

    //same for RemoveBar
    public void AddBar(Bar bar)
    {
        synchronized(this)
        {
            bars.put(bar.id, bar);
        }
    }

    public void RemoveAll()
    {
        synchronized(this)
        {
            //some before removall logic for each one
            bars.remove(bar.id, bar);
        }
    }

}

public class Bar
{}

原文

I have a class Manager that is going to be accessed by multiple threads at the same time, I want to know if I did it the right way ?
also I think I need RemoveFoo to be atomic, but I'm not sure

public class Manager
{
    private ConcurrentHashMap<String, Foo> foos;
    //init in constructor

    public RemoveFoo(String name)
    {
        Foo foo = foos.Get(name);
        foo.RemoveAll();
        foos.Remove(name);
    }

    public AddFoo(Foo foo)
    {...}
}

public class Foo
{
    private Map<String,Bar> bars;
    //intialize it in constructor

    //same for RemoveBar
    public void AddBar(Bar bar)
    {
        synchronized(this)
        {
            bars.put(bar.id, bar);
        }
    }

    public void RemoveAll()
    {
        synchronized(this)
        {
            //some before removall logic for each one
            bars.remove(bar.id, bar);
        }
    }

}

public class Bar
{}

分享到QQ

分享到微博

如果你对这篇内容有疑问，欢迎到本站社区发帖提问参与讨论，获取更多帮助，或者扫码二维码加入 Web 技术交流群。

发布评论

需要登录才能够评论，你可以免费注册一个本站的账号。

旧竹 2024-08-19 21:09:59

当您使用 ConcurrentHashMap 时，您不需要同步方法，但请注意 Foo foo = foos.Get(name) 可能会返回 null，因为另一个线程可能已经从映射中删除了该条目。

成员可以声明为 Map; foos，但必须缩写为 foos = new ConcurrentHashMap;

回复收藏 0 原文

诗酒趁年少 2024-08-19 21:09:59

RemoveFoo 可能会出现问题。我建议使用：

Foo foo = foos.remove (name);
if (foo != null) foo.removeAll();

代替。这可以确保地图在 get() 和 remove() 之间不会发生变化。

在 Foo 中，在 bars 上同步而不是整个实例就足够了。但这只是一个小优化。

RemoveFoo could be problematic. I suggest to use:

Foo foo = foos.remove (name);
if (foo != null) foo.removeAll();

instead. This makes sure that the map doesn't change between get() and remove().

In Foo, it's enough to synchronize on bars instead of the whole instance. But that's just a minor optimization.

回复收藏 0 原文

书信已泛黄 2024-08-19 21:09:59

将 RemoveFoo(String) 声明为 synchronized：

public synchronized void RemoveFoo(String name) {
    …
}

另外，请注意以下事项：

方法名称应小写，例如 removeFoo 而不是 删除Foo。这不是 C#。 :)
每个方法都需要一个返回类型：public removeFoo() 不是有效的方法声明，它需要是 public void removeFoo()。

Declare RemoveFoo(String) as synchronized:

public synchronized void RemoveFoo(String name) {
    …
}

Also, be advised of the following:

method names should be lower case, e.g. removeFoo instead of RemoveFoo. This is not C#. :)
Every method needs a return type: public removeFoo() is not a valid method declaration, it needs to be public void removeFoo().

回复收藏 0 原文