Как поточно-безопасное перечисление в java? Я реализую Singleton с использованием enum (согласно Bloch Effective Java), Должен ли я вообще беспокоиться о безопасности потоков для моего перечисления singleton? Есть ли способ доказать или опровергнуть, что он является потокобезопасным?
// Enum singleton - the preferred approach
public enum Elvis {
INSTANCE;
public void leaveTheBuilding() { ... }
}
Спасибо
Как сообщает @Mike, создание переименования гарантировано будет потокобезопасным. Однако методы, которые вы добавляете в класс enum, не несут никакой гарантии безопасности потоков. В частности, метод leaveTheBuilding может выполняться одновременно несколькими потоками. Если этот метод имеет побочные эффекты (изменяет состояние некоторой переменной), тогда вам нужно подумать о его защите (т.е. Сделать его synchronized) или его части.
Индивидуальное определение перечисления может быть небезопасным. Например,
RoleEnum.java:
package com.threadsafe.bad;
public enum RoleEnum {
ADMIN(1),
DEV(2),
HEAD(3);
private Integer value;
private RoleEnum(Integer role){
this.value=role;
}
public static RoleEnum fromIntegerValue(Integer role){
for(RoleEnum x : values()){
if(x.value == role ){
return x;
}
}
return RoleEnum.HEAD;
}
Class<?> buildFromClass;
public void setBuildFromClass(Class<?> classType){
buildFromClass=classType;
}
public Class<?> getBuildFromClass(){
return this.buildFromClass;
}
}
Main.java:
package com.threadsafe.bad;
public class Main {
public static void main(String[] args) {
// TODO Auto-generated method stub
Thread threadA = new Thread(){
public void run(){
System.out.println("A started");
RoleEnum role;
role=RoleEnum.fromIntegerValue(1);
System.out.println("A called fromIntegerValue");
role.setBuildFromClass(String.class);
System.out.println("A called setBuildFromClass and start to sleep");
try {
Thread.sleep(10000);
} catch (InterruptedException e) {
// TODO Auto-generated catch block
e.printStackTrace();
}
System.out.println("Thread A: "+role.getBuildFromClass());
}
};
Thread threadB = new Thread(){
public void run(){
System.out.println("B started");
RoleEnum role;
role=RoleEnum.fromIntegerValue(1);
role.setBuildFromClass(Integer.class);
System.out.println("B called fromIntegerValue&setBuildFromClass and Start to sleep");
try {
Thread.sleep(20000);
} catch (InterruptedException e) {
// TODO Auto-generated catch block
e.printStackTrace();
}
System.out.println("B waked up!");
System.out.println("Thread B: "+ role.getBuildFromClass());
}
};
threadA.start();
threadB.start();
}
}
Иногда вывод будет:
B начал
B, вызываемый изIntegerValue & setBuildFromClass и начинающий спать
Запущен
A, вызванный изIntegerValue
Вызывается setBuildFromClass и начинает спать
Тема: класс java.lang.String
B проснулся!
Тема B: класс java.lang.String < -We ожидает java.lang.Integer
Иногда вывод будет:
Запущен
A, вызванный изIntegerValue
Вызывается setBuildFromClass и начинает спать
B начал
B, вызываемый изIntegerValue & setBuildFromClass и начинающий спать
Тема: класс java.lang.Integer < -We ожидает java.lang.String
B проснулся!
Тема B: класс java.lang.Integer
Этот метод абсолютно нитевиден. Значение enum гарантируется только инициализацией только один раз, когда-либо одним потоком, прежде чем он будет использоваться. Тем не менее, я не уверен, будет ли загружаться класс перечисления или первый раз, когда имеет значение enum. Использование этого метода на самом деле немного безопаснее, чем другие методы, потому что нет даже способа с отражением, чтобы получить вторую копию вашего одноэлементного элемента, основанного на перечислении.
Добавление синхронизируемой информации позволяет избежать несогласованного состояния с перечислениями.
Приведённый ниже код будет блокировать красивую печать "Один". Однако, когда вы закомментируете синхронизацию, будут напечатаны и другие значения.
import java.util.Random;
import java.util.concurrent.atomic.AtomicInteger;
public class TestEnum
{
public static AtomicInteger count = new AtomicInteger(1);
public static enum E
{
One("One"),
Two("Two");
String s;
E(final String s)
{
this.s = s;
}
public void set(final String s)
{
this.s = s;
}
public String get()
{
return this.s;
}
}
public static void main(final String[] args)
{
doit().start();
doit().start();
doit().start();
}
static Thread doit()
{
return new Thread()
{
@Override
public void run()
{
String name = "MyThread_" + count.getAndIncrement();
System.out.println(name + " started");
try
{
int i = 100;
while (--i >= 0)
{
synchronized (E.One)
{
System.out.println(E.One.get());
E.One.set("A");
Thread.sleep(new Random().nextInt(100));
E.One.set("B");
Thread.sleep(new Random().nextInt(100));
E.One.set("C");
Thread.sleep(new Random().nextInt(100));
E.One.set("One");
System.out.println(E.One.get());
}
}
}
catch (InterruptedException e)
{
// TODO Auto-generated catch block
e.printStackTrace();
}
System.out.println(name + " ended");
}
};
}
}